wireset

Documentation

Index

• Variables
• func InitializeChoiceExecutor(logger zerolog.Logger) *choiceExecutor.ChoiceExecutor
• func InitializeConfig(configPath string) (cfg config.Config, err error)
• func InitializeDBHelperWorker(config config.Config, db *gorm.DB) *dbhelper.DBHelperWorker
• func InitializeDatabase(config config.Config) (*gorm.DB, error)
• func InitializeGraphqlSchema(config config.Config, mq mq.MQ, db *gorm.DB, tracer *opentracer.ServiceTracer, ...) generated.Config
• func InitializeGrpcHandler(logger zerolog.Logger) *grpc.GrpcHandler
• func InitializeHttpHandler(logger zerolog.Logger) *http.HttpHandler
• func InitializeHttpServer(config config.Config, graphqlConfig generated.Config, ...) *graph.HttpServer
• func InitializeLocker(config config.Config) (lock.Locker, error)
• func InitializeLogger(config config.Config) (zerolog.Logger, error)
• func InitializeMQ(config config.Config, logger zerolog.Logger) (mq.MQ, error)
• func InitializeNatsHandler(logger zerolog.Logger) *nats.NatsHandler
• func InitializeOpenTracer(config config.Config, logger zerolog.Logger) (opentracer.OpenTracer, error)
• func InitializeParallelExecutor(config config.Config, mq mq.MQ, logger zerolog.Logger) *parallelExecutor.ParallelExecutor
• func InitializePassExecutor(logger zerolog.Logger) *passExecutor.PassExecutor
• func InitializePubSubHandler(logger zerolog.Logger) *pubsub.PubSubHandler
• func InitializeRedisStreamHandler(logger zerolog.Logger) *redisstream.RedisStreamHandler
• func InitializeScheduleWorker(config config.Config, mq mq.MQ, lock lock.Locker, logger zerolog.Logger, ...) *scheduler.ScheduleWorker
• func InitializeServiceTracer(config config.Config, tracer opentracer.OpenTracer) *opentracer.ServiceTracer
• func InitializeTaskExecutor(http *http.HttpHandler, grpc *grpc.GrpcHandler, pubsub *pubsub.PubSubHandler, ...) *taskExecutor.TaskExecutor
• func InitializeTaskWorker(taskExecutor *taskExecutor.TaskExecutor, ...) *task.TaskWorker
• func InitializeWaitExecutor(logger zerolog.Logger) *waitExecutor.WaitExecutor
• func InitializeWorker(config config.Config, db *gorm.DB, lock lock.Locker, logger zerolog.Logger, ...) *initializer.InitializeWorker

Variables

var ConfigSet = wire.NewSet(
	InitializeConfig,
)

var DatabaseSet = wire.NewSet(
	InitializeDatabase,
)

var EndpointSet = wire.NewSet(
	InitializeHttpHandler,
	InitializeGrpcHandler,
	InitializePubSubHandler,
	InitializeNatsHandler,
	InitializeRedisStreamHandler,
)

var ExecutorSet = wire.NewSet(
	InitializeParallelExecutor,
	InitializePassExecutor,
	InitializeTaskExecutor,
	InitializeWaitExecutor,
	InitializeChoiceExecutor,
)

var GraphqlSchemaSet = wire.NewSet(
	InitializeGraphqlSchema,
)

var HttpSet = wire.NewSet(
	InitializeHttpServer,
)

var LockerSet = wire.NewSet(
	InitializeLocker,
)

var LoggerSet = wire.NewSet(
	InitializeLogger,
)

var MQSet = wire.NewSet(
	InitializeMQ,
)

var TracerSet = wire.NewSet(
	InitializeServiceTracer,
	InitializeOpenTracer,
)

var WorkerSet = wire.NewSet(
	InitializeWorker,
	InitializeTaskWorker,
	InitializeScheduleWorker,
	InitializeDBHelperWorker,
)

Functions

func InitializeChoiceExecutor

func InitializeChoiceExecutor(
	logger zerolog.Logger,
) *choiceExecutor.ChoiceExecutor

func InitializeConfig

func InitializeConfig(configPath string) (cfg config.Config, err error)

func InitializeDBHelperWorker

func InitializeDBHelperWorker(
	config config.Config,
	db *gorm.DB,
) *dbhelper.DBHelperWorker

func InitializeDatabase

func InitializeDatabase(config config.Config) (*gorm.DB, error)

func InitializeGraphqlSchema

func InitializeGraphqlSchema(config config.Config, mq mq.MQ, db *gorm.DB, tracer *opentracer.ServiceTracer, logger zerolog.Logger) generated.Config

func InitializeGrpcHandler

func InitializeGrpcHandler(logger zerolog.Logger) *grpc.GrpcHandler

func InitializeHttpHandler

func InitializeHttpHandler(logger zerolog.Logger) *http.HttpHandler

func InitializeHttpServer

func InitializeHttpServer(
	config config.Config,
	graphqlConfig generated.Config,
	openTracer opentracer.OpenTracer,
	logger zerolog.Logger,
) *graph.HttpServer

func InitializeLocker

func InitializeLocker(config config.Config) (lock.Locker, error)

func InitializeLogger

func InitializeLogger(config config.Config) (zerolog.Logger, error)

func InitializeMQ

func InitializeMQ(config config.Config, logger zerolog.Logger) (mq.MQ, error)

func InitializeNatsHandler

func InitializeNatsHandler(logger zerolog.Logger) *nats.NatsHandler

func InitializeOpenTracer

func InitializeOpenTracer(config config.Config, logger zerolog.Logger) (opentracer.OpenTracer, error)

func InitializeParallelExecutor

func InitializeParallelExecutor(
	config config.Config,
	mq mq.MQ,
	logger zerolog.Logger,
) *parallelExecutor.ParallelExecutor

func InitializePassExecutor

func InitializePassExecutor(
	logger zerolog.Logger,
) *passExecutor.PassExecutor

func InitializePubSubHandler

func InitializePubSubHandler(logger zerolog.Logger) *pubsub.PubSubHandler

func InitializeRedisStreamHandler

func InitializeRedisStreamHandler(logger zerolog.Logger) *redisstream.RedisStreamHandler

func InitializeScheduleWorker

func InitializeScheduleWorker(
	config config.Config,
	mq mq.MQ,
	lock lock.Locker,
	logger zerolog.Logger,
	tracer *opentracer.ServiceTracer,
) *scheduler.ScheduleWorker

func InitializeServiceTracer

func InitializeServiceTracer(config config.Config, tracer opentracer.OpenTracer) *opentracer.ServiceTracer

func InitializeTaskExecutor

func InitializeTaskExecutor(
	http *http.HttpHandler,
	grpc *grpc.GrpcHandler,
	pubsub *pubsub.PubSubHandler,
	nats *nats.NatsHandler,
	redisstream *redisstream.RedisStreamHandler,
	logger zerolog.Logger,
) *taskExecutor.TaskExecutor

func InitializeTaskWorker

func InitializeTaskWorker(
	taskExecutor *taskExecutor.TaskExecutor,
	parallelExecutor *parallelExecutor.ParallelExecutor,
	waitExecutor *waitExecutor.WaitExecutor,
	passExecutor *passExecutor.PassExecutor,
	choiceExecutor *choiceExecutor.ChoiceExecutor,
	config config.Config,
	lock lock.Locker,
	logger zerolog.Logger,
	tracer *opentracer.ServiceTracer,
) *task.TaskWorker

func InitializeWaitExecutor

func InitializeWaitExecutor(
	logger zerolog.Logger,
) *waitExecutor.WaitExecutor

func InitializeWorker

func InitializeWorker(
	config config.Config,
	db *gorm.DB,
	lock lock.Locker,
	logger zerolog.Logger,
	tracer *opentracer.ServiceTracer,
) *initializer.InitializeWorker