pb

Documentation

Index

• func RegisterEventLogServer(s *grpc.Server, srv EventLogServer)
• type EventLogClient
  • func NewEventLogClient(cc *grpc.ClientConn) EventLogClient
• type EventLogServer
• type EventLog_LogClient
• type EventLog_LogServer
• type LogMessage
  • func (*LogMessage) Descriptor() ([]byte, []int)
  • func (m *LogMessage) GetLog() []byte
  • func (*LogMessage) ProtoMessage()
  • func (m *LogMessage) Reset()
  • func (m *LogMessage) String() string
• type Reply
  • func (*Reply) Descriptor() ([]byte, []int)
  • func (m *Reply) GetMessage() string
  • func (m *Reply) GetStatus() string
  • func (*Reply) ProtoMessage()
  • func (m *Reply) Reset()
  • func (m *Reply) String() string

Functions

func RegisterEventLogServer

func RegisterEventLogServer(s *grpc.Server, srv EventLogServer)

Types

type EventLogClient

type EventLogClient interface {
	Log(ctx context.Context, opts ...grpc.CallOption) (EventLog_LogClient, error)
}

func NewEventLogClient

func NewEventLogClient(cc *grpc.ClientConn) EventLogClient

type EventLogServer

type EventLogServer interface {
	Log(EventLog_LogServer) error
}

type EventLog_LogClient

type EventLog_LogClient interface {
	Send(*LogMessage) error
	CloseAndRecv() (*Reply, error)
	grpc.ClientStream
}

type EventLog_LogServer

type EventLog_LogServer interface {
	SendAndClose(*Reply) error
	Recv() (*LogMessage, error)
	grpc.ServerStream
}

type LogMessage

type LogMessage struct {
	Log []byte `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"`
}

func (*LogMessage) Descriptor

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

func (*LogMessage) GetLog

func (m *LogMessage) GetLog() []byte

func (*LogMessage) ProtoMessage

func (*LogMessage) ProtoMessage()

func (*LogMessage) Reset

func (m *LogMessage) Reset()

func (*LogMessage) String

func (m *LogMessage) String() string

type Reply

type Reply struct {
	Status  string `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}

func (*Reply) Descriptor

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

func (*Reply) GetMessage

func (m *Reply) GetMessage() string

func (*Reply) GetStatus

func (m *Reply) GetStatus() string

func (*Reply) ProtoMessage

func (*Reply) ProtoMessage()

func (*Reply) Reset

func (m *Reply) Reset()

func (*Reply) String

func (m *Reply) String() string