sender

Documentation

Index

• Constants
• func CtxSenderInstance(entry interface{}, ctx context.Context) context.Context
• func NewSenderAsInterface(cfg config.Config, _ context.Context) interface{}
• func RunSenderAsInterface(structure interface{}, ctx context.Context)
• type Sender
  • func SenderInstance(ctx context.Context) *Sender
  • func (s *Sender) Run(ctx context.Context)
  • func (s *Sender) SendMessageToCustomChannel(topic string, msg *message.Message) error

Constants

const ServiceName = data.ModuleName + "-sender"

Functions

func CtxSenderInstance

func CtxSenderInstance(entry interface{}, ctx context.Context) context.Context

func NewSenderAsInterface

func NewSenderAsInterface(cfg config.Config, _ context.Context) interface{}

func RunSenderAsInterface

func RunSenderAsInterface(structure interface{}, ctx context.Context)

Types

type Sender

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

func SenderInstance

func SenderInstance(ctx context.Context) *Sender

func (*Sender) Run

func (s *Sender) Run(ctx context.Context)

func (*Sender) SendMessageToCustomChannel

func (s *Sender) SendMessageToCustomChannel(topic string, msg *message.Message) error