Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CollectingProcess ¶ added in v0.3.1
type CollectingProcess struct {
// contains filtered or unexported fields
}
func InitCollectingProcess ¶
func InitCollectingProcess(input CollectorInput) (*CollectingProcess, error)
func (*CollectingProcess) CloseMsgChan ¶ added in v0.4.0
func (cp *CollectingProcess) CloseMsgChan()
func (*CollectingProcess) GetAddress ¶ added in v0.4.0
func (cp *CollectingProcess) GetAddress() net.Addr
func (*CollectingProcess) GetMsgChan ¶ added in v0.3.1
func (cp *CollectingProcess) GetMsgChan() chan *entities.Message
func (*CollectingProcess) Start ¶ added in v0.3.1
func (cp *CollectingProcess) Start()
func (*CollectingProcess) Stop ¶ added in v0.3.1
func (cp *CollectingProcess) Stop()
type CollectorInput ¶ added in v0.4.0
type CollectorInput struct {
// Address needs to be provided in hostIP:port format.
Address string
// Protocol needs to be provided in lower case format.
// We support "tcp" and "udp" protocols.
Protocol string
MaxBufferSize uint16
TemplateTTL uint32
IsEncrypted bool
// TODO: group following fields into struct to be reuse in exporter
CACert []byte
ServerCert []byte
ServerKey []byte
IsIPv6 bool
}
Source Files
Click to show internal directories.
Click to hide internal directories.