logs

Nov 30, 2017

Changes in this version

type GetReply

+ Size int32

+ Total int32

+ func (m *GetReply) GetSize() int32

+ func (m *GetReply) GetTotal() int32

type GetRequest

+ From string

+ func (m *GetRequest) GetFrom() string

type LogEntry

+ FromId string

+ func (m *LogEntry) GetFromId() string

type LogsClient

+ LogsGet func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)

+ LogsGetStream func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (Logs_LogsGetStreamClient, error)

type LogsServer

+ LogsGet func(context.Context, *GetRequest) (*GetReply, error)

+ LogsGetStream func(*GetRequest, Logs_LogsGetStreamServer) error

+ type Logs_LogsGetStreamClient interface

+ Recv func() (*LogEntry, error)

+ type Logs_LogsGetStreamServer interface

+ Send func(*LogEntry) error

type Server

+ func (s *Server) LogsGet(ctx context.Context, in *GetRequest) (*GetReply, error)

+ func (s *Server) LogsGetStream(in *GetRequest, stream Logs_LogsGetStreamServer) error

Nov 16, 2017

Changes in this version

+ func RegisterLogsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LogsClient) error

Aug 4, 2017

Changes in this version

type GetRequest

+ Regexp bool

+ func (m *GetRequest) GetRegexp() bool

Jul 25, 2017

Changes in this version

type GetRequest

+ Since int32

+ func (m *GetRequest) GetSince() int32

Jul 6, 2017

Changes in this version

+ const NumberOfEntries

type GetRequest

+ IncludeAmpLogs bool

+ func (m *GetRequest) GetIncludeAmpLogs() bool

type LogEntry

+ TaskSlot int32

+ func (m *LogEntry) GetTaskSlot() int32

May 19, 2017

Changes in this version

type GetRequest

+ Task string

+ func (m *GetRequest) GetTask() string

type Server

+ ES *elasticsearch.Elasticsearch

+ NS *ns.NatsStreaming

Apr 17, 2017

Changes in this version

type GetRequest

+ Infra bool

+ func (m *GetRequest) GetInfra() bool

type LogEntry

+ ContainerName string

+ ContainerShortName string

+ ContainerState string

+ Labels map[string]string

+ Msg string

+ func (m *LogEntry) GetContainerName() string

+ func (m *LogEntry) GetContainerShortName() string

+ func (m *LogEntry) GetContainerState() string

+ func (m *LogEntry) GetLabels() map[string]string

+ func (m *LogEntry) GetMsg() string

type Server

+ Docker *docker.Docker

Jan 3, 2017

Changes in this version

type Server

+ NatsStreaming ns.NatsStreaming

Dec 20, 2016

Changes in this version

+ func RegisterLogsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterLogsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

type GetRequest

+ func (m *GetRequest) GetContainer() string

+ func (m *GetRequest) GetMessage() string

+ func (m *GetRequest) GetNode() string

+ func (m *GetRequest) GetService() string

+ func (m *GetRequest) GetSize() int64

+ func (m *GetRequest) GetStack() string

type LogEntry

+ func (m *LogEntry) GetContainerId() string

+ func (m *LogEntry) GetMessage() string

+ func (m *LogEntry) GetNodeId() string

+ func (m *LogEntry) GetServiceId() string

+ func (m *LogEntry) GetServiceName() string

+ func (m *LogEntry) GetStackId() string

+ func (m *LogEntry) GetStackName() string

+ func (m *LogEntry) GetTaskId() string

+ func (m *LogEntry) GetTaskName() string

+ func (m *LogEntry) GetTimeId() string

+ func (m *LogEntry) GetTimestamp() string

+ type Server struct

+ Es *elasticsearch.Elasticsearch

+ Nats stan.Conn

+ Store storage.Interface

+ func (s *Server) Get(ctx context.Context, in *GetRequest) (*GetReply, error)

+ func (s *Server) GetStream(in *GetRequest, stream Logs_GetStreamServer) error

Oct 19, 2016

Changes in this version

+ const NatsLogTopic

type Logs

+ Nats stan.Conn

Oct 12, 2016

Changes in this version

+ func RegisterLogsServer(s *grpc.Server, srv LogsServer)

+ type GetReply struct

+ Entries []*LogEntry

+ func (*GetReply) Descriptor() ([]byte, []int)

+ func (*GetReply) ProtoMessage()

+ func (m *GetReply) GetEntries() []*LogEntry

+ func (m *GetReply) Reset()

+ func (m *GetReply) String() string

+ type GetRequest struct

+ Container string

+ Message string

+ Node string

+ Service string

+ Size int64

+ Stack string

+ func (*GetRequest) Descriptor() ([]byte, []int)

+ func (*GetRequest) ProtoMessage()

+ func (m *GetRequest) Reset()

+ func (m *GetRequest) String() string

+ type LogEntry struct

+ ContainerId string

+ Message string

+ NodeId string

+ ServiceId string

+ ServiceName string

+ StackId string

+ StackName string

+ TaskId string

+ TaskName string

+ TimeId string

+ Timestamp string

+ func (*LogEntry) Descriptor() ([]byte, []int)

+ func (*LogEntry) ProtoMessage()

+ func (m *LogEntry) Reset()

+ func (m *LogEntry) String() string

+ type Logs struct

+ Es elasticsearch.Elasticsearch

+ Kafka kafka.Kafka

+ Store storage.Interface

+ func (logs *Logs) Get(ctx context.Context, in *GetRequest) (*GetReply, error)

+ func (logs *Logs) GetStream(in *GetRequest, stream Logs_GetStreamServer) error

+ type LogsClient interface

+ Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)

+ GetStream func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (Logs_GetStreamClient, error)

+ func NewLogsClient(cc *grpc.ClientConn) LogsClient

+ type LogsServer interface

+ Get func(context.Context, *GetRequest) (*GetReply, error)

+ GetStream func(*GetRequest, Logs_GetStreamServer) error

+ type Logs_GetStreamClient interface

+ Recv func() (*LogEntry, error)

+ type Logs_GetStreamServer interface

+ Send func(*LogEntry) error