Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionCountTopic ¶
type ConnectionCountTopic struct{}
type EntryCountTopic ¶
type EntryCountTopic struct{}
type FluentRecord ¶
type ForwardInput ¶
type ForwardInput struct {
// contains filtered or unexported fields
}
func NewForwardInput ¶
func NewForwardInput(logger *logrus.Logger, bind string, port shared.InputListener) (*ForwardInput, error)
func (*ForwardInput) Start ¶
func (input *ForwardInput) Start()
func (*ForwardInput) Stop ¶
func (input *ForwardInput) Stop()
func (*ForwardInput) String ¶
func (input *ForwardInput) String() string
func (*ForwardInput) WaitForShutdown ¶
func (input *ForwardInput) WaitForShutdown()
type ForwardInputFactory ¶
type ForwardInputFactory struct{}
type HeartbeatInput ¶
type HeartbeatInput struct {
// contains filtered or unexported fields
}
func NewForwardHeartbeatInput ¶
func NewForwardHeartbeatInput(logger *logrus.Logger, bind string) (*HeartbeatInput, error)
func (*HeartbeatInput) Start ¶
func (input *HeartbeatInput) Start()
func (*HeartbeatInput) Stop ¶
func (input *HeartbeatInput) Stop()
func (*HeartbeatInput) String ¶
func (input *HeartbeatInput) String() string
func (*HeartbeatInput) WaitForShutdown ¶
func (input *HeartbeatInput) WaitForShutdown()
Click to show internal directories.
Click to hide internal directories.