producer

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(mqConfig configs.MQ, logger *zap.Logger, admin admin.Admin) (Client, error)
• type SubmissionCreatedProducer
  • func NewSubmissionCreatedProducer(client Client, logger *zap.Logger) (SubmissionCreatedProducer, error)

Constants

const (
	MessageQueueSubmissionCreated = "submission_created"
)

Variables

var WireSet = wire.NewSet(
	NewClient,
	NewSubmissionCreatedProducer,
)

Types

type Client

type Client interface {
	Produce(ctx context.Context, queueName string, payload []byte) error
}

func NewClient

func NewClient(mqConfig configs.MQ, logger *zap.Logger, admin admin.Admin) (Client, error)

type SubmissionCreatedProducer

type SubmissionCreatedProducer interface {
	Produce(ctx context.Context, submissionID uint64) error
}

func NewSubmissionCreatedProducer

func NewSubmissionCreatedProducer(client Client, logger *zap.Logger) (SubmissionCreatedProducer, error)