forward

Documentation

Index

• func Consume(part cluster.PartitionConsumer, output *output.Output, ...)
• type Forwarder
  • func NewForwarder(i input.Parameter, o output.Parameter, f filter.IClaimFunc) (*Forwarder, error)
  • func (c *Forwarder) Start()
  • func (c *Forwarder) Stop()

Functions

func Consume

func Consume(part cluster.PartitionConsumer, output *output.Output, filterClaim filter.IClaimFunc, wait *sync.WaitGroup)

Types

type Forwarder

type Forwarder struct {
	FilterClaim filter.IClaimFunc
	// contains filtered or unexported fields
}

func NewForwarder

func NewForwarder(i input.Parameter, o output.Parameter, f filter.IClaimFunc) (*Forwarder, error)

func (*Forwarder) Start

func (c *Forwarder) Start()

func (*Forwarder) Stop

func (c *Forwarder) Stop()