go_micro_debug_log

Documentation

Index

• func NewLogEndpoints() []*api.Endpoint
• func RegisterLogHandler(s server.Server, hdlr LogHandler, opts ...server.HandlerOption) error
• type LogHandler
• type LogService
  • func NewLogService(name string, c client.Client) LogService
• type ReadRequest
  • func (*ReadRequest) Descriptor() ([]byte, []int)
  • func (m *ReadRequest) GetService() string
  • func (m *ReadRequest) GetVersion() string
  • func (*ReadRequest) ProtoMessage()
  • func (m *ReadRequest) Reset()
  • func (m *ReadRequest) String() string
  • func (m *ReadRequest) XXX_DiscardUnknown()
  • func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ReadRequest) XXX_Merge(src proto.Message)
  • func (m *ReadRequest) XXX_Size() int
  • func (m *ReadRequest) XXX_Unmarshal(b []byte) error
• type ReadResponse
  • func (*ReadResponse) Descriptor() ([]byte, []int)
  • func (m *ReadResponse) GetRecords() []*Record
  • func (*ReadResponse) ProtoMessage()
  • func (m *ReadResponse) Reset()
  • func (m *ReadResponse) String() string
  • func (m *ReadResponse) XXX_DiscardUnknown()
  • func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ReadResponse) XXX_Merge(src proto.Message)
  • func (m *ReadResponse) XXX_Size() int
  • func (m *ReadResponse) XXX_Unmarshal(b []byte) error
• type Record
  • func (*Record) Descriptor() ([]byte, []int)
  • func (m *Record) GetMessage() string
  • func (m *Record) GetMetadata() map[string]string
  • func (m *Record) GetTimestamp() int64
  • func (*Record) ProtoMessage()
  • func (m *Record) Reset()
  • func (m *Record) String() string
  • func (m *Record) XXX_DiscardUnknown()
  • func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Record) XXX_Merge(src proto.Message)
  • func (m *Record) XXX_Size() int
  • func (m *Record) XXX_Unmarshal(b []byte) error

Functions

func NewLogEndpoints

func NewLogEndpoints() []*api.Endpoint

func RegisterLogHandler

func RegisterLogHandler(s server.Server, hdlr LogHandler, opts ...server.HandlerOption) error

Types

type LogHandler

type LogHandler interface {
	Read(context.Context, *ReadRequest, *ReadResponse) error
}

type LogService

type LogService interface {
	Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)
}

func NewLogService

func NewLogService(name string, c client.Client) LogService

type ReadRequest

type ReadRequest struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadRequest) Descriptor

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

func (*ReadRequest) GetService

func (m *ReadRequest) GetService() string

func (*ReadRequest) GetVersion

func (m *ReadRequest) GetVersion() string

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset

func (m *ReadRequest) Reset()

func (*ReadRequest) String

func (m *ReadRequest) String() string

func (*ReadRequest) XXX_DiscardUnknown

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal

func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadRequest) XXX_Merge

func (m *ReadRequest) XXX_Merge(src proto.Message)

func (*ReadRequest) XXX_Size

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal

func (m *ReadRequest) XXX_Unmarshal(b []byte) error

type ReadResponse

type ReadResponse struct {
	Records              []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ReadResponse) Descriptor

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

func (*ReadResponse) GetRecords

func (m *ReadResponse) GetRecords() []*Record

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset

func (m *ReadResponse) Reset()

func (*ReadResponse) String

func (m *ReadResponse) String() string

func (*ReadResponse) XXX_DiscardUnknown

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal

func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadResponse) XXX_Merge

func (m *ReadResponse) XXX_Merge(src proto.Message)

func (*ReadResponse) XXX_Size

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal

func (m *ReadResponse) XXX_Unmarshal(b []byte) error

type Record

type Record struct {
	// timestamp of log record
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// record metadata
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// record value
	Message              string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Record) Descriptor

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

func (*Record) GetMessage

func (m *Record) GetMessage() string

func (*Record) GetMetadata

func (m *Record) GetMetadata() map[string]string

func (*Record) GetTimestamp

func (m *Record) GetTimestamp() int64

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) Reset

func (m *Record) Reset()

func (*Record) String

func (m *Record) String() string

func (*Record) XXX_DiscardUnknown

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal

func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Record) XXX_Merge

func (m *Record) XXX_Merge(src proto.Message)

func (*Record) XXX_Size

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal

func (m *Record) XXX_Unmarshal(b []byte) error