messaging

Documentation

Index

• type EventGateway
  • func NewEventGateway(ceConfig ce.Config, authHandler security.AuthHandler) EventGateway
  • func (e EventGateway) GenerateAuthorizationHandler(ctx context.Context, event event.Event) (*event.Event, error)
  • func (e EventGateway) Listen(ctx context.Context) error
• type Recipient
  • func (r Recipient) Validate() error
• type RecipientType

Types

type EventGateway

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

func NewEventGateway

func NewEventGateway(ceConfig ce.Config, authHandler security.AuthHandler) EventGateway

func (EventGateway) GenerateAuthorizationHandler

func (e EventGateway) GenerateAuthorizationHandler(ctx context.Context, event event.Event) (*event.Event, error)

func (EventGateway) Listen

func (e EventGateway) Listen(ctx context.Context) error

Listen starts the request handler by listening for incoming requests

type Recipient

type Recipient struct {
	Type    RecipientType
	Address string
}

func (Recipient) Validate

func (r Recipient) Validate() error

type RecipientType

type RecipientType string