agent

Documentation

Index

• type Agent
  • func New(interfaceName string, filter string, archivistAddress string, agentName string) (*Agent, error)
  • func (agent *Agent) Close()
  • func (agent *Agent) Start() error
• type BatchQueue
  • func NewBatchQueue(cap int, timeout time.Duration, f func([]*pb.Packet)) *BatchQueue
  • func (bq *BatchQueue) Add(pkt *pb.Packet)

Types

type Agent

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

func New

func New(interfaceName string, filter string, archivistAddress string, agentName string) (*Agent, error)

func (*Agent) Close

func (agent *Agent) Close()

func (*Agent) Start

func (agent *Agent) Start() error

type BatchQueue

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

func NewBatchQueue

func NewBatchQueue(cap int, timeout time.Duration, f func([]*pb.Packet)) *BatchQueue

func (*BatchQueue) Add

func (bq *BatchQueue) Add(pkt *pb.Packet)