ports

Documentation

Index

• type MsgPubber
• type MsgSubber
• type SMTPSender

Types

type MsgPubber

type MsgPubber interface {
	Put(ctx context.Context, msg *models.MsgAnalytics) error
}

MsgPubber writes messages for analytics microservice

type MsgSubber

type MsgSubber interface {
	Get(ctx context.Context, msg *models.MsgTask) error
}

MsgSubber listens for messages from task microservice

type SMTPSender

type SMTPSender interface {
	Send(ctx context.Context, msg *models.MsgSMTP) error
	Notify(ctx context.Context, msg *models.MsgAnalytics) error
}

SMTPSender sends smtp messages