outputs

type ElasticsearchOutputType struct {
	OutputInterface
	Index          string
	TopologyExpire int

	TopologyMap map[string]string
}

type FileOutputType struct {
	OutputInterface
	// contains filtered or unexported fields
}

type FileRotator struct {
	Path             string
	Name             string
	RotateEveryBytes uint64
	KeepFiles        int
	// contains filtered or unexported fields
}

type OutputInterface interface {
	PublishIPs(name string, localAddrs []string) error
	GetNameByIP(ip string) string
	PublishEvent(ts time.Time, event common.MapStr) error
}

type PublishedTopology struct {
	Name string
	IPs  string
}

type PublisherType struct {
	Index               string
	Output              []OutputInterface
	TopologyOutput      OutputInterface
	ElasticsearchOutput ElasticsearchOutputType
	RedisOutput         RedisOutputType
	FileOutput          FileOutputType

	RefreshTopologyTimer <-chan time.Time
	Queue                chan common.MapStr
	// contains filtered or unexported fields
}

type RedisDataType uint16

type RedisOutputType struct {
	OutputInterface
	Index string
	Conn  redis.Conn

	TopologyExpire    time.Duration
	ReconnectInterval time.Duration
	Hostname          string
	Password          string
	Db                int
	DbTopology        int
	Timeout           time.Duration
	DataType          RedisDataType
	FlushInterval     time.Duration

	TopologyMap map[string]string
	// contains filtered or unexported fields
}

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

type Topology struct {
	Name string `json:"name"`
	Ip   string `json:"ip"`
}