Documentation ¶
Index ¶
- Constants
- type Amqpin
- type Beat
- type Fanin
- type Heartbeat
- type Httpin
- func (httpin *Httpin) Close()
- func (httpin *Httpin) Config(config *generic.ConfigurationLink) bool
- func (httpin *Httpin) Do(input chan messages.Message) chan messages.Message
- func (httpin *Httpin) GetName() string
- func (httpin *Httpin) GetType() generic.LinkType
- func (httpin *Httpin) Serve(handler http.Handler)
- type Line
- type Tail
- func (tail *Tail) Close()
- func (tail *Tail) Config(config *generic.ConfigurationLink) bool
- func (tail *Tail) Do(input chan messages.Message) chan messages.Message
- func (tail *Tail) GetName() string
- func (tail *Tail) GetType() generic.LinkType
- func (tail *Tail) ProcessLine(line string) (output string, err error)
Constants ¶
View Source
const (
HEARTBEAT_TAG = "heartbeat"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Amqpin ¶
type Heartbeat ¶
type Heartbeat struct {
// contains filtered or unexported fields
}
func NewHeartbeat ¶
func NewHeartbeat() *Heartbeat
func (*Heartbeat) Config ¶
func (heartbeat *Heartbeat) Config(config *generic.ConfigurationLink) bool
Click to show internal directories.
Click to hide internal directories.