ingest

Documentation

Index

• type CloudEventHandler
• type Instance
  • func NewInstance(reporter metrics.Reporter, logger *zap.SugaredLogger, opts ...InstanceOption) *Instance
  • func (i *Instance) RegisterCloudEventHandler(h CloudEventHandler)
  • func (i *Instance) RegisterProbeHandler(h ProbeHandler)
  • func (i *Instance) Start(ctx context.Context) error
  • func (i *Instance) UpdateFromConfig(c *cfgbroker.Config)
• type InstanceOption
  • func InstanceWithPort(port int) InstanceOption
  • func InstanceWithStatusManager(sm status.Manager) InstanceOption
• type ProbeHandler

Types

type CloudEventHandler

type CloudEventHandler func(context.Context, *cloudevents.Event) error

type Instance

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

func NewInstance

func NewInstance(reporter metrics.Reporter, logger *zap.SugaredLogger, opts ...InstanceOption) *Instance

func (*Instance) RegisterCloudEventHandler

func (i *Instance) RegisterCloudEventHandler(h CloudEventHandler)

func (*Instance) RegisterProbeHandler

func (i *Instance) RegisterProbeHandler(h ProbeHandler)

func (*Instance) Start

func (i *Instance) Start(ctx context.Context) error

func (*Instance) UpdateFromConfig

func (i *Instance) UpdateFromConfig(c *cfgbroker.Config)

type InstanceOption

type InstanceOption func(*Instance)

func InstanceWithPort

func InstanceWithPort(port int) InstanceOption

func InstanceWithStatusManager

func InstanceWithStatusManager(sm status.Manager) InstanceOption

type ProbeHandler

type ProbeHandler func() error