broker

Documentation

Index

• type FilterResult
• type Handler
  • func NewBroker(logger *zap.SugaredLogger) (*Handler, error)
  • func (r *Handler) Start(ctx context.Context) error

Types

type FilterResult

type FilterResult string

FilterResult has the result of the filtering operation.

type Handler

type Handler struct {
	TriggersJson string `envconfig:"TRIGGERS" required:"true"`
	// contains filtered or unexported fields
}

Handler parses Cloud Events, determines if they pass a filter, and sends them to a subscriber.

func NewBroker

func NewBroker(logger *zap.SugaredLogger) (*Handler, error)

func (*Handler) Start

func (r *Handler) Start(ctx context.Context) error

Start begins to receive messages for the handler.

Only HTTP POST requests to the root path (/) are accepted. If other paths or methods are needed, use the HandleRequest method directly with another HTTP server.

This method will block until a message is received on the stop channel.