hydra

type Config struct {
	TagPrefix      string
	FieldName      string
	ReadBufferSize int
	Servers        []*ConfigServer
	Logs           []*ConfigLogfile
	Receiver       *ConfigReceiver
	Monitor        *ConfigMonitor
}

type ConfigLogfile struct {
	Tag       string
	File      string
	FieldName string
}

type ConfigMonitor struct {
	Host string
	Port int
}

type ConfigReceiver struct {
	Host              string
	Port              int
	MaxBufferMessages int
}

type ConfigServer struct {
	Host string
	Port int
}

type File struct {
	*os.File
	Path     string
	Tag      string
	Position int64

	FieldName string
	// contains filtered or unexported fields
}

type FileStat struct {
	Tag      string `json:"tag"`
	File     string `json:"-"`
	Position int64  `json:"position"`
	Error    string `json:"error"`
}

type InForward struct {
	Addr net.Addr
	// contains filtered or unexported fields
}

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

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

type Monitor struct {
	Addr net.Addr
	// contains filtered or unexported fields
}

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

type ReceiverStat struct {
	Address            string `json:"address"`
	Connections        int    `json:"-"`
	TotalConnections   int    `json:"total_connections"`
	CurrentConnections int    `json:"current_connections"`
	Messages           int64  `json:"messages"`
	Disposed           int64  `json:"disposed"`
	Buffered           int64  `json:"buffered"`
	MaxBufferMessages  int64  `json:"max_buffer_messages"`
}

type SentStat struct {
	Tag      string `json:"-"`
	Messages int64  `json:"messages"`
	Bytes    int64  `json:"bytes"`
}

type ServerStat struct {
	Index   int    `json:"-"`
	Address string `json:"address"`
	Alive   bool   `json:"alive"`
	Error   string `json:"error"`
}

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

type Stat interface {
	ApplyTo(*Stats)
}

type Stats struct {
	Sent     map[string]*SentStat `json:"sent"`
	Files    map[string]*FileStat `json:"files"`
	Servers  []*ServerStat        `json:"servers"`
	Receiver *ReceiverStat        `json:"receiver"`
	// contains filtered or unexported fields
}

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