manifold

Documentation

Index

• type ChannelManifold
  • func (m *ChannelManifold) Enqueue(envelopes []envelope.Envelope) error
  • func (m *ChannelManifold) GetRegistry() *registry.Registry
  • func (m *ChannelManifold) Initialize(registry *registry.Registry, sinks *[]backendutils.Sink, conf *config.Config, ...) error
  • func (m *ChannelManifold) Shutdown() error
• type KernelBufferManifold
• type Manifold
• type SimpleManifold
  • func (m *SimpleManifold) Enqueue(envelopes []envelope.Envelope) error
  • func (m *SimpleManifold) GetRegistry() *registry.Registry
  • func (m *SimpleManifold) Initialize(registry *registry.Registry, sinks *[]backendutils.Sink, conf *config.Config, ...) error
  • func (m *SimpleManifold) Shutdown() error

Types

type ChannelManifold

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

func (*ChannelManifold) Enqueue

func (m *ChannelManifold) Enqueue(envelopes []envelope.Envelope) error

func (*ChannelManifold) GetRegistry

func (m *ChannelManifold) GetRegistry() *registry.Registry

func (*ChannelManifold) Initialize

func (m *ChannelManifold) Initialize(registry *registry.Registry, sinks *[]backendutils.Sink, conf *config.Config, metadata *meta.CollectorMeta) error

func (*ChannelManifold) Shutdown

func (m *ChannelManifold) Shutdown() error

type KernelBufferManifold

type KernelBufferManifold struct {
}

type Manifold

type Manifold interface {
	Initialize(registry *registry.Registry, sinks *[]backendutils.Sink, conf *config.Config, metadata *meta.CollectorMeta) error
	Enqueue(envelopes []envelope.Envelope) error
	GetRegistry() *registry.Registry
	Shutdown() 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 it will probably overload the configured sink(s).

func (*SimpleManifold) Enqueue

func (m *SimpleManifold) Enqueue(envelopes []envelope.Envelope) error

func (*SimpleManifold) GetRegistry

func (m *SimpleManifold) GetRegistry() *registry.Registry

func (*SimpleManifold) Initialize

func (m *SimpleManifold) Initialize(registry *registry.Registry, sinks *[]backendutils.Sink, conf *config.Config, metadata *meta.CollectorMeta) error

func (*SimpleManifold) Shutdown

func (m *SimpleManifold) Shutdown() error