v1

package
v0.0.0-...-ba3aa93 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 15, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrorMissingOrigin = errors.New("Event not emitted due to missing origin information")
View Source
var ErrorUnknownEventType = errors.New("Cannot create envelope for unknown event type")
View Source
var MaxTTL = time.Minute

Functions

This section is empty.

Types

type BatchChainByteWriter

type BatchChainByteWriter interface {
	Write(message []byte) (err error)
}

type EnvelopeWriter

type EnvelopeWriter interface {
	Write(event *events.Envelope)
}

type EventMarshaller

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

func NewMarshaller

func NewMarshaller(mc MetricClient) *EventMarshaller

func (*EventMarshaller) SetWriter

func (m *EventMarshaller) SetWriter(byteWriter BatchChainByteWriter)

func (*EventMarshaller) Write

func (m *EventMarshaller) Write(envelope *events.Envelope)

type EventWriter

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

func New

func New(origin string) *EventWriter

func (*EventWriter) Emit

func (e *EventWriter) Emit(event events.Event) error

func (*EventWriter) EmitEnvelope

func (e *EventWriter) EmitEnvelope(envelope *events.Envelope) error

func (*EventWriter) Origin

func (e *EventWriter) Origin() string

func (*EventWriter) SetWriter

func (e *EventWriter) SetWriter(writer EnvelopeWriter)

type MessageAggregator

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

func NewAggregator

func NewAggregator(outputWriter EnvelopeWriter) *MessageAggregator

func (*MessageAggregator) Write

func (m *MessageAggregator) Write(envelope *events.Envelope)

type MetricClient

type MetricClient interface {
	NewCounter(name, helpText string, opts ...metrics.MetricOption) metrics.Counter
}

MetricClient creates new CounterMetrics to be emitted periodically.

type Tagger

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

func NewTagger

func NewTagger(deploymentName, job, index, ip string, outputWriter EnvelopeWriter) *Tagger

func (*Tagger) Write

func (t *Tagger) Write(envelope *events.Envelope)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL