proto

README

protoc pkg/messenger/proto/message.proto --go_out=plugins=grpc:.

Documentation

Index

• func RegisterMessageServiceServer(s *grpc.Server, srv MessageServiceServer)
• type CreateMessageReply
  • func (*CreateMessageReply) Descriptor() ([]byte, []int)
  • func (m *CreateMessageReply) GetMsgID() string
  • func (m *CreateMessageReply) GetMsgSeqID() int32
  • func (*CreateMessageReply) ProtoMessage()
  • func (m *CreateMessageReply) Reset()
  • func (m *CreateMessageReply) String() string
  • func (m *CreateMessageReply) XXX_DiscardUnknown()
  • func (m *CreateMessageReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *CreateMessageReply) XXX_Merge(src proto.Message)
  • func (m *CreateMessageReply) XXX_Size() int
  • func (m *CreateMessageReply) XXX_Unmarshal(b []byte) error
• type CreateMessageRequest
  • func (*CreateMessageRequest) Descriptor() ([]byte, []int)
  • func (m *CreateMessageRequest) GetData() []byte
  • func (*CreateMessageRequest) ProtoMessage()
  • func (m *CreateMessageRequest) Reset()
  • func (m *CreateMessageRequest) String() string
  • func (m *CreateMessageRequest) XXX_DiscardUnknown()
  • func (m *CreateMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *CreateMessageRequest) XXX_Merge(src proto.Message)
  • func (m *CreateMessageRequest) XXX_Size() int
  • func (m *CreateMessageRequest) XXX_Unmarshal(b []byte) error
• type EmptyReply
  • func (*EmptyReply) Descriptor() ([]byte, []int)
  • func (*EmptyReply) ProtoMessage()
  • func (m *EmptyReply) Reset()
  • func (m *EmptyReply) String() string
  • func (m *EmptyReply) XXX_DiscardUnknown()
  • func (m *EmptyReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *EmptyReply) XXX_Merge(src proto.Message)
  • func (m *EmptyReply) XXX_Size() int
  • func (m *EmptyReply) XXX_Unmarshal(b []byte) error
• type EmptyRequest
  • func (*EmptyRequest) Descriptor() ([]byte, []int)
  • func (*EmptyRequest) ProtoMessage()
  • func (m *EmptyRequest) Reset()
  • func (m *EmptyRequest) String() string
  • func (m *EmptyRequest) XXX_DiscardUnknown()
  • func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *EmptyRequest) XXX_Merge(src proto.Message)
  • func (m *EmptyRequest) XXX_Size() int
  • func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
• type MessageServiceClient
  • func NewMessageServiceClient(cc *grpc.ClientConn) MessageServiceClient
• type MessageServiceServer

Functions

func RegisterMessageServiceServer

func RegisterMessageServiceServer(s *grpc.Server, srv MessageServiceServer)

Types

type CreateMessageReply

type CreateMessageReply struct {
	MsgID                string   `protobuf:"bytes,1,opt,name=MsgID,proto3" json:"MsgID,omitempty"`
	MsgSeqID             int32    `protobuf:"varint,2,opt,name=MsgSeqID,proto3" json:"MsgSeqID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateMessageReply) Descriptor

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

func (*CreateMessageReply) GetMsgID

func (m *CreateMessageReply) GetMsgID() string

func (*CreateMessageReply) GetMsgSeqID

func (m *CreateMessageReply) GetMsgSeqID() int32

func (*CreateMessageReply) ProtoMessage

func (*CreateMessageReply) ProtoMessage()

func (*CreateMessageReply) Reset

func (m *CreateMessageReply) Reset()

func (*CreateMessageReply) String

func (m *CreateMessageReply) String() string

func (*CreateMessageReply) XXX_DiscardUnknown

func (m *CreateMessageReply) XXX_DiscardUnknown()

func (*CreateMessageReply) XXX_Marshal

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

func (*CreateMessageReply) XXX_Merge

func (dst *CreateMessageReply) XXX_Merge(src proto.Message)

func (*CreateMessageReply) XXX_Size

func (m *CreateMessageReply) XXX_Size() int

func (*CreateMessageReply) XXX_Unmarshal

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

type CreateMessageRequest

type CreateMessageRequest struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateMessageRequest) Descriptor

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

func (*CreateMessageRequest) GetData

func (m *CreateMessageRequest) GetData() []byte

func (*CreateMessageRequest) ProtoMessage

func (*CreateMessageRequest) ProtoMessage()

func (*CreateMessageRequest) Reset

func (m *CreateMessageRequest) Reset()

func (*CreateMessageRequest) String

func (m *CreateMessageRequest) String() string

func (*CreateMessageRequest) XXX_DiscardUnknown

func (m *CreateMessageRequest) XXX_DiscardUnknown()

func (*CreateMessageRequest) XXX_Marshal

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

func (*CreateMessageRequest) XXX_Merge

func (dst *CreateMessageRequest) XXX_Merge(src proto.Message)

func (*CreateMessageRequest) XXX_Size

func (m *CreateMessageRequest) XXX_Size() int

func (*CreateMessageRequest) XXX_Unmarshal

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

type EmptyReply

type EmptyReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmptyReply) Descriptor

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

func (*EmptyReply) ProtoMessage

func (*EmptyReply) ProtoMessage()

func (*EmptyReply) Reset

func (m *EmptyReply) Reset()

func (*EmptyReply) String

func (m *EmptyReply) String() string

func (*EmptyReply) XXX_DiscardUnknown

func (m *EmptyReply) XXX_DiscardUnknown()

func (*EmptyReply) XXX_Marshal

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

func (*EmptyReply) XXX_Merge

func (dst *EmptyReply) XXX_Merge(src proto.Message)

func (*EmptyReply) XXX_Size

func (m *EmptyReply) XXX_Size() int

func (*EmptyReply) XXX_Unmarshal

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

type EmptyRequest

type EmptyRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmptyRequest) Descriptor

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

func (*EmptyRequest) ProtoMessage

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) Reset

func (m *EmptyRequest) Reset()

func (*EmptyRequest) String

func (m *EmptyRequest) String() string

func (*EmptyRequest) XXX_DiscardUnknown

func (m *EmptyRequest) XXX_DiscardUnknown()

func (*EmptyRequest) XXX_Marshal

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

func (*EmptyRequest) XXX_Merge

func (dst *EmptyRequest) XXX_Merge(src proto.Message)

func (*EmptyRequest) XXX_Size

func (m *EmptyRequest) XXX_Size() int

func (*EmptyRequest) XXX_Unmarshal

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

type MessageServiceClient

type MessageServiceClient interface {
	CreateMessage(ctx context.Context, in *CreateMessageRequest, opts ...grpc.CallOption) (*CreateMessageReply, error)
}

MessageServiceClient is the client API for MessageService service.

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

func NewMessageServiceClient

func NewMessageServiceClient(cc *grpc.ClientConn) MessageServiceClient

type MessageServiceServer

type MessageServiceServer interface {
	CreateMessage(context.Context, *CreateMessageRequest) (*CreateMessageReply, error)
}

MessageServiceServer is the server API for MessageService service.