Versions in this module Expand all Collapse all v0 v0.1.2 Oct 16, 2017 Changes in this version + func PrintVersions() + type HandleEvent func(eventID string) error v0.1.1 Sep 29, 2017 v0.1.0 Sep 29, 2017 Changes in this version + var Git = "unset" + var Version = "unset" + func RegisterPromMetrics() error + type Annotation struct + Datasource string + Enable bool + IconColor string + Name string + Query string + ShowLine bool + type AnnotationQuery struct + DC string + Topic string + type AnnotationResponse struct + Annotation Annotation + Tags string + Text string + Time int64 + Title string + func FromEvent(store topicNamer, ev *Event) (AnnotationResponse, error) + type AnnotationsReq struct + Annotation Annotation + Range Range + type AssetTemplate struct + Asset func(name string) ([]byte, error) + func NewAssetTemplate(asset func(string) ([]byte, error)) *AssetTemplate + func (at *AssetTemplate) Get(name string) (*template.Template, error) + type CassandraConfig struct + Addrs []string + Consistency string + Keyspace string + ServiceName string + Timeout string + type CassandraStore struct + func NewCassandraStore(c CassandraConfig) (*CassandraStore, error) + func (c *CassandraStore) AddDC(dc DC) error + func (c *CassandraStore) AddEvent(evt *Event) error + func (c *CassandraStore) AddTopic(t RawTopic) error + func (c *CassandraStore) CloseSession() + func (c *CassandraStore) DeleteTopic(id string) error + func (c *CassandraStore) Find(q *eventmaster.Query, topicIds []string, dcIds []string) (Events, error) + func (c *CassandraStore) FindByID(id string, includeData bool) (*Event, error) + func (c *CassandraStore) FindIDs(q *eventmaster.TimeQuery, stream streamFn) error + func (c *CassandraStore) GetDCs() ([]DC, error) + func (c *CassandraStore) GetTopics() ([]Topic, error) + func (c *CassandraStore) UpdateDC(id string, newName string) error + func (c *CassandraStore) UpdateTopic(t RawTopic) error + type DC struct + ID string + Name string + type DataStore interface + AddDC func(DC) error + AddEvent func(*Event) error + AddTopic func(RawTopic) error + CloseSession func() + DeleteTopic func(string) error + Find func(q *eventmaster.Query, topicIds []string, dcIds []string) (Events, error) + FindByID func(string, bool) (*Event, error) + FindIDs func(*eventmaster.TimeQuery, streamFn) error + GetDCs func() ([]DC, error) + GetTopics func() ([]Topic, error) + UpdateDC func(string, string) error + UpdateTopic func(RawTopic) error + type Disk struct + Root string + func (d Disk) Get(name string) (*template.Template, error) + type Event struct + DCID string + Data map[string]interface{} + EventID string + EventTime int64 + Host string + ParentEventID string + ReceivedTime int64 + Tags []string + TargetHosts []string + TopicID string + User string + type EventResult struct + DC string + Data map[string]interface{} + EventID string + EventTime int64 + Host string + ParentEventID string + ReceivedTime int64 + Tags []string + TargetHosts []string + TopicName string + User string + type EventStore struct + func NewEventStore(ds DataStore) (*EventStore, error) + func (es *EventStore) AddDC(dc *eventmaster.DC) (string, error) + func (es *EventStore) AddEvent(event *UnaddedEvent) (string, error) + func (es *EventStore) AddTopic(topic Topic) (string, error) + func (es *EventStore) CloseSession() + func (es *EventStore) DeleteTopic(deleteReq *eventmaster.DeleteTopicRequest) error + func (es *EventStore) Find(q *eventmaster.Query) (Events, error) + func (es *EventStore) FindByID(id string) (*Event, error) + func (es *EventStore) FindIDs(q *eventmaster.TimeQuery, stream streamFn) error + func (es *EventStore) GetDCs() ([]DC, error) + func (es *EventStore) GetTopics() ([]Topic, error) + func (es *EventStore) Update() error + func (es *EventStore) UpdateDC(updateReq *eventmaster.UpdateDCRequest) (string, error) + func (es *EventStore) UpdateTopic(oldName string, td Topic) (string, error) + type Events []*Event + func (evts Events) Len() int + func (evts Events) Less(i, j int) bool + func (evts Events) Swap(i, j int) + type Flags struct + CAFile string + CassandraServiceName string + CertFile string + ConfigFile string + KeyFile string + Port int + RsyslogPort int + RsyslogServer bool + StaticFiles string + Templates string + type GRPCServer struct + func NewGRPCServer(config *Flags, s *EventStore) *GRPCServer + func (s *GRPCServer) AddDC(ctx context.Context, d *eventmaster.DC) (*eventmaster.WriteResponse, error) + func (s *GRPCServer) AddEvent(ctx context.Context, evt *eventmaster.Event) (*eventmaster.WriteResponse, error) + func (s *GRPCServer) AddTopic(ctx context.Context, t *eventmaster.Topic) (*eventmaster.WriteResponse, error) + func (s *GRPCServer) DeleteTopic(ctx context.Context, t *eventmaster.DeleteTopicRequest) (*eventmaster.WriteResponse, error) + func (s *GRPCServer) GetDCs(ctx context.Context, _ *eventmaster.EmptyRequest) (*eventmaster.DCResult, error) + func (s *GRPCServer) GetEventByID(ctx context.Context, id *eventmaster.EventID) (*eventmaster.Event, error) + func (s *GRPCServer) GetEventIDs(q *eventmaster.TimeQuery, stream eventmaster.EventMaster_GetEventIDsServer) error + func (s *GRPCServer) GetEvents(q *eventmaster.Query, stream eventmaster.EventMaster_GetEventsServer) error + func (s *GRPCServer) GetTopics(ctx context.Context, _ *eventmaster.EmptyRequest) (*eventmaster.TopicResult, error) + func (s *GRPCServer) Healthcheck(ctx context.Context, in *eventmaster.HealthcheckRequest) (*eventmaster.HealthcheckResponse, error) + func (s *GRPCServer) UpdateDC(ctx context.Context, t *eventmaster.UpdateDCRequest) (*eventmaster.WriteResponse, error) + func (s *GRPCServer) UpdateTopic(ctx context.Context, t *eventmaster.UpdateTopicRequest) (*eventmaster.WriteResponse, error) + type GetEventPageData struct + Query *eventmaster.Query + Topics []Topic + type LogParser func(int64, string, string, string, string) *UnaddedEvent + type Pair struct + type Range struct + From time.Time + To time.Time + type RawTopic struct + ID string + Name string + Schema string + type RsyslogServer struct + func NewRsyslogServer(s *EventStore, tlsConfig *tls.Config, port int) (*RsyslogServer, error) + func (s *RsyslogServer) AcceptLogs() + func (s *RsyslogServer) Stop() error + type SearchResult struct + Results []*EventResult + type Server struct + func NewServer(store *EventStore, static, templates string) *Server + func (s *Server) HandleCreatePage(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (s *Server) HandleDCPage(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (s *Server) HandleGetEventPage(w http.ResponseWriter, r *http.Request, ps httprouter.Params) + func (s *Server) HandleMainPage(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (s *Server) HandleTopicPage(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (srv *Server) ServeHTTP(w http.ResponseWriter, req *http.Request) + type StatusRecorder struct + func NewStatusRecorder(w http.ResponseWriter) *StatusRecorder + func (sr *StatusRecorder) Status() int + func (sr *StatusRecorder) WriteHeader(status int) + type TemplateGetter interface + Get func(name string) (*template.Template, error) + type TemplateRequest struct + Target string + type Topic struct + ID string + Name string + Schema map[string]interface{} + type UnaddedEvent struct + DC string + Data map[string]interface{} + EventTime int64 + Host string + ParentEventID string + Tags []string + TargetHosts []string + TopicName string + User string v0.0.0 Aug 25, 2017
Go to main page