trigger

Documentation

Index

• Variables
• func WrapInQuotes(input string, quoteChar string) string
• type KafkaTriggerer
  • func (t *KafkaTriggerer) Resolve(ctx context.Context, test test.Test, opts *ResolveOptions) (test.Test, error)
  • func (t *KafkaTriggerer) Trigger(ctx context.Context, test test.Test, opts *TriggerOptions) (Response, error)
  • func (t *KafkaTriggerer) Type() trigger.TriggerType
• type Registry
  • func NewRegistry(tracer, triggerSpanTracer trace.Tracer) *Registry
  • func (r *Registry) Add(t Triggerer)
  • func (r *Registry) Get(triggererType trigger.TriggerType) (Triggerer, error)
• type ResolveOptions
• type Response
• type TriggerOptions
• type Triggerer
  • func GRPC() Triggerer
  • func HTTP() Triggerer
  • func Instrument(tracer, triggerSpanTracer trace.Tracer, wrapped Triggerer) Triggerer
  • func Kafka() Triggerer
  • func TRACEID() Triggerer

Variables

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

Functions

func WrapInQuotes

func WrapInQuotes(input string, quoteChar string) string

Types

type KafkaTriggerer

type KafkaTriggerer struct{}

func (*KafkaTriggerer) Resolve

func (t *KafkaTriggerer) Resolve(ctx context.Context, test test.Test, opts *ResolveOptions) (test.Test, error)

func (*KafkaTriggerer) Trigger

func (t *KafkaTriggerer) Trigger(ctx context.Context, test test.Test, opts *TriggerOptions) (Response, error)

func (*KafkaTriggerer) Type

func (t *KafkaTriggerer) Type() trigger.TriggerType

type Registry

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

func NewRegistry

func NewRegistry(tracer, triggerSpanTracer 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 ResolveOptions

type ResolveOptions struct {
	Executor expression.Executor
}

type Response

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

type TriggerOptions

type TriggerOptions struct {
	TraceID trace.TraceID
}

type Triggerer

type Triggerer interface {
	Trigger(context.Context, test.Test, *TriggerOptions) (Response, error)
	Type() trigger.TriggerType
	Resolve(context.Context, test.Test, *ResolveOptions) (test.Test, error)
}

func GRPC

func GRPC() Triggerer

func HTTP

func HTTP() Triggerer

func Instrument

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

func Kafka

func Kafka() Triggerer

func TRACEID

func TRACEID() Triggerer