messagequeue

Documentation

Index

• func Subscribe(cfg TrainingConfig, tcTopic string, s app.TrainingService, ...) (err error)
• type TrainingConfig

Functions

func Subscribe

func Subscribe(
	cfg TrainingConfig,
	tcTopic string,
	s app.TrainingService,
	subscriber message.Subscriber,
) (err error)

Types

type TrainingConfig

type TrainingConfig struct {
	TrainingEndpoint string `json:"training_endpoint" required:"true"`
}