agent

Documentation

Index

• func ParseSink(s string) (cypress.Receiver, error)
• type Latch
• type ManyReceiver
  • func ManyReceivers(r ...cypress.Receiver) *ManyReceiver
  • func (mr *ManyReceiver) Close() error
  • func (mr *ManyReceiver) Receive(m *cypress.Message) error
• type Pipeline
  • func MakePipeline(srcs, sinks string) (*Pipeline, error)
  • func (p *Pipeline) Close()
  • func (p *Pipeline) Start() error
• type RedisInput
  • func (r *RedisInput) Close()
  • func (r *RedisInput) Init(host, list string, rc cypress.Receiver) error
  • func (r *RedisInput) Start() error
• type RedisOutput
  • func (r *RedisOutput) Close() error
  • func (r *RedisOutput) Receive(m *cypress.Message) error
  • func (r *RedisOutput) Start(host, list string) error
• type Source
  • func LocalCollector(r cypress.Receiver) Source
  • func ParseSource(s string, r cypress.Receiver) Source

Functions

func ParseSink

func ParseSink(s string) (cypress.Receiver, error)

Types

type Latch

type Latch chan error

type ManyReceiver

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

func ManyReceivers

func ManyReceivers(r ...cypress.Receiver) *ManyReceiver

func (*ManyReceiver) Close

func (mr *ManyReceiver) Close() error

func (*ManyReceiver) Receive

func (mr *ManyReceiver) Receive(m *cypress.Message) error

type Pipeline

type Pipeline struct {
	Receivers *ManyReceiver
	Sources   []Source
}

func MakePipeline

func MakePipeline(srcs, sinks string) (*Pipeline, error)

func (*Pipeline) Close

func (p *Pipeline) Close()

func (*Pipeline) Start

func (p *Pipeline) Start() error

type RedisInput

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

func (*RedisInput) Close

func (r *RedisInput) Close()

func (*RedisInput) Init

func (r *RedisInput) Init(host, list string, rc cypress.Receiver) error

func (*RedisInput) Start

func (r *RedisInput) Start() error

type RedisOutput

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

func (*RedisOutput) Close

func (r *RedisOutput) Close() error

func (*RedisOutput) Receive

func (r *RedisOutput) Receive(m *cypress.Message) error

func (*RedisOutput) Start

func (r *RedisOutput) Start(host, list string) error

type Source

type Source interface {
	Start() error
	Close()
}

func LocalCollector

func LocalCollector(r cypress.Receiver) Source

func ParseSource

func ParseSource(s string, r cypress.Receiver) Source