logs

Documentation

Overview

Package logs is a generated protocol buffer package.

It is generated from these files:

github.com/appcelerator/amp/api/rpc/logs/logs.proto

It has these top-level messages:

LogEntry
GetRequest
GetReply

Index

• Constants
• func RegisterLogsServer(s *grpc.Server, srv LogsServer)
• type GetReply
  • func (*GetReply) Descriptor() ([]byte, []int)
  • func (m *GetReply) GetEntries() []*LogEntry
  • func (*GetReply) ProtoMessage()
  • func (m *GetReply) Reset()
  • func (m *GetReply) String() string
• type GetRequest
  • func (*GetRequest) Descriptor() ([]byte, []int)
  • func (*GetRequest) ProtoMessage()
  • func (m *GetRequest) Reset()
  • func (m *GetRequest) String() string
• type LogEntry
  • func (*LogEntry) Descriptor() ([]byte, []int)
  • func (*LogEntry) ProtoMessage()
  • func (m *LogEntry) Reset()
  • func (m *LogEntry) String() string
• type Logs
  • func (logs *Logs) Get(ctx context.Context, in *GetRequest) (*GetReply, error)
  • func (logs *Logs) GetStream(in *GetRequest, stream Logs_GetStreamServer) error
• type LogsClient
  • func NewLogsClient(cc *grpc.ClientConn) LogsClient
• type LogsServer
• type Logs_GetStreamClient
• type Logs_GetStreamServer

Constants

const (

	// NatsLogTopic is the nats channel
	NatsLogTopic = "amp-logs"
)

Functions

func RegisterLogsServer

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

Types

type GetReply

type GetReply struct {
	Entries []*LogEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
}

func (*GetReply) Descriptor

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

func (*GetReply) GetEntries

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

func (*GetReply) ProtoMessage

func (*GetReply) ProtoMessage()

func (*GetReply) Reset

func (m *GetReply) Reset()

func (*GetReply) String

func (m *GetReply) String() string

type GetRequest

type GetRequest struct {
	Container string `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
	Message   string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	Node      string `protobuf:"bytes,3,opt,name=node" json:"node,omitempty"`
	Size      int64  `protobuf:"zigzag64,4,opt,name=size" json:"size,omitempty"`
	Service   string `protobuf:"bytes,5,opt,name=service" json:"service,omitempty"`
	Stack     string `protobuf:"bytes,6,opt,name=stack" json:"stack,omitempty"`
}

func (*GetRequest) Descriptor

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

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset

func (m *GetRequest) Reset()

func (*GetRequest) String

func (m *GetRequest) String() string

type LogEntry

type LogEntry struct {
	Timestamp   string `protobuf:"bytes,1,opt,name=timestamp" json:"timestamp,omitempty"`
	TimeId      string `protobuf:"bytes,2,opt,name=time_id,json=timeId" json:"time_id,omitempty"`
	ServiceId   string `protobuf:"bytes,3,opt,name=service_id,json=serviceId" json:"service_id,omitempty"`
	ServiceName string `protobuf:"bytes,4,opt,name=service_name,json=serviceName" json:"service_name,omitempty"`
	Message     string `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	ContainerId string `protobuf:"bytes,6,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	NodeId      string `protobuf:"bytes,7,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	TaskId      string `protobuf:"bytes,8,opt,name=task_id,json=taskId" json:"task_id,omitempty"`
	TaskName    string `protobuf:"bytes,9,opt,name=task_name,json=taskName" json:"task_name,omitempty"`
	StackId     string `protobuf:"bytes,10,opt,name=stack_id,json=stackId" json:"stack_id,omitempty"`
	StackName   string `protobuf:"bytes,11,opt,name=stack_name,json=stackName" json:"stack_name,omitempty"`
}

func (*LogEntry) Descriptor

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

func (*LogEntry) ProtoMessage

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset

func (m *LogEntry) Reset()

func (*LogEntry) String

func (m *LogEntry) String() string

type Logs

type Logs struct {
	Es    elasticsearch.Elasticsearch
	Store storage.Interface
	Nats  stan.Conn
}

Logs is used to implement log.LogServer

func (*Logs) Get

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

Get implements log.LogServer

func (*Logs) GetStream

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

GetStream implements log.LogServer

type LogsClient

type LogsClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
	GetStream(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (Logs_GetStreamClient, error)
}

func NewLogsClient

func NewLogsClient(cc *grpc.ClientConn) LogsClient

type LogsServer

type LogsServer interface {
	Get(context.Context, *GetRequest) (*GetReply, error)
	GetStream(*GetRequest, Logs_GetStreamServer) error
}

type Logs_GetStreamClient

type Logs_GetStreamClient interface {
	Recv() (*LogEntry, error)
	grpc.ClientStream
}

type Logs_GetStreamServer

type Logs_GetStreamServer interface {
	Send(*LogEntry) error
	grpc.ServerStream
}