Documentation ¶
Index ¶
- Variables
- func RegisterUserServiceServer(s *grpc.Server, srv UserServiceServer)
- type Any
- func (*Any) Descriptor() ([]byte, []int)
- func (m *Any) GetTypeUrl() string
- func (m *Any) GetValue() []byte
- func (*Any) ProtoMessage()
- func (m *Any) Reset()
- func (m *Any) String() string
- func (m *Any) XXX_DiscardUnknown()
- func (m *Any) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Any) XXX_Merge(src proto.Message)
- func (m *Any) XXX_Size() int
- func (m *Any) XXX_Unmarshal(b []byte) error
- type CreateConnectionRequest
- func (*CreateConnectionRequest) Descriptor() ([]byte, []int)
- func (m *CreateConnectionRequest) GetConnection() *CreateConnectionRequest_ConnectionInfo
- func (*CreateConnectionRequest) ProtoMessage()
- func (m *CreateConnectionRequest) Reset()
- func (m *CreateConnectionRequest) String() string
- func (m *CreateConnectionRequest) XXX_DiscardUnknown()
- func (m *CreateConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateConnectionRequest) XXX_Merge(src proto.Message)
- func (m *CreateConnectionRequest) XXX_Size() int
- func (m *CreateConnectionRequest) XXX_Unmarshal(b []byte) error
- type CreateConnectionRequest_ConnectionInfo
- func (*CreateConnectionRequest_ConnectionInfo) Descriptor() ([]byte, []int)
- func (m *CreateConnectionRequest_ConnectionInfo) GetEmail() string
- func (m *CreateConnectionRequest_ConnectionInfo) GetPhoneNumber() string
- func (m *CreateConnectionRequest_ConnectionInfo) GetUID() string
- func (*CreateConnectionRequest_ConnectionInfo) ProtoMessage()
- func (m *CreateConnectionRequest_ConnectionInfo) Reset()
- func (m *CreateConnectionRequest_ConnectionInfo) String() string
- func (m *CreateConnectionRequest_ConnectionInfo) XXX_DiscardUnknown()
- func (m *CreateConnectionRequest_ConnectionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateConnectionRequest_ConnectionInfo) XXX_Merge(src proto.Message)
- func (m *CreateConnectionRequest_ConnectionInfo) XXX_Size() int
- func (m *CreateConnectionRequest_ConnectionInfo) XXX_Unmarshal(b []byte) error
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (m *Empty) GetEmpty() string
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type FetchMessagesRequest
- func (*FetchMessagesRequest) Descriptor() ([]byte, []int)
- func (m *FetchMessagesRequest) GetChannelId() string
- func (m *FetchMessagesRequest) GetPage() uint64
- func (*FetchMessagesRequest) ProtoMessage()
- func (m *FetchMessagesRequest) Reset()
- func (m *FetchMessagesRequest) String() string
- func (m *FetchMessagesRequest) XXX_DiscardUnknown()
- func (m *FetchMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchMessagesRequest) XXX_Merge(src proto.Message)
- func (m *FetchMessagesRequest) XXX_Size() int
- func (m *FetchMessagesRequest) XXX_Unmarshal(b []byte) error
- type FetchMessagesResponse
- func (*FetchMessagesResponse) Descriptor() ([]byte, []int)
- func (m *FetchMessagesResponse) GetMessages() []*FetchMessagesResponse_Message
- func (*FetchMessagesResponse) ProtoMessage()
- func (m *FetchMessagesResponse) Reset()
- func (m *FetchMessagesResponse) String() string
- func (m *FetchMessagesResponse) XXX_DiscardUnknown()
- func (m *FetchMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchMessagesResponse) XXX_Merge(src proto.Message)
- func (m *FetchMessagesResponse) XXX_Size() int
- func (m *FetchMessagesResponse) XXX_Unmarshal(b []byte) error
- type FetchMessagesResponse_Message
- func (*FetchMessagesResponse_Message) Descriptor() ([]byte, []int)
- func (m *FetchMessagesResponse_Message) GetChannelId() string
- func (m *FetchMessagesResponse_Message) GetChannelIndex() string
- func (m *FetchMessagesResponse_Message) GetCreatedAt() string
- func (m *FetchMessagesResponse_Message) GetMessageReference() string
- func (m *FetchMessagesResponse_Message) GetUpdatedAt() string
- func (*FetchMessagesResponse_Message) ProtoMessage()
- func (m *FetchMessagesResponse_Message) Reset()
- func (m *FetchMessagesResponse_Message) String() string
- func (m *FetchMessagesResponse_Message) XXX_DiscardUnknown()
- func (m *FetchMessagesResponse_Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchMessagesResponse_Message) XXX_Merge(src proto.Message)
- func (m *FetchMessagesResponse_Message) XXX_Size() int
- func (m *FetchMessagesResponse_Message) XXX_Unmarshal(b []byte) error
- type ReportChannelsResponse
- func (*ReportChannelsResponse) Descriptor() ([]byte, []int)
- func (m *ReportChannelsResponse) GetChannels() []*ReportChannelsResponse_ChannelItem
- func (m *ReportChannelsResponse) GetPerPageMessage() uint64
- func (*ReportChannelsResponse) ProtoMessage()
- func (m *ReportChannelsResponse) Reset()
- func (m *ReportChannelsResponse) String() string
- func (m *ReportChannelsResponse) XXX_DiscardUnknown()
- func (m *ReportChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportChannelsResponse) XXX_Merge(src proto.Message)
- func (m *ReportChannelsResponse) XXX_Size() int
- func (m *ReportChannelsResponse) XXX_Unmarshal(b []byte) error
- type ReportChannelsResponse_ChannelItem
- func (*ReportChannelsResponse_ChannelItem) Descriptor() ([]byte, []int)
- func (m *ReportChannelsResponse_ChannelItem) GetChannelId() string
- func (m *ReportChannelsResponse_ChannelItem) GetChannelName() string
- func (m *ReportChannelsResponse_ChannelItem) GetChannelOffset() uint64
- func (m *ReportChannelsResponse_ChannelItem) GetChannelType() string
- func (m *ReportChannelsResponse_ChannelItem) GetYourOffset() uint64
- func (*ReportChannelsResponse_ChannelItem) ProtoMessage()
- func (m *ReportChannelsResponse_ChannelItem) Reset()
- func (m *ReportChannelsResponse_ChannelItem) String() string
- func (m *ReportChannelsResponse_ChannelItem) XXX_DiscardUnknown()
- func (m *ReportChannelsResponse_ChannelItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportChannelsResponse_ChannelItem) XXX_Merge(src proto.Message)
- func (m *ReportChannelsResponse_ChannelItem) XXX_Size() int
- func (m *ReportChannelsResponse_ChannelItem) XXX_Unmarshal(b []byte) error
- type ReqMeta
- func (*ReqMeta) Descriptor() ([]byte, []int)
- func (m *ReqMeta) GetAction() *RequestMetaAction
- func (m *ReqMeta) GetEndAt() string
- func (m *ReqMeta) GetFID() string
- func (m *ReqMeta) GetFilters() *RequestMetaFilter
- func (m *ReqMeta) GetIpAddress() string
- func (m *ReqMeta) GetPage() uint32
- func (m *ReqMeta) GetPerPage() uint32
- func (m *ReqMeta) GetSorts() *RequestMetaSorts
- func (m *ReqMeta) GetStartAt() string
- func (m *ReqMeta) GetUID() string
- func (m *ReqMeta) GetUTP() string
- func (*ReqMeta) ProtoMessage()
- func (m *ReqMeta) Reset()
- func (m *ReqMeta) String() string
- func (m *ReqMeta) XXX_DiscardUnknown()
- func (m *ReqMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReqMeta) XXX_Merge(src proto.Message)
- func (m *ReqMeta) XXX_Size() int
- func (m *ReqMeta) XXX_Unmarshal(b []byte) error
- type RequestMessage
- func (*RequestMessage) Descriptor() ([]byte, []int)
- func (m *RequestMessage) GetBody() *Any
- func (m *RequestMessage) GetHeader() *ReqMeta
- func (m *RequestMessage) GetName() string
- func (m *RequestMessage) GetTime() string
- func (m *RequestMessage) GetType() string
- func (*RequestMessage) ProtoMessage()
- func (m *RequestMessage) Reset()
- func (m *RequestMessage) String() string
- func (m *RequestMessage) XXX_DiscardUnknown()
- func (m *RequestMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestMessage) XXX_Merge(src proto.Message)
- func (m *RequestMessage) XXX_Size() int
- func (m *RequestMessage) XXX_Unmarshal(b []byte) error
- type RequestMetaAction
- func (*RequestMetaAction) Descriptor() ([]byte, []int)
- func (m *RequestMetaAction) GetActionType() string
- func (*RequestMetaAction) ProtoMessage()
- func (m *RequestMetaAction) Reset()
- func (m *RequestMetaAction) String() string
- func (m *RequestMetaAction) XXX_DiscardUnknown()
- func (m *RequestMetaAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestMetaAction) XXX_Merge(src proto.Message)
- func (m *RequestMetaAction) XXX_Size() int
- func (m *RequestMetaAction) XXX_Unmarshal(b []byte) error
- type RequestMetaFilter
- func (*RequestMetaFilter) Descriptor() ([]byte, []int)
- func (m *RequestMetaFilter) GetOpt() string
- func (m *RequestMetaFilter) GetType() string
- func (m *RequestMetaFilter) GetValue() string
- func (*RequestMetaFilter) ProtoMessage()
- func (m *RequestMetaFilter) Reset()
- func (m *RequestMetaFilter) String() string
- func (m *RequestMetaFilter) XXX_DiscardUnknown()
- func (m *RequestMetaFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestMetaFilter) XXX_Merge(src proto.Message)
- func (m *RequestMetaFilter) XXX_Size() int
- func (m *RequestMetaFilter) XXX_Unmarshal(b []byte) error
- type RequestMetaSorts
- func (*RequestMetaSorts) Descriptor() ([]byte, []int)
- func (m *RequestMetaSorts) GetDir() uint32
- func (m *RequestMetaSorts) GetName() string
- func (*RequestMetaSorts) ProtoMessage()
- func (m *RequestMetaSorts) Reset()
- func (m *RequestMetaSorts) String() string
- func (m *RequestMetaSorts) XXX_DiscardUnknown()
- func (m *RequestMetaSorts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestMetaSorts) XXX_Merge(src proto.Message)
- func (m *RequestMetaSorts) XXX_Size() int
- func (m *RequestMetaSorts) XXX_Unmarshal(b []byte) error
- type RequestMetaSortsDirection
- type ResponseMessage
- func (*ResponseMessage) Descriptor() ([]byte, []int)
- func (m *ResponseMessage) GetData() *Any
- func (m *ResponseMessage) GetEntity() string
- func (m *ResponseMessage) GetMeta() *ResponseMetadata
- func (*ResponseMessage) ProtoMessage()
- func (m *ResponseMessage) Reset()
- func (m *ResponseMessage) String() string
- func (m *ResponseMessage) XXX_DiscardUnknown()
- func (m *ResponseMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseMessage) XXX_Merge(src proto.Message)
- func (m *ResponseMessage) XXX_Size() int
- func (m *ResponseMessage) XXX_Unmarshal(b []byte) error
- type ResponseMetadata
- func (*ResponseMetadata) Descriptor() ([]byte, []int)
- func (m *ResponseMetadata) GetPage() uint32
- func (m *ResponseMetadata) GetPerPage() uint32
- func (m *ResponseMetadata) GetTotal() uint32
- func (*ResponseMetadata) ProtoMessage()
- func (m *ResponseMetadata) Reset()
- func (m *ResponseMetadata) String() string
- func (m *ResponseMetadata) XXX_DiscardUnknown()
- func (m *ResponseMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseMetadata) XXX_Merge(src proto.Message)
- func (m *ResponseMetadata) XXX_Size() int
- func (m *ResponseMetadata) XXX_Unmarshal(b []byte) error
- type SendMessageRequest
- func (*SendMessageRequest) Descriptor() ([]byte, []int)
- func (m *SendMessageRequest) GetChannelId() string
- func (m *SendMessageRequest) GetCreatedAt() string
- func (m *SendMessageRequest) GetMessageReference() string
- func (*SendMessageRequest) ProtoMessage()
- func (m *SendMessageRequest) Reset()
- func (m *SendMessageRequest) String() string
- func (m *SendMessageRequest) XXX_DiscardUnknown()
- func (m *SendMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SendMessageRequest) XXX_Merge(src proto.Message)
- func (m *SendMessageRequest) XXX_Size() int
- func (m *SendMessageRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedUserServiceServer
- func (*UnimplementedUserServiceServer) AddMemberToConversation(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
- func (*UnimplementedUserServiceServer) CreateConnection(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
- func (*UnimplementedUserServiceServer) FetchMessages(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
- func (*UnimplementedUserServiceServer) JoinConversation(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
- func (*UnimplementedUserServiceServer) ReportChannelsMessages(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
- func (*UnimplementedUserServiceServer) SendMessage(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
- type UserServiceClient
- type UserServiceServer
Constants ¶
This section is empty.
Variables ¶
View Source
var RequestMetaSortsDirection_name = map[int32]string{
0: "Descending",
1: "Ascending",
}
View Source
var RequestMetaSortsDirection_value = map[string]int32{
"Descending": 0,
"Ascending": 1,
}
Functions ¶
func RegisterUserServiceServer ¶
func RegisterUserServiceServer(s *grpc.Server, srv UserServiceServer)
Types ¶
type Any ¶
type Any struct { TypeUrl string `protobuf:"bytes,1,opt,name=type_url,json=typeUrl,proto3" json:"type_url"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Any) Descriptor ¶
func (*Any) GetTypeUrl ¶
func (*Any) ProtoMessage ¶
func (*Any) ProtoMessage()
func (*Any) XXX_DiscardUnknown ¶
func (m *Any) XXX_DiscardUnknown()
func (*Any) XXX_Unmarshal ¶
type CreateConnectionRequest ¶
type CreateConnectionRequest struct { // create connection with one of thus connection infos Connection *CreateConnectionRequest_ConnectionInfo `protobuf:"bytes,1,opt,name=Connection,proto3" json:"Connection"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
========== Add data which have to be transferred between services create connection request and response
func (*CreateConnectionRequest) Descriptor ¶
func (*CreateConnectionRequest) Descriptor() ([]byte, []int)
func (*CreateConnectionRequest) GetConnection ¶
func (m *CreateConnectionRequest) GetConnection() *CreateConnectionRequest_ConnectionInfo
func (*CreateConnectionRequest) ProtoMessage ¶
func (*CreateConnectionRequest) ProtoMessage()
func (*CreateConnectionRequest) Reset ¶
func (m *CreateConnectionRequest) Reset()
func (*CreateConnectionRequest) String ¶
func (m *CreateConnectionRequest) String() string
func (*CreateConnectionRequest) XXX_DiscardUnknown ¶
func (m *CreateConnectionRequest) XXX_DiscardUnknown()
func (*CreateConnectionRequest) XXX_Marshal ¶
func (m *CreateConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateConnectionRequest) XXX_Merge ¶
func (m *CreateConnectionRequest) XXX_Merge(src proto.Message)
func (*CreateConnectionRequest) XXX_Size ¶
func (m *CreateConnectionRequest) XXX_Size() int
func (*CreateConnectionRequest) XXX_Unmarshal ¶
func (m *CreateConnectionRequest) XXX_Unmarshal(b []byte) error
type CreateConnectionRequest_ConnectionInfo ¶
type CreateConnectionRequest_ConnectionInfo struct { UID string `protobuf:"bytes,1,opt,name=UID,proto3" json:"UID"` PhoneNumber string `protobuf:"bytes,2,opt,name=PhoneNumber,proto3" json:"PhoneNumber"` Email string `protobuf:"bytes,3,opt,name=Email,proto3" json:"Email"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateConnectionRequest_ConnectionInfo) Descriptor ¶
func (*CreateConnectionRequest_ConnectionInfo) Descriptor() ([]byte, []int)
func (*CreateConnectionRequest_ConnectionInfo) GetEmail ¶
func (m *CreateConnectionRequest_ConnectionInfo) GetEmail() string
func (*CreateConnectionRequest_ConnectionInfo) GetPhoneNumber ¶
func (m *CreateConnectionRequest_ConnectionInfo) GetPhoneNumber() string
func (*CreateConnectionRequest_ConnectionInfo) GetUID ¶
func (m *CreateConnectionRequest_ConnectionInfo) GetUID() string
func (*CreateConnectionRequest_ConnectionInfo) ProtoMessage ¶
func (*CreateConnectionRequest_ConnectionInfo) ProtoMessage()
func (*CreateConnectionRequest_ConnectionInfo) Reset ¶
func (m *CreateConnectionRequest_ConnectionInfo) Reset()
func (*CreateConnectionRequest_ConnectionInfo) String ¶
func (m *CreateConnectionRequest_ConnectionInfo) String() string
func (*CreateConnectionRequest_ConnectionInfo) XXX_DiscardUnknown ¶
func (m *CreateConnectionRequest_ConnectionInfo) XXX_DiscardUnknown()
func (*CreateConnectionRequest_ConnectionInfo) XXX_Marshal ¶
func (m *CreateConnectionRequest_ConnectionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateConnectionRequest_ConnectionInfo) XXX_Merge ¶
func (m *CreateConnectionRequest_ConnectionInfo) XXX_Merge(src proto.Message)
func (*CreateConnectionRequest_ConnectionInfo) XXX_Size ¶
func (m *CreateConnectionRequest_ConnectionInfo) XXX_Size() int
func (*CreateConnectionRequest_ConnectionInfo) XXX_Unmarshal ¶
func (m *CreateConnectionRequest_ConnectionInfo) XXX_Unmarshal(b []byte) error
type Empty ¶
type Empty struct { Empty string `protobuf:"bytes,1,opt,name=empty,proto3" json:"empty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type FetchMessagesRequest ¶
type FetchMessagesRequest struct { ChannelId string `protobuf:"bytes,1,opt,name=ChannelId,proto3" json:"ChannelId"` Page uint64 `protobuf:"varint,2,opt,name=Page,proto3" json:"Page"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
fetch messages request and response
func (*FetchMessagesRequest) Descriptor ¶
func (*FetchMessagesRequest) Descriptor() ([]byte, []int)
func (*FetchMessagesRequest) GetChannelId ¶
func (m *FetchMessagesRequest) GetChannelId() string
func (*FetchMessagesRequest) GetPage ¶
func (m *FetchMessagesRequest) GetPage() uint64
func (*FetchMessagesRequest) ProtoMessage ¶
func (*FetchMessagesRequest) ProtoMessage()
func (*FetchMessagesRequest) Reset ¶
func (m *FetchMessagesRequest) Reset()
func (*FetchMessagesRequest) String ¶
func (m *FetchMessagesRequest) String() string
func (*FetchMessagesRequest) XXX_DiscardUnknown ¶
func (m *FetchMessagesRequest) XXX_DiscardUnknown()
func (*FetchMessagesRequest) XXX_Marshal ¶
func (m *FetchMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchMessagesRequest) XXX_Merge ¶
func (m *FetchMessagesRequest) XXX_Merge(src proto.Message)
func (*FetchMessagesRequest) XXX_Size ¶
func (m *FetchMessagesRequest) XXX_Size() int
func (*FetchMessagesRequest) XXX_Unmarshal ¶
func (m *FetchMessagesRequest) XXX_Unmarshal(b []byte) error
type FetchMessagesResponse ¶
type FetchMessagesResponse struct { Messages []*FetchMessagesResponse_Message `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FetchMessagesResponse) Descriptor ¶
func (*FetchMessagesResponse) Descriptor() ([]byte, []int)
func (*FetchMessagesResponse) GetMessages ¶
func (m *FetchMessagesResponse) GetMessages() []*FetchMessagesResponse_Message
func (*FetchMessagesResponse) ProtoMessage ¶
func (*FetchMessagesResponse) ProtoMessage()
func (*FetchMessagesResponse) Reset ¶
func (m *FetchMessagesResponse) Reset()
func (*FetchMessagesResponse) String ¶
func (m *FetchMessagesResponse) String() string
func (*FetchMessagesResponse) XXX_DiscardUnknown ¶
func (m *FetchMessagesResponse) XXX_DiscardUnknown()
func (*FetchMessagesResponse) XXX_Marshal ¶
func (m *FetchMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchMessagesResponse) XXX_Merge ¶
func (m *FetchMessagesResponse) XXX_Merge(src proto.Message)
func (*FetchMessagesResponse) XXX_Size ¶
func (m *FetchMessagesResponse) XXX_Size() int
func (*FetchMessagesResponse) XXX_Unmarshal ¶
func (m *FetchMessagesResponse) XXX_Unmarshal(b []byte) error
type FetchMessagesResponse_Message ¶
type FetchMessagesResponse_Message struct { ChannelId string `protobuf:"bytes,1,opt,name=ChannelId,proto3" json:"ChannelId"` CreatedAt string `protobuf:"bytes,2,opt,name=CreatedAt,proto3" json:"CreatedAt"` UpdatedAt string `protobuf:"bytes,3,opt,name=UpdatedAt,proto3" json:"UpdatedAt"` ChannelIndex string `protobuf:"bytes,4,opt,name=ChannelIndex,proto3" json:"ChannelIndex"` MessageReference string `protobuf:"bytes,5,opt,name=MessageReference,proto3" json:"MessageReference"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FetchMessagesResponse_Message) Descriptor ¶
func (*FetchMessagesResponse_Message) Descriptor() ([]byte, []int)
func (*FetchMessagesResponse_Message) GetChannelId ¶
func (m *FetchMessagesResponse_Message) GetChannelId() string
func (*FetchMessagesResponse_Message) GetChannelIndex ¶
func (m *FetchMessagesResponse_Message) GetChannelIndex() string
func (*FetchMessagesResponse_Message) GetCreatedAt ¶
func (m *FetchMessagesResponse_Message) GetCreatedAt() string
func (*FetchMessagesResponse_Message) GetMessageReference ¶
func (m *FetchMessagesResponse_Message) GetMessageReference() string
func (*FetchMessagesResponse_Message) GetUpdatedAt ¶
func (m *FetchMessagesResponse_Message) GetUpdatedAt() string
func (*FetchMessagesResponse_Message) ProtoMessage ¶
func (*FetchMessagesResponse_Message) ProtoMessage()
func (*FetchMessagesResponse_Message) Reset ¶
func (m *FetchMessagesResponse_Message) Reset()
func (*FetchMessagesResponse_Message) String ¶
func (m *FetchMessagesResponse_Message) String() string
func (*FetchMessagesResponse_Message) XXX_DiscardUnknown ¶
func (m *FetchMessagesResponse_Message) XXX_DiscardUnknown()
func (*FetchMessagesResponse_Message) XXX_Marshal ¶
func (m *FetchMessagesResponse_Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchMessagesResponse_Message) XXX_Merge ¶
func (m *FetchMessagesResponse_Message) XXX_Merge(src proto.Message)
func (*FetchMessagesResponse_Message) XXX_Size ¶
func (m *FetchMessagesResponse_Message) XXX_Size() int
func (*FetchMessagesResponse_Message) XXX_Unmarshal ¶
func (m *FetchMessagesResponse_Message) XXX_Unmarshal(b []byte) error
type ReportChannelsResponse ¶
type ReportChannelsResponse struct { Channels []*ReportChannelsResponse_ChannelItem `protobuf:"bytes,1,rep,name=Channels,proto3" json:"Channels"` PerPageMessage uint64 `protobuf:"varint,2,opt,name=PerPageMessage,proto3" json:"PerPageMessage"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
report channels messages request and response
func (*ReportChannelsResponse) Descriptor ¶
func (*ReportChannelsResponse) Descriptor() ([]byte, []int)
func (*ReportChannelsResponse) GetChannels ¶
func (m *ReportChannelsResponse) GetChannels() []*ReportChannelsResponse_ChannelItem
func (*ReportChannelsResponse) GetPerPageMessage ¶
func (m *ReportChannelsResponse) GetPerPageMessage() uint64
func (*ReportChannelsResponse) ProtoMessage ¶
func (*ReportChannelsResponse) ProtoMessage()
func (*ReportChannelsResponse) Reset ¶
func (m *ReportChannelsResponse) Reset()
func (*ReportChannelsResponse) String ¶
func (m *ReportChannelsResponse) String() string
func (*ReportChannelsResponse) XXX_DiscardUnknown ¶
func (m *ReportChannelsResponse) XXX_DiscardUnknown()
func (*ReportChannelsResponse) XXX_Marshal ¶
func (m *ReportChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportChannelsResponse) XXX_Merge ¶
func (m *ReportChannelsResponse) XXX_Merge(src proto.Message)
func (*ReportChannelsResponse) XXX_Size ¶
func (m *ReportChannelsResponse) XXX_Size() int
func (*ReportChannelsResponse) XXX_Unmarshal ¶
func (m *ReportChannelsResponse) XXX_Unmarshal(b []byte) error
type ReportChannelsResponse_ChannelItem ¶
type ReportChannelsResponse_ChannelItem struct { ChannelId string `protobuf:"bytes,1,opt,name=ChannelId,proto3" json:"ChannelId"` ChannelType string `protobuf:"bytes,2,opt,name=ChannelType,proto3" json:"ChannelType"` ChannelName string `protobuf:"bytes,3,opt,name=ChannelName,proto3" json:"ChannelName"` YourOffset uint64 `protobuf:"varint,4,opt,name=YourOffset,proto3" json:"YourOffset"` ChannelOffset uint64 `protobuf:"varint,5,opt,name=ChannelOffset,proto3" json:"ChannelOffset"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReportChannelsResponse_ChannelItem) Descriptor ¶
func (*ReportChannelsResponse_ChannelItem) Descriptor() ([]byte, []int)
func (*ReportChannelsResponse_ChannelItem) GetChannelId ¶
func (m *ReportChannelsResponse_ChannelItem) GetChannelId() string
func (*ReportChannelsResponse_ChannelItem) GetChannelName ¶
func (m *ReportChannelsResponse_ChannelItem) GetChannelName() string
func (*ReportChannelsResponse_ChannelItem) GetChannelOffset ¶
func (m *ReportChannelsResponse_ChannelItem) GetChannelOffset() uint64
func (*ReportChannelsResponse_ChannelItem) GetChannelType ¶
func (m *ReportChannelsResponse_ChannelItem) GetChannelType() string
func (*ReportChannelsResponse_ChannelItem) GetYourOffset ¶
func (m *ReportChannelsResponse_ChannelItem) GetYourOffset() uint64
func (*ReportChannelsResponse_ChannelItem) ProtoMessage ¶
func (*ReportChannelsResponse_ChannelItem) ProtoMessage()
func (*ReportChannelsResponse_ChannelItem) Reset ¶
func (m *ReportChannelsResponse_ChannelItem) Reset()
func (*ReportChannelsResponse_ChannelItem) String ¶
func (m *ReportChannelsResponse_ChannelItem) String() string
func (*ReportChannelsResponse_ChannelItem) XXX_DiscardUnknown ¶
func (m *ReportChannelsResponse_ChannelItem) XXX_DiscardUnknown()
func (*ReportChannelsResponse_ChannelItem) XXX_Marshal ¶
func (m *ReportChannelsResponse_ChannelItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportChannelsResponse_ChannelItem) XXX_Merge ¶
func (m *ReportChannelsResponse_ChannelItem) XXX_Merge(src proto.Message)
func (*ReportChannelsResponse_ChannelItem) XXX_Size ¶
func (m *ReportChannelsResponse_ChannelItem) XXX_Size() int
func (*ReportChannelsResponse_ChannelItem) XXX_Unmarshal ¶
func (m *ReportChannelsResponse_ChannelItem) XXX_Unmarshal(b []byte) error
type ReqMeta ¶
type ReqMeta struct { UTP string `protobuf:"bytes,1,opt,name=UTP,proto3" json:"UTP"` UID string `protobuf:"bytes,2,opt,name=UID,proto3" json:"UID"` FID string `protobuf:"bytes,3,opt,name=FID,proto3" json:"FID"` Page uint32 `protobuf:"varint,4,opt,name=page,proto3" json:"page"` PerPage uint32 `protobuf:"varint,5,opt,name=perPage,proto3" json:"perPage"` IpAddress string `protobuf:"bytes,6,opt,name=ipAddress,proto3" json:"ipAddress"` StartAt string `protobuf:"bytes,7,opt,name=startAt,proto3" json:"startAt"` EndAt string `protobuf:"bytes,8,opt,name=endAt,proto3" json:"endAt"` Sorts *RequestMetaSorts `protobuf:"bytes,9,opt,name=sorts,proto3" json:"sorts"` Filters *RequestMetaFilter `protobuf:"bytes,10,opt,name=filters,proto3" json:"filters"` Action *RequestMetaAction `protobuf:"bytes,11,opt,name=action,proto3" json:"action"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
==================== Meta
func (*ReqMeta) Descriptor ¶
func (*ReqMeta) GetAction ¶
func (m *ReqMeta) GetAction() *RequestMetaAction
func (*ReqMeta) GetFilters ¶
func (m *ReqMeta) GetFilters() *RequestMetaFilter
func (*ReqMeta) GetIpAddress ¶
func (*ReqMeta) GetPerPage ¶
func (*ReqMeta) GetSorts ¶
func (m *ReqMeta) GetSorts() *RequestMetaSorts
func (*ReqMeta) GetStartAt ¶
func (*ReqMeta) ProtoMessage ¶
func (*ReqMeta) ProtoMessage()
func (*ReqMeta) XXX_DiscardUnknown ¶
func (m *ReqMeta) XXX_DiscardUnknown()
func (*ReqMeta) XXX_Marshal ¶
func (*ReqMeta) XXX_Unmarshal ¶
type RequestMessage ¶
type RequestMessage struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name"` Type string `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type"` Time string `protobuf:"bytes,3,opt,name=time,proto3" json:"time"` Header *ReqMeta `protobuf:"bytes,4,opt,name=Header,proto3" json:"Header"` Body *Any `protobuf:"bytes,5,opt,name=Body,proto3" json:"Body"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
============ The request message
func (*RequestMessage) Descriptor ¶
func (*RequestMessage) Descriptor() ([]byte, []int)
func (*RequestMessage) GetBody ¶
func (m *RequestMessage) GetBody() *Any
func (*RequestMessage) GetHeader ¶
func (m *RequestMessage) GetHeader() *ReqMeta
func (*RequestMessage) GetName ¶
func (m *RequestMessage) GetName() string
func (*RequestMessage) GetTime ¶
func (m *RequestMessage) GetTime() string
func (*RequestMessage) GetType ¶
func (m *RequestMessage) GetType() string
func (*RequestMessage) ProtoMessage ¶
func (*RequestMessage) ProtoMessage()
func (*RequestMessage) Reset ¶
func (m *RequestMessage) Reset()
func (*RequestMessage) String ¶
func (m *RequestMessage) String() string
func (*RequestMessage) XXX_DiscardUnknown ¶
func (m *RequestMessage) XXX_DiscardUnknown()
func (*RequestMessage) XXX_Marshal ¶
func (m *RequestMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestMessage) XXX_Merge ¶
func (m *RequestMessage) XXX_Merge(src proto.Message)
func (*RequestMessage) XXX_Size ¶
func (m *RequestMessage) XXX_Size() int
func (*RequestMessage) XXX_Unmarshal ¶
func (m *RequestMessage) XXX_Unmarshal(b []byte) error
type RequestMetaAction ¶
type RequestMetaAction struct { ActionType string `protobuf:"bytes,1,opt,name=actionType,proto3" json:"actionType"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RequestMetaAction) Descriptor ¶
func (*RequestMetaAction) Descriptor() ([]byte, []int)
func (*RequestMetaAction) GetActionType ¶
func (m *RequestMetaAction) GetActionType() string
func (*RequestMetaAction) ProtoMessage ¶
func (*RequestMetaAction) ProtoMessage()
func (*RequestMetaAction) Reset ¶
func (m *RequestMetaAction) Reset()
func (*RequestMetaAction) String ¶
func (m *RequestMetaAction) String() string
func (*RequestMetaAction) XXX_DiscardUnknown ¶
func (m *RequestMetaAction) XXX_DiscardUnknown()
func (*RequestMetaAction) XXX_Marshal ¶
func (m *RequestMetaAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestMetaAction) XXX_Merge ¶
func (m *RequestMetaAction) XXX_Merge(src proto.Message)
func (*RequestMetaAction) XXX_Size ¶
func (m *RequestMetaAction) XXX_Size() int
func (*RequestMetaAction) XXX_Unmarshal ¶
func (m *RequestMetaAction) XXX_Unmarshal(b []byte) error
type RequestMetaFilter ¶
type RequestMetaFilter struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type"` Opt string `protobuf:"bytes,2,opt,name=opt,proto3" json:"opt"` Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RequestMetaFilter) Descriptor ¶
func (*RequestMetaFilter) Descriptor() ([]byte, []int)
func (*RequestMetaFilter) GetOpt ¶
func (m *RequestMetaFilter) GetOpt() string
func (*RequestMetaFilter) GetType ¶
func (m *RequestMetaFilter) GetType() string
func (*RequestMetaFilter) GetValue ¶
func (m *RequestMetaFilter) GetValue() string
func (*RequestMetaFilter) ProtoMessage ¶
func (*RequestMetaFilter) ProtoMessage()
func (*RequestMetaFilter) Reset ¶
func (m *RequestMetaFilter) Reset()
func (*RequestMetaFilter) String ¶
func (m *RequestMetaFilter) String() string
func (*RequestMetaFilter) XXX_DiscardUnknown ¶
func (m *RequestMetaFilter) XXX_DiscardUnknown()
func (*RequestMetaFilter) XXX_Marshal ¶
func (m *RequestMetaFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestMetaFilter) XXX_Merge ¶
func (m *RequestMetaFilter) XXX_Merge(src proto.Message)
func (*RequestMetaFilter) XXX_Size ¶
func (m *RequestMetaFilter) XXX_Size() int
func (*RequestMetaFilter) XXX_Unmarshal ¶
func (m *RequestMetaFilter) XXX_Unmarshal(b []byte) error
type RequestMetaSorts ¶
type RequestMetaSorts struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name"` Dir uint32 `protobuf:"varint,2,opt,name=dir,proto3" json:"dir"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RequestMetaSorts) Descriptor ¶
func (*RequestMetaSorts) Descriptor() ([]byte, []int)
func (*RequestMetaSorts) GetDir ¶
func (m *RequestMetaSorts) GetDir() uint32
func (*RequestMetaSorts) GetName ¶
func (m *RequestMetaSorts) GetName() string
func (*RequestMetaSorts) ProtoMessage ¶
func (*RequestMetaSorts) ProtoMessage()
func (*RequestMetaSorts) Reset ¶
func (m *RequestMetaSorts) Reset()
func (*RequestMetaSorts) String ¶
func (m *RequestMetaSorts) String() string
func (*RequestMetaSorts) XXX_DiscardUnknown ¶
func (m *RequestMetaSorts) XXX_DiscardUnknown()
func (*RequestMetaSorts) XXX_Marshal ¶
func (m *RequestMetaSorts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestMetaSorts) XXX_Merge ¶
func (m *RequestMetaSorts) XXX_Merge(src proto.Message)
func (*RequestMetaSorts) XXX_Size ¶
func (m *RequestMetaSorts) XXX_Size() int
func (*RequestMetaSorts) XXX_Unmarshal ¶
func (m *RequestMetaSorts) XXX_Unmarshal(b []byte) error
type RequestMetaSortsDirection ¶
type RequestMetaSortsDirection int32
const ( RequestMetaSorts_Descending RequestMetaSortsDirection = 0 RequestMetaSorts_Ascending RequestMetaSortsDirection = 1 )
func (RequestMetaSortsDirection) EnumDescriptor ¶
func (RequestMetaSortsDirection) EnumDescriptor() ([]byte, []int)
func (RequestMetaSortsDirection) String ¶
func (x RequestMetaSortsDirection) String() string
type ResponseMessage ¶
type ResponseMessage struct { Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity"` Meta *ResponseMetadata `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta"` Data *Any `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
============ The response message
func (*ResponseMessage) Descriptor ¶
func (*ResponseMessage) Descriptor() ([]byte, []int)
func (*ResponseMessage) GetData ¶
func (m *ResponseMessage) GetData() *Any
func (*ResponseMessage) GetEntity ¶
func (m *ResponseMessage) GetEntity() string
func (*ResponseMessage) GetMeta ¶
func (m *ResponseMessage) GetMeta() *ResponseMetadata
func (*ResponseMessage) ProtoMessage ¶
func (*ResponseMessage) ProtoMessage()
func (*ResponseMessage) Reset ¶
func (m *ResponseMessage) Reset()
func (*ResponseMessage) String ¶
func (m *ResponseMessage) String() string
func (*ResponseMessage) XXX_DiscardUnknown ¶
func (m *ResponseMessage) XXX_DiscardUnknown()
func (*ResponseMessage) XXX_Marshal ¶
func (m *ResponseMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseMessage) XXX_Merge ¶
func (m *ResponseMessage) XXX_Merge(src proto.Message)
func (*ResponseMessage) XXX_Size ¶
func (m *ResponseMessage) XXX_Size() int
func (*ResponseMessage) XXX_Unmarshal ¶
func (m *ResponseMessage) XXX_Unmarshal(b []byte) error
type ResponseMetadata ¶
type ResponseMetadata struct { Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total"` Page uint32 `protobuf:"varint,2,opt,name=page,proto3" json:"page"` PerPage uint32 `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ResponseMetadata) Descriptor ¶
func (*ResponseMetadata) Descriptor() ([]byte, []int)
func (*ResponseMetadata) GetPage ¶
func (m *ResponseMetadata) GetPage() uint32
func (*ResponseMetadata) GetPerPage ¶
func (m *ResponseMetadata) GetPerPage() uint32
func (*ResponseMetadata) GetTotal ¶
func (m *ResponseMetadata) GetTotal() uint32
func (*ResponseMetadata) ProtoMessage ¶
func (*ResponseMetadata) ProtoMessage()
func (*ResponseMetadata) Reset ¶
func (m *ResponseMetadata) Reset()
func (*ResponseMetadata) String ¶
func (m *ResponseMetadata) String() string
func (*ResponseMetadata) XXX_DiscardUnknown ¶
func (m *ResponseMetadata) XXX_DiscardUnknown()
func (*ResponseMetadata) XXX_Marshal ¶
func (m *ResponseMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseMetadata) XXX_Merge ¶
func (m *ResponseMetadata) XXX_Merge(src proto.Message)
func (*ResponseMetadata) XXX_Size ¶
func (m *ResponseMetadata) XXX_Size() int
func (*ResponseMetadata) XXX_Unmarshal ¶
func (m *ResponseMetadata) XXX_Unmarshal(b []byte) error
type SendMessageRequest ¶
type SendMessageRequest struct { ChannelId string `protobuf:"bytes,1,opt,name=ChannelId,proto3" json:"ChannelId"` CreatedAt string `protobuf:"bytes,2,opt,name=CreatedAt,proto3" json:"CreatedAt"` MessageReference string `protobuf:"bytes,3,opt,name=MessageReference,proto3" json:"MessageReference"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
send message request and response
func (*SendMessageRequest) Descriptor ¶
func (*SendMessageRequest) Descriptor() ([]byte, []int)
func (*SendMessageRequest) GetChannelId ¶
func (m *SendMessageRequest) GetChannelId() string
func (*SendMessageRequest) GetCreatedAt ¶
func (m *SendMessageRequest) GetCreatedAt() string
func (*SendMessageRequest) GetMessageReference ¶
func (m *SendMessageRequest) GetMessageReference() string
func (*SendMessageRequest) ProtoMessage ¶
func (*SendMessageRequest) ProtoMessage()
func (*SendMessageRequest) Reset ¶
func (m *SendMessageRequest) Reset()
func (*SendMessageRequest) String ¶
func (m *SendMessageRequest) String() string
func (*SendMessageRequest) XXX_DiscardUnknown ¶
func (m *SendMessageRequest) XXX_DiscardUnknown()
func (*SendMessageRequest) XXX_Marshal ¶
func (m *SendMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendMessageRequest) XXX_Merge ¶
func (m *SendMessageRequest) XXX_Merge(src proto.Message)
func (*SendMessageRequest) XXX_Size ¶
func (m *SendMessageRequest) XXX_Size() int
func (*SendMessageRequest) XXX_Unmarshal ¶
func (m *SendMessageRequest) XXX_Unmarshal(b []byte) error
type UnimplementedUserServiceServer ¶
type UnimplementedUserServiceServer struct { }
UnimplementedUserServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedUserServiceServer) AddMemberToConversation ¶
func (*UnimplementedUserServiceServer) AddMemberToConversation(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
func (*UnimplementedUserServiceServer) CreateConnection ¶
func (*UnimplementedUserServiceServer) CreateConnection(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
func (*UnimplementedUserServiceServer) FetchMessages ¶
func (*UnimplementedUserServiceServer) FetchMessages(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
func (*UnimplementedUserServiceServer) JoinConversation ¶
func (*UnimplementedUserServiceServer) JoinConversation(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
func (*UnimplementedUserServiceServer) ReportChannelsMessages ¶
func (*UnimplementedUserServiceServer) ReportChannelsMessages(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
func (*UnimplementedUserServiceServer) SendMessage ¶
func (*UnimplementedUserServiceServer) SendMessage(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)
type UserServiceClient ¶
type UserServiceClient interface { CreateConnection(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error) SendMessage(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error) ReportChannelsMessages(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error) FetchMessages(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error) JoinConversation(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error) AddMemberToConversation(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error) }
UserServiceClient is the client API for UserService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewUserServiceClient ¶
func NewUserServiceClient(cc grpc.ClientConnInterface) UserServiceClient
type UserServiceServer ¶
type UserServiceServer interface { CreateConnection(context.Context, *RequestMessage) (*ResponseMessage, error) SendMessage(context.Context, *RequestMessage) (*ResponseMessage, error) ReportChannelsMessages(context.Context, *RequestMessage) (*ResponseMessage, error) FetchMessages(context.Context, *RequestMessage) (*ResponseMessage, error) JoinConversation(context.Context, *RequestMessage) (*ResponseMessage, error) AddMemberToConversation(context.Context, *RequestMessage) (*ResponseMessage, error) }
UserServiceServer is the server API for UserService service.
Click to show internal directories.
Click to hide internal directories.