http

Documentation

Index

• func NewFromCLI(c *cli.Context, tracer opentracing.Tracer) (eventsources.EventSource, error)
• func NewSource(tracer opentracing.Tracer) (eventsources.EventSource, error)
• type Event
  • func (e Event) IsError() (bool, error)
  • func (e Event) OperationName() string
  • func (e Event) ParentSpanID() (*string, error)
  • func (e Event) SpanID() (string, error)
  • func (e Event) State(prev *eventsources.EventState) (eventsources.SpanState, error)
  • func (e Event) Tags() (map[string]interface{}, error)
  • func (e Event) Timings() (eventsources.EventTimings, error)
• type Source
  • func (es *Source) Event(r *http.Request, payload []byte) (eventsources.Event, error)
  • func (es *Source) Name() string
  • func (es *Source) SecretKey() []byte
  • func (es *Source) Tracer() opentracing.Tracer
  • func (es *Source) ValidatePayload(r *http.Request, secretKey []byte) ([]byte, error)

Functions

func NewFromCLI

func NewFromCLI(c *cli.Context, tracer opentracing.Tracer) (eventsources.EventSource, error)

func NewSource

func NewSource(tracer opentracing.Tracer) (eventsources.EventSource, error)

Types

type Event

type Event struct {
	Identifier string `json:"id"`
	Action     string
	ParentID   *string
	Error      bool
	Namespace  string
	Type       string
	Metadata   map[string]interface{}
}

func (Event) IsError

func (e Event) IsError() (bool, error)

func (Event) OperationName

func (e Event) OperationName() string

func (Event) ParentSpanID

func (e Event) ParentSpanID() (*string, error)

ParentSpanID allows this HTTP event to reference any other event.

func (Event) SpanID

func (e Event) SpanID() (string, error)

ID is how an INDIVIDUAL event is referenced internally

func (Event) State

func (e Event) State(prev *eventsources.EventState) (eventsources.SpanState, error)

func (Event) Tags

func (e Event) Tags() (map[string]interface{}, error)

func (Event) Timings

func (e Event) Timings() (eventsources.EventTimings, error)

type Source

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

func (*Source) Event

func (es *Source) Event(r *http.Request, payload []byte) (eventsources.Event, error)

func (*Source) Name

func (es *Source) Name() string

func (*Source) SecretKey

func (es *Source) SecretKey() []byte

func (*Source) Tracer

func (es *Source) Tracer() opentracing.Tracer

func (*Source) ValidatePayload

func (es *Source) ValidatePayload(r *http.Request, secretKey []byte) ([]byte, error)