core

package

v2.3.4+incompatible Latest Latest Go to latest Published: Aug 16, 2018 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

func Run()

ListenAndUpdate is the main working goroutine of rebellion

type AppInfo struct {
	PodInfos []PodInfo `json:"PodInfos"`
}

type KafkaAddressList string

KafkaAddressList represents the json string of Kafka addresses list

type KafkaConfHandler struct {
	KafkaAddrs KafkaAddressList
}

KafkaConfHandler renders kafka.toml dynamically

func NewKafkaConfHandler() *KafkaConfHandler

NewKafkaConfHandler initalizes a pointer of KafkaConfHandler with empty KafkaAddrs

func (kc *KafkaConfHandler) DynamicallyHandle(update chan interface{})

DynamicallyHandle implements DynamicalHandler

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

LainAppConfHandler handles log files of lain applications

func NewLainAppConfHandler() *LainAppConfHandler

func (lh *LainAppConfHandler) DynamicallyHandle(update chan interface{})

type LogInfo struct {
	AppName    string
	AppVersion string
	ProcName   string
	InstanceNo int
	LogFile    string
}

type PodInfo struct {
	InstanceNo int    `json:"InstanceNo"`
	AppVersion string `json:"AppVersion"`
	Annotation string `json:"Annotation"`
}

type Rebellion struct {
	KafkaAddr   KafkaAddressList
	LogInfos    []LogInfo
	LainletPort string
	// contains filtered or unexported fields
}

Rebellion is the data holder rendering Filebeat template