trigger

Documentation

Index

• Variables
• type Options
• type Registry
  • func NewRegistry(tracer trace.Tracer) *Registry
  • func (r *Registry) Add(t Triggerer)
  • func (r *Registry) Get(triggererType trigger.TriggerType) (Triggerer, error)
• type Response
• type Triggerer
  • func GRPC() Triggerer
  • func HTTP() Triggerer
  • func Instrument(tracer trace.Tracer, wrapped Triggerer) Triggerer
  • func KAFKA() Triggerer
  • func TRACEID() Triggerer

Variables

var ErrTriggererTypeNotRegistered = errors.New("triggerer type not found")

Types

type Options

type Options struct {
	TraceID trace.TraceID
	SpanID  trace.SpanID
	TestID  id.ID
}

type Registry

type Registry struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewRegistry

func NewRegistry(tracer trace.Tracer) *Registry

func (*Registry) Add

func (r *Registry) Add(t Triggerer)

func (*Registry) Get

func (r *Registry) Get(triggererType trigger.TriggerType) (Triggerer, error)

type Response

type Response struct {
	SpanAttributes map[string]string
	Result         trigger.TriggerResult
	TraceID        trace.TraceID
	SpanID         trace.SpanID
}

type Triggerer

type Triggerer interface {
	Trigger(context.Context, trigger.Trigger, *Options) (Response, error)
	Type() trigger.TriggerType
}

func GRPC

func GRPC() Triggerer

func HTTP

func HTTP() Triggerer

func Instrument

func Instrument(tracer trace.Tracer, wrapped Triggerer) Triggerer

func KAFKA

func KAFKA() Triggerer

func TRACEID

func TRACEID() Triggerer