Versions in this module Expand all Collapse all v0 v0.2.0 Sep 11, 2017 Changes in this version + type AggregateStatistics struct + type Config struct + Host string + LoggerConfig *journal.Config + Port int + StatsPath string + TokenPath string + UnixSockPath string + type LogServer struct + func New(config *Config) (*LogServer, error) + func (l *LogServer) AddToken(service, instance string) (string, error) + func (l *LogServer) AggregateServiceStatistics() (totalVolume int64, services []*AggregateStatistics, hourly [24][2]int64) + func (l *LogServer) Authorize(ctx context.Context) error + func (l *LogServer) GatherStatistics(service, instance, key, ip string, logEntry *logrpc.LogEntry) + func (l *LogServer) KillSwitch() chan bool + func (l *LogServer) Logfiles() (map[string]string, error) + func (l *LogServer) Quit() + func (l *LogServer) RemoteLog(ctx context.Context, logEntry *logrpc.LogEntry) (*logrpc.Nothing, error) + func (l *LogServer) RemoveToken(service, instance string, lock bool) error + func (l *LogServer) RemoveTokens(service string) error + type ManagementConsole interface + CmdLogsList func(unixsock.Args) *unixsock.Response + CmdRemoteAdd func(unixsock.Args) *unixsock.Response + CmdRemoteList func(unixsock.Args) *unixsock.Response + CmdRemoteRemove func(unixsock.Args) *unixsock.Response + CmdStatistics func(unixsock.Args) *unixsock.Response + CmdTokensAdd func(unixsock.Args) *unixsock.Response + CmdTokensListInstances func(unixsock.Args) *unixsock.Response + CmdTokensListServices func(unixsock.Args) *unixsock.Response + CmdTokensRemoveInstance func(unixsock.Args) *unixsock.Response + CmdTokensRemoveService func(unixsock.Args) *unixsock.Response + Execute func(string, unixsock.Args) *unixsock.Response + func NewConsole(server *LogServer) ManagementConsole + type Statistic struct + Instance string + LastActive time.Time + LastIP string + LogsParsed [24]int64 + LogsParsedBytes [24]int64 + Service string v0.1.2-alpha Sep 11, 2017 v0.1.1-alpha Sep 11, 2017 v0.1.0-alpha Sep 8, 2017
Go to main page