fanout

Documentation

Index

• type ForwardResult
• type Handler
  • func (h *Handler) Start(ctx context.Context) error
• type PubsubConfig

Types

type ForwardResult

type ForwardResult struct {
	Err         error
	IsPurgatory bool
	IsFiltered  bool
}

type Handler

type Handler struct {
	Logger                 *zap.SugaredLogger
	ListenersCfg           config.Config
	PubsubCfg              *PubsubConfig
	MaxConcurrencyPerEvent int
	ForwardClient          cloudevents.Client
	// contains filtered or unexported fields
}

func (*Handler) Start

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

type PubsubConfig

type PubsubConfig struct {
	ProjectID, TopicID, SubscriptionID, PurgatoryTopicID string
}