cloud/ocis
1
0
Fork 0
mirror of https://github.com/owncloud/ocis.git synced 2025-04-18 23:44:07 +03:00
Code

chore: change constant name to camelcase

Browse Source
This commit is contained in:
Juan Pablo Villafáñez 2025-03-19 10:29:01 +01:00
parent 37b064e977
commit f4644a6225
21 changed files with 23 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ocis-pkg/generators/natsnames.go
View File

@ -9,9 +9,9 @@ import (
type NType int
const (
NTYPE_BUS NType = iota
NTYPE_KEYVALUE
NTYPE_REGISTRY
NTypeBus NType = iota
NTypeKeyValue
NTypeRegistry
)
func (n NType) String() string {

2
ocis-pkg/natsjsregistry/registry.go
View File

@ -201,7 +201,7 @@ func (n *storeregistry) storeOptions(opts registry.Options) []store.Option {
storeoptions = append(storeoptions, store.Nodes(addr...))
natsOptions := nats.GetDefaultOptions()
natsOptions.Name = generators.GenerateConnectionName(serviceName, generators.NTYPE_REGISTRY)
natsOptions.Name = generators.GenerateConnectionName(serviceName, generators.NTypeRegistry)
natsOptions.User, natsOptions.Password = getAuth()
natsOptions.ReconnectedCB = func(_ *nats.Conn) {
if err := n.Init(); err != nil {

2
services/activitylog/pkg/command/server.go
View File

@ -71,7 +71,7 @@ func Server(cfg *config.Config) *cli.Command {
defer cancel()
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
evStream, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Events))
if err != nil {
logger.Error().Err(err).Msg("Failed to initialize event stream")

2
services/antivirus/pkg/service/service.go
View File

@ -108,7 +108,7 @@ func (av Antivirus) Run() error {
av.c.Events.TLSInsecure = false
}
connName := generators.GenerateConnectionName(av.c.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(av.c.Service.Name, generators.NTypeBus)
natsStream, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(av.c.Events))
if err != nil {
return err

2
services/audit/pkg/command/server.go
View File

@ -37,7 +37,7 @@ func Server(cfg *config.Config) *cli.Command {
)
defer cancel()
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
client, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Events))
if err != nil {
return err

2
services/clientlog/pkg/command/server.go
View File

@ -69,7 +69,7 @@ func Server(cfg *config.Config) *cli.Command {
defer cancel()
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
s, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Events))
if err != nil {
return err

2
services/eventhistory/pkg/command/server.go
View File

@ -56,7 +56,7 @@ func Server(cfg *config.Config) *cli.Command {
m.BuildInfo.WithLabelValues(version.GetString()).Set(1)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
consumer, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Events))
if err != nil {
return err

2
services/frontend/pkg/command/events.go
View File

@ -35,7 +35,7 @@ var _registeredEvents = []events.Unmarshaller{
// ListenForEvents listens for events and acts accordingly
func ListenForEvents(ctx context.Context, cfg *config.Config, l log.Logger) error {
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
bus, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Events))
if err != nil {
l.Error().Err(err).Msg("cannot connect to nats")

2
services/graph/pkg/server/http/server.go
View File

@ -54,7 +54,7 @@ func Server(opts ...Option) (http.Service, error) {
if options.Config.Events.Endpoint != "" {
var err error
connName := generators.GenerateConnectionName(options.Config.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(options.Config.Service.Name, generators.NTypeBus)
eventsStream, err = stream.NatsFromConfig(connName, false, stream.NatsConfig(options.Config.Events))
if err != nil {
options.Logger.Error().

2
services/notifications/pkg/command/send_email.go
View File

@ -34,7 +34,7 @@ func SendEmail(cfg *config.Config) *cli.Command {
if !daily && !weekly {
return errors.New("at least one of '--daily' or '--weekly' must be set")
}
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
s, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Notifications.Events))
if err != nil {
return err

2
services/notifications/pkg/command/server.go
View File

@ -96,7 +96,7 @@ func Server(cfg *config.Config) *cli.Command {
registeredEvents[typ.String()] = e
}
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
client, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Notifications.Events))
if err != nil {
return err

2
services/policies/pkg/command/server.go
View File

@ -105,7 +105,7 @@ func Server(cfg *config.Config) *cli.Command {
{
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
bus, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Events))
if err != nil {
return err

2
services/postprocessing/pkg/command/postprocessing.go
View File

@ -41,7 +41,7 @@ func RestartPostprocessing(cfg *config.Config) *cli.Command {
return configlog.ReturnFatal(parser.ParseConfig(cfg))
},
Action: func(c *cli.Context) error {
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
stream, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Postprocessing.Events))
if err != nil {
return err

2
services/postprocessing/pkg/command/server.go
View File

@ -48,7 +48,7 @@ func Server(cfg *config.Config) *cli.Command {
}
{
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
bus, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Postprocessing.Events))
if err != nil {
return err

2
services/proxy/pkg/command/server.go
View File

@ -157,7 +157,7 @@ func Server(cfg *config.Config) *cli.Command {
var publisher events.Stream
if cfg.Events.Endpoint != "" {
var err error
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
publisher, err = stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Events))
if err != nil {
logger.Error().

2
services/search/pkg/service/grpc/v0/service.go
View File

@ -80,7 +80,7 @@ func NewHandler(opts ...Option) (searchsvc.SearchProviderHandler, func(), error)
return nil, teardown, fmt.Errorf("unknown search extractor: %s", cfg.Extractor.Type)
}
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
bus, err := stream.NatsFromConfig(connName, false, stream.NatsConfig{
Endpoint: cfg.Events.Endpoint,
Cluster: cfg.Events.Cluster,

2
services/sharing/pkg/revaconfig/config.go
View File

@ -136,7 +136,7 @@ func SharingConfigFromStruct(cfg *config.Config, logger log.Logger) (map[string]
"tls-insecure": cfg.Events.TLSInsecure,
"tls-root-ca-cert": cfg.Events.TLSRootCaCertPath,
"enable-tls": cfg.Events.EnableTLS,
"name": generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS),
"name": generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus),
"username": cfg.Events.AuthUsername,
"password": cfg.Events.AuthPassword,
},

2
services/sse/pkg/command/server.go
View File

@ -53,7 +53,7 @@ func Server(cfg *config.Config) *cli.Command {
}
{
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
natsStream, err := stream.NatsFromConfig(connName, true, stream.NatsConfig(cfg.Events))
if err != nil {
return err

2
services/storage-users/pkg/event/event.go
View File

@ -9,7 +9,7 @@ import (
// NewStream prepares the requested nats stream and returns it.
func NewStream(cfg *config.Config) (events.Stream, error) {
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
return stream.NatsFromConfig(connName, false, stream.NatsConfig{
Endpoint: cfg.Events.Addr,
Cluster: cfg.Events.ClusterID,

2
services/storage-users/pkg/revaconfig/config.go
View File

@ -58,7 +58,7 @@ func StorageUsersConfigFromStruct(cfg *config.Config) map[string]interface{} {
"tls-insecure": cfg.Events.TLSInsecure,
"tls-root-ca-cert": cfg.Events.TLSRootCaCertPath,
"enable-tls": cfg.Events.EnableTLS,
"name": generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS),
"name": generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus),
"username": cfg.Events.AuthUsername,
"password": cfg.Events.AuthPassword,
},

2
services/userlog/pkg/command/server.go
View File

@ -79,7 +79,7 @@ func Server(cfg *config.Config) *cli.Command {
defer cancel()
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTYPE_BUS)
connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
stream, err := stream.NatsFromConfig(connName, false, stream.NatsConfig(cfg.Events))
if err != nil {
return err