bitbucket

Documentation

Index

• type EventProcessor
  • func NewEventProcessor(ksClient ctrlClient.Reader, options *EventProcessorOptions) *EventProcessor
  • func (p *EventProcessor) Process(ctx context.Context, body []byte, ns, eventType string) (*event_processor.EventInfo, error)
• type EventProcessorOptions

Types

type EventProcessor

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

func NewEventProcessor

func NewEventProcessor(ksClient ctrlClient.Reader, options *EventProcessorOptions) *EventProcessor

func (*EventProcessor) Process

func (p *EventProcessor) Process(ctx context.Context, body []byte, ns, eventType string) (*event_processor.EventInfo, error)

type EventProcessorOptions

type EventProcessorOptions struct {
	Logger      *zap.SugaredLogger
	RestyClient *resty.Client
}