service

Documentation

Index

• Constants
• Variables
• func AddActions(registry *actions.WorkerTemplateRegistry)
• func AfterInit(station *ochestrator.Station, envConfig *nenv.EnvStore) error
• func BeforeInit(station *ochestrator.Station, envConfig *nenv.EnvStore) error
• func UseCodec(ctx context.Context, logger sabuhp.Logger) (sabuhp.Codec, error)
• func UseInjector(ctx context.Context, logger sabuhp.Logger, envConfig *nenv.EnvStore) (*injectors.Injector, error)

Constants

const (
	ProjectName      = "[project]"
	ProjectNamespace = "[PROJECT]"
	EnvConfigAlias   = "*npkg.EnvStore"
)

Variables

var HelloWorldRequest = actions.WorkerRequest{
	ActionName:  "helloWorld",
	PubSubTopic: "hello-world",
	WorkerCreator: func(config actions.WorkerConfig) *actions.WorkerGroup {
		config.Action = actions.ActionFunc(helloWorldAction)
		return actions.NewWorkGroup(config)
	},
}

var Logger = &loggerImpl{}

Functions

func AddActions

func AddActions(registry *actions.WorkerTemplateRegistry)

func AfterInit

func AfterInit(station *ochestrator.Station, envConfig *nenv.EnvStore) error

func BeforeInit

func BeforeInit(station *ochestrator.Station, envConfig *nenv.EnvStore) error

func UseCodec

func UseCodec(ctx context.Context, logger sabuhp.Logger) (sabuhp.Codec, error)

func UseInjector

func UseInjector(ctx context.Context, logger sabuhp.Logger, envConfig *nenv.EnvStore) (*injectors.Injector, error)