eventmaster

type Annotation struct {
	// Name must match in the request and response
	Name string `json:"name"`

	Datasource string `json:"datasource"`
	IconColor  string `json:"iconColor"`
	Enable     bool   `json:"enable"`
	ShowLine   bool   `json:"showLine"`
	Query      string `json:"query"`
}

type AnnotationQuery struct {
	Topic string `json:"topic"`
	DC    string `json:"dc"`
}

type AnnotationResponse struct {
	// The original annotation sent from Grafana.
	Annotation Annotation `json:"annotation"`
	// Time since UNIX Epoch in milliseconds. (required)
	Time int64 `json:"time"`
	// The title for the annotation tooltip. (required)
	Title string `json:"title"`
	// Tags for the annotation. (optional)
	Tags string `json:"tags"`
	// Text for the annotation. (optional)
	Text string `json:"text"`
}

type AnnotationsReq struct {
	Range      Range      `json:"range"`
	Annotation Annotation `json:"annotation"`
}

type AssetTemplate struct {
	sync.RWMutex
	Asset func(name string) ([]byte, error)
	// contains filtered or unexported fields
}

type CassandraConfig struct {
	Addrs       []string `json:"addrs"`
	Keyspace    string   `json:"keyspace"`
	Consistency string   `json:"consistency"`
	Timeout     string   `json:"timeout"`
	ServiceName string   `json:"service_name"`
}

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

type DC struct {
	ID   string `json:"dc_id"`
	Name string `json:"dc_name"`
}

type DataStore interface {
	AddEvent(*Event) error
	Find(q *eventmaster.Query, topicIDs []string, dcIDs []string) (Events, error)
	FindByID(string, bool) (*Event, error)
	FindIDs(*eventmaster.TimeQuery, HandleEvent) error
	GetTopics() ([]Topic, error)
	AddTopic(RawTopic) error
	UpdateTopic(RawTopic) error
	DeleteTopic(string) error
	GetDCs() ([]DC, error)
	AddDC(DC) error
	UpdateDC(string, string) error
	CloseSession()
}

type Disk struct {
	Root string
}

type Event struct {
	EventID       string                 `json:"event_id"`
	ParentEventID string                 `json:"parent_event_id"`
	EventTime     int64                  `json:"event_time"`
	DCID          string                 `json:"dc_id"`
	TopicID       string                 `json:"topic_id"`
	Tags          []string               `json:"tag_set"`
	Host          string                 `json:"host"`
	TargetHosts   []string               `json:"target_host_set"`
	User          string                 `json:"user"`
	Data          map[string]interface{} `json:"data"`
	ReceivedTime  int64                  `json:"received_time"`
}

type EventResult struct {
	EventID       string                 `json:"event_id"`
	ParentEventID string                 `json:"parent_event_id"`
	EventTime     int64                  `json:"event_time"`
	DC            string                 `json:"dc"`
	TopicName     string                 `json:"topic_name"`
	Tags          []string               `json:"tag_set"`
	Host          string                 `json:"host"`
	TargetHosts   []string               `json:"target_host_set"`
	User          string                 `json:"user"`
	Data          map[string]interface{} `json:"data"`
	ReceivedTime  int64                  `json:"received_time"`
}

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

type Events []*Event

type Flags struct {
	Port int `long:"port" default:"50052" description:"Port for EventMaster gRPC + HTTP API"`

	ConfigFile string `short:"c" long:"config" description:"location of configuration file"`

	RsyslogServer bool `short:"r" long:"rsyslog_server" description:"Flag to start TCP rsyslog server"`
	RsyslogPort   int  `long:"rsyslog_port" default:"50053" description:"Port for rsyslog clients to send logs to"`

	CAFile   string `long:"ca_file" description:"PEM encoded CA's certificate file path"`
	CertFile string `long:"cert_file" description:"PEM encoded certificate file path"`
	KeyFile  string `long:"key_file" description:"PEM encoded private key file path"`

	StaticFiles string `short:"s" long:"static" description:"location of static files to use (instead of embedded files)"`
	Templates   string `short:"t" long:"templates" description:"location of template files to use (instead of embedded)"`
}

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

type GetEventPageData struct {
	Topics []Topic
	Query  *eventmaster.Query
}

type HandleEvent func(eventID string) error

type LogParser func(int64, string, string, string, string) *UnaddedEvent

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

type Range struct {
	From time.Time `json:"from"`
	To   time.Time `json:"to"`
}

type RawTopic struct {
	ID     string
	Name   string
	Schema string
}

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

type SearchResult struct {
	Results []*EventResult `json:"results"`
}

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

type StatusRecorder struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

type TemplateGetter interface {
	Get(name string) (*template.Template, error)
}

type TemplateRequest struct {
	Target string `json:"target"`
}

type Topic struct {
	ID     string                 `json:"topic_id"`
	Name   string                 `json:"topic_name"`
	Schema map[string]interface{} `json:"data_schema"`
}

type UnaddedEvent struct {
	ParentEventID string                 `json:"parent_event_id"`
	EventTime     int64                  `json:"event_time"`
	DC            string                 `json:"dc"`
	TopicName     string                 `json:"topic_name"`
	Tags          []string               `json:"tag_set"`
	Host          string                 `json:"host"`
	TargetHosts   []string               `json:"target_host_set"`
	User          string                 `json:"user"`
	Data          map[string]interface{} `json:"data"`
}