manifold

Documentation

Index

• type Manifold
• type SimpleManifold
  • func (m *SimpleManifold) Distribute(envelopes []envelope.Envelope, s *stats.ProtocolStats) error
  • func (m *SimpleManifold) Initialize(sinks *[]sink.Sink) error

Types

type Manifold

type Manifold interface {
	Initialize(sinks *[]sink.Sink) error
	Distribute(e []envelope.Envelope) error
}

type SimpleManifold

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

A stupid-simple manifold with strict guarantees. This manifold requires buffering at the client level for substantial event volumes. Otherwise there is a change it will overload the configured sink(s).

func (*SimpleManifold) Distribute

func (m *SimpleManifold) Distribute(envelopes []envelope.Envelope, s *stats.ProtocolStats) error

func (*SimpleManifold) Initialize

func (m *SimpleManifold) Initialize(sinks *[]sink.Sink) error