Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageQueueService ¶
type MessageQueueService interface { PublishProjectSettingsMessage(updateType string, settings *_pubsub.ProjectSettings) error PublishExperimentMessage(updateType string, experiment *_pubsub.Experiment) error PublishProjectSegmenterMessage(updateType string, segmenter *segmenters.SegmenterConfiguration, projectId int64) error }
func NewMessageQueueService ¶
func NewMessageQueueService(mqConfig common_mq_config.MessageQueueConfig) (MessageQueueService, error)
func NewNoopMQService ¶
func NewNoopMQService() (MessageQueueService, error)
NewNoopMQ initializes a noopMQ struct
func NewPubSubMQService ¶
func NewPubSubMQService(config common_mq_config.PubSubConfig) (MessageQueueService, error)
Click to show internal directories.
Click to hide internal directories.