logdrpc

Documentation

Index

• func RegisterLoggerServer(s *grpc.Server, srv LoggerServer)
• func ToMessage(m *Message) (res logger.Message, err error)
• type LoggerClient
  • func NewLoggerClient(cc grpc.ClientConnInterface) LoggerClient
• type LoggerServer
• type Message
  • func FromMessage(m logger.Message) *Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetData() string
  • func (m *Message) GetIdentifier() string
  • func (m *Message) GetLogMessage() string
  • func (m *Message) GetLogName() string
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) String() string
  • func (m *Message) XXX_DiscardUnknown()
  • func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Message) XXX_Merge(src proto.Message)
  • func (m *Message) XXX_Size() int
  • func (m *Message) XXX_Unmarshal(b []byte) error
• type UnimplementedLoggerServer
  • func (*UnimplementedLoggerServer) LogMessage(ctx context.Context, req *Message) (*empty.Empty, error)

Functions

func RegisterLoggerServer

func RegisterLoggerServer(s *grpc.Server, srv LoggerServer)

func ToMessage

func ToMessage(m *Message) (res logger.Message, err error)

ToMessage converts the given *Message to a logger.Message.

Types

type LoggerClient

type LoggerClient interface {
	LogMessage(ctx context.Context, in *Message, opts ...grpc.CallOption) (*empty.Empty, error)
}

LoggerClient is the client API for Logger service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLoggerClient

func NewLoggerClient(cc grpc.ClientConnInterface) LoggerClient

type LoggerServer

type LoggerServer interface {
	LogMessage(context.Context, *Message) (*empty.Empty, error)
}

LoggerServer is the server API for Logger service.

type Message

type Message struct {
	Identifier           string   `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	LogName              string   `protobuf:"bytes,2,opt,name=log_name,json=logName,proto3" json:"log_name,omitempty"`
	LogMessage           string   `protobuf:"bytes,3,opt,name=log_message,json=logMessage,proto3" json:"log_message,omitempty"`
	Data                 string   `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func FromMessage

func FromMessage(m logger.Message) *Message

FromMessage converts the given logger.Message to a *Message.

func (*Message) Descriptor

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

func (*Message) GetData

func (m *Message) GetData() string

func (*Message) GetIdentifier

func (m *Message) GetIdentifier() string

func (*Message) GetLogMessage

func (m *Message) GetLogMessage() string

func (*Message) GetLogName

func (m *Message) GetLogName() string

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) String

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal

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

func (*Message) XXX_Merge

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

func (*Message) XXX_Size

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal

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

type UnimplementedLoggerServer

type UnimplementedLoggerServer struct {
}

UnimplementedLoggerServer can be embedded to have forward compatible implementations.

func (*UnimplementedLoggerServer) LogMessage

func (*UnimplementedLoggerServer) LogMessage(ctx context.Context, req *Message) (*empty.Empty, error)