messagequeue

Documentation

Index

• type MessageQueueService
  • func NewMessageQueueService(ctx context.Context, storage *models.LocalStorage, ...) (MessageQueueService, error)
  • func NewNoopMQService() (MessageQueueService, error)
• type PubsubSubscriber
  • func NewPubsubMQService(ctx context.Context, storage *models.LocalStorage, ...) (*PubsubSubscriber, error)
  • func (u *PubsubSubscriber) DeleteSubscriptions(ctx context.Context) error
  • func (u *PubsubSubscriber) SubscribeToManagementService(ctx context.Context) error
• type PubsubSubscriberConfig

Types

type MessageQueueService

type MessageQueueService interface {
	SubscribeToManagementService(ctx context.Context) error
	DeleteSubscriptions(ctx context.Context) error
}

func NewMessageQueueService

func NewMessageQueueService(
	ctx context.Context,
	storage *models.LocalStorage,
	mqConfig common_mq_config.MessageQueueConfig,
	projectIds []uint32,
	googleApplicationCredentialsEnvVar string,
) (MessageQueueService, error)

func NewNoopMQService

func NewNoopMQService() (MessageQueueService, error)

NewNoopMQService initializes a noopMQ struct

type PubsubSubscriber

type PubsubSubscriber struct {
	// contains filtered or unexported fields
}

func NewPubsubMQService

func NewPubsubMQService(
	ctx context.Context,
	storage *models.LocalStorage,
	config PubsubSubscriberConfig,
	googleApplicationCredentialsEnvVar string,
) (*PubsubSubscriber, error)

func (*PubsubSubscriber) DeleteSubscriptions

func (u *PubsubSubscriber) DeleteSubscriptions(ctx context.Context) error

func (*PubsubSubscriber) SubscribeToManagementService

func (u *PubsubSubscriber) SubscribeToManagementService(ctx context.Context) error

type PubsubSubscriberConfig

type PubsubSubscriberConfig struct {
	Project         string
	UpdateTopicName string
	ProjectIds      []models.ProjectId
}