builder

Documentation

Index

• type Builder
  • func (builder *Builder) BuildDiscovery(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (service.Service, []service.Middleware, error)
  • func (builder *Builder) BuildEvents(ctx context.Context, cfg config.DynamicConfig) (*event.Broker, error)
  • func (builder *Builder) BuildHttpApi(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (service.Service, []service.Middleware, error)
  • func (builder *Builder) BuildMiddlewares(ctx context.Context, srvc service.Service, sys system.AbstractSystem, ...) (mws []service.Middleware, err error)
  • func (builder *Builder) BuildMongo(ctx context.Context, cfg config.DynamicConfig) (MongoInfo, error)
  • func (builder *Builder) BuildPostgres(ctx context.Context, cfg config.DynamicConfig) (*pgxpool.Pool, error)
  • func (builder *Builder) BuildProcessor(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (service.Service, []service.Middleware, error)
  • func (builder *Builder) BuildRedis(ctx context.Context, cfg config.DynamicConfig) (redis.UniversalClient, error)
  • func (builder *Builder) BuildResources(ctx context.Context, cfg config.DynamicConfig) (resource.Storage, error)
  • func (builder *Builder) BuildScheduler(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (srvc service.Service, mws []service.Middleware, err error)
  • func (builder *Builder) BuildServiceCore(ctx context.Context, defaultName string, cfg config.DynamicConfig) (service.Core, error)
  • func (builder *Builder) BuildStatus(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (service.Service, []service.Middleware, error)
  • func (builder *Builder) BuildSystem(ctx context.Context, cfg config.SystemConfig) (system.System, error)
  • func (builder *Builder) BuildTasks(ctx context.Context, cfg config.DynamicConfig) (record.Storage[task.Task], error)
• type MongoInfo
  • func (info MongoInfo) GetCollection() *mongo.Collection
• type ServiceData

Types

type Builder

type Builder struct{}

func (*Builder) BuildDiscovery

func (builder *Builder) BuildDiscovery(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (service.Service, []service.Middleware, error)

func (*Builder) BuildEvents

func (builder *Builder) BuildEvents(ctx context.Context, cfg config.DynamicConfig) (*event.Broker, error)

func (*Builder) BuildHttpApi

func (builder *Builder) BuildHttpApi(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (service.Service, []service.Middleware, error)

func (*Builder) BuildMiddlewares

func (builder *Builder) BuildMiddlewares(ctx context.Context, srvc service.Service, sys system.AbstractSystem, cfg config.DynamicConfig) (mws []service.Middleware, err error)

func (*Builder) BuildMongo

func (builder *Builder) BuildMongo(ctx context.Context, cfg config.DynamicConfig) (MongoInfo, error)

func (*Builder) BuildPostgres

func (builder *Builder) BuildPostgres(ctx context.Context, cfg config.DynamicConfig) (*pgxpool.Pool, error)

func (*Builder) BuildProcessor

func (builder *Builder) BuildProcessor(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (service.Service, []service.Middleware, error)

func (*Builder) BuildRedis

func (builder *Builder) BuildRedis(ctx context.Context, cfg config.DynamicConfig) (redis.UniversalClient, error)

func (*Builder) BuildResources

func (builder *Builder) BuildResources(ctx context.Context, cfg config.DynamicConfig) (resource.Storage, error)

func (*Builder) BuildScheduler

func (builder *Builder) BuildScheduler(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (srvc service.Service, mws []service.Middleware, err error)

func (*Builder) BuildServiceCore

func (builder *Builder) BuildServiceCore(ctx context.Context, defaultName string, cfg config.DynamicConfig) (service.Core, error)

func (*Builder) BuildStatus

func (builder *Builder) BuildStatus(ctx context.Context, sys system.AbstractSystem, cfg config.DynamicConfig) (service.Service, []service.Middleware, error)

func (*Builder) BuildSystem

func (builder *Builder) BuildSystem(ctx context.Context, cfg config.SystemConfig) (system.System, error)

func (*Builder) BuildTasks

func (builder *Builder) BuildTasks(ctx context.Context, cfg config.DynamicConfig) (record.Storage[task.Task], error)

type MongoInfo

type MongoInfo struct {
	Client     *mongo.Client
	Collection string
	Database   string
}

func (MongoInfo) GetCollection

func (info MongoInfo) GetCollection() *mongo.Collection

type ServiceData

type ServiceData[T any] struct {
	Info T `mapstructure:"$"`
}