notificationsending

Documentation

Index

• type Operation
  • func NewOperation(publisher Producer) *Operation
  • func (o *Operation) SendNotificationMessage(ctx context.Context, message string) error
• type Producer

Types

type Operation

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

Operation provides an API for fetching single or multiple notifications.

func NewOperation

func NewOperation(publisher Producer) *Operation

NewOperation is a contruction function for Operation.

func (*Operation) SendNotificationMessage

func (o *Operation) SendNotificationMessage(ctx context.Context, message string) error

SendNotificationMessage sends the given message as kafka event.

type Producer

type Producer interface {
	Produce(ctx context.Context, channel string, message any) error
}

Producer is a contract to a message producer.