Documentation ¶
Index ¶
- Variables
- func DebugSequenceID(seq uint64) string
- func HelpForMessage(name string) string
- func HelpForMessageField(message, field string) string
- type AcceptGCInviteRequest
- func (*AcceptGCInviteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AcceptGCInviteRequest) GetInviteId() uint64
- func (*AcceptGCInviteRequest) ProtoMessage()
- func (x *AcceptGCInviteRequest) ProtoReflect() protoreflect.Message
- func (x *AcceptGCInviteRequest) Reset()
- func (x *AcceptGCInviteRequest) String() string
- type AcceptGCInviteResponse
- type AcceptInviteRequest
- func (*AcceptInviteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AcceptInviteRequest) GetInviteBytes() []byte
- func (*AcceptInviteRequest) ProtoMessage()
- func (x *AcceptInviteRequest) ProtoReflect() protoreflect.Message
- func (x *AcceptInviteRequest) Reset()
- func (x *AcceptInviteRequest) String() string
- type AcceptInviteResponse
- func (*AcceptInviteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AcceptInviteResponse) GetInvite() *OOBPublicIdentityInvite
- func (*AcceptInviteResponse) ProtoMessage()
- func (x *AcceptInviteResponse) ProtoReflect() protoreflect.Message
- func (x *AcceptInviteResponse) Reset()
- func (x *AcceptInviteResponse) String() string
- type AckRequest
- type AckResponse
- type ChatServiceClient
- type ChatServiceServer
- type ChatService_GCMStreamClient
- type ChatService_GCMStreamServer
- type ChatService_KXStreamClient
- type ChatService_KXStreamServer
- type ChatService_PMStreamClient
- type ChatService_PMStreamServer
- type ClientConn
- type ClientStream
- type GCMRequest
- type GCMResponse
- type GCMStreamRequest
- type GCMembersAddedEvent
- func (*GCMembersAddedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *GCMembersAddedEvent) GetGc() []byte
- func (x *GCMembersAddedEvent) GetGcName() string
- func (x *GCMembersAddedEvent) GetSequenceId() uint64
- func (x *GCMembersAddedEvent) GetUsers() []*UserAndNick
- func (*GCMembersAddedEvent) ProtoMessage()
- func (x *GCMembersAddedEvent) ProtoReflect() protoreflect.Message
- func (x *GCMembersAddedEvent) Reset()
- func (x *GCMembersAddedEvent) String() string
- type GCMembersAddedRequest
- func (*GCMembersAddedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GCMembersAddedRequest) GetUnackedFrom() uint64
- func (*GCMembersAddedRequest) ProtoMessage()
- func (x *GCMembersAddedRequest) ProtoReflect() protoreflect.Message
- func (x *GCMembersAddedRequest) Reset()
- func (x *GCMembersAddedRequest) String() string
- type GCMembersRemovedEvent
- func (*GCMembersRemovedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *GCMembersRemovedEvent) GetGc() []byte
- func (x *GCMembersRemovedEvent) GetGcName() string
- func (x *GCMembersRemovedEvent) GetSequenceId() uint64
- func (x *GCMembersRemovedEvent) GetUsers() []*UserAndNick
- func (*GCMembersRemovedEvent) ProtoMessage()
- func (x *GCMembersRemovedEvent) ProtoReflect() protoreflect.Message
- func (x *GCMembersRemovedEvent) Reset()
- func (x *GCMembersRemovedEvent) String() string
- type GCMembersRemovedRequest
- func (*GCMembersRemovedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GCMembersRemovedRequest) GetUnackedFrom() uint64
- func (*GCMembersRemovedRequest) ProtoMessage()
- func (x *GCMembersRemovedRequest) ProtoReflect() protoreflect.Message
- func (x *GCMembersRemovedRequest) Reset()
- func (x *GCMembersRemovedRequest) String() string
- type GCReceivedMsg
- func (*GCReceivedMsg) Descriptor() ([]byte, []int)deprecated
- func (x *GCReceivedMsg) GetGcAlias() string
- func (x *GCReceivedMsg) GetMsg() *RMGroupMessage
- func (x *GCReceivedMsg) GetNick() string
- func (x *GCReceivedMsg) GetSequenceId() uint64
- func (x *GCReceivedMsg) GetTimestampMs() int64
- func (x *GCReceivedMsg) GetUid() []byte
- func (*GCReceivedMsg) ProtoMessage()
- func (x *GCReceivedMsg) ProtoReflect() protoreflect.Message
- func (x *GCReceivedMsg) Reset()
- func (x *GCReceivedMsg) String() string
- type GCServiceClient
- type GCServiceServer
- type GCService_JoinedGCsClient
- type GCService_JoinedGCsServer
- type GCService_MembersAddedClient
- type GCService_MembersAddedServer
- type GCService_MembersRemovedClient
- type GCService_MembersRemovedServer
- type GCService_ReceivedGCInvitesClient
- type GCService_ReceivedGCInvitesServer
- type GetGCRequest
- type GetGCResponse
- type InviteToGCRequest
- func (*InviteToGCRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InviteToGCRequest) GetGc() string
- func (x *InviteToGCRequest) GetUser() string
- func (*InviteToGCRequest) ProtoMessage()
- func (x *InviteToGCRequest) ProtoReflect() protoreflect.Message
- func (x *InviteToGCRequest) Reset()
- func (x *InviteToGCRequest) String() string
- type InviteToGCResponse
- type JoinedGCEvent
- func (*JoinedGCEvent) Descriptor() ([]byte, []int)deprecated
- func (x *JoinedGCEvent) GetGc() *RMGroupList
- func (x *JoinedGCEvent) GetSequenceId() uint64
- func (*JoinedGCEvent) ProtoMessage()
- func (x *JoinedGCEvent) ProtoReflect() protoreflect.Message
- func (x *JoinedGCEvent) Reset()
- func (x *JoinedGCEvent) String() string
- type JoinedGCsRequest
- type KXCompleted
- func (*KXCompleted) Descriptor() ([]byte, []int)deprecated
- func (x *KXCompleted) GetNick() string
- func (x *KXCompleted) GetSequenceId() uint64
- func (x *KXCompleted) GetUid() []byte
- func (*KXCompleted) ProtoMessage()
- func (x *KXCompleted) ProtoReflect() protoreflect.Message
- func (x *KXCompleted) Reset()
- func (x *KXCompleted) String() string
- type KXStreamRequest
- type KeepaliveEvent
- type KeepaliveStreamRequest
- func (*KeepaliveStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeepaliveStreamRequest) GetInterval() int64
- func (*KeepaliveStreamRequest) ProtoMessage()
- func (x *KeepaliveStreamRequest) ProtoReflect() protoreflect.Message
- func (x *KeepaliveStreamRequest) Reset()
- func (x *KeepaliveStreamRequest) String() string
- type KickFromGCRequest
- func (*KickFromGCRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KickFromGCRequest) GetGc() string
- func (x *KickFromGCRequest) GetReason() string
- func (x *KickFromGCRequest) GetUser() string
- func (*KickFromGCRequest) ProtoMessage()
- func (x *KickFromGCRequest) ProtoReflect() protoreflect.Message
- func (x *KickFromGCRequest) Reset()
- func (x *KickFromGCRequest) String() string
- type KickFromGCResponse
- type ListGCsRequest
- type ListGCsResponse
- func (*ListGCsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListGCsResponse) GetGcs() []*ListGCsResponse_GCInfo
- func (*ListGCsResponse) ProtoMessage()
- func (x *ListGCsResponse) ProtoReflect() protoreflect.Message
- func (x *ListGCsResponse) Reset()
- func (x *ListGCsResponse) String() string
- type ListGCsResponse_GCInfo
- func (*ListGCsResponse_GCInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ListGCsResponse_GCInfo) GetId() []byte
- func (x *ListGCsResponse_GCInfo) GetName() string
- func (x *ListGCsResponse_GCInfo) GetNbMembers() uint32
- func (x *ListGCsResponse_GCInfo) GetTimestamp() int64
- func (x *ListGCsResponse_GCInfo) GetVersion() uint32
- func (*ListGCsResponse_GCInfo) ProtoMessage()
- func (x *ListGCsResponse_GCInfo) ProtoReflect() protoreflect.Message
- func (x *ListGCsResponse_GCInfo) Reset()
- func (x *ListGCsResponse_GCInfo) String() string
- type MediateKXRequest
- func (*MediateKXRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MediateKXRequest) GetMediator() string
- func (x *MediateKXRequest) GetTarget() string
- func (*MediateKXRequest) ProtoMessage()
- func (x *MediateKXRequest) ProtoReflect() protoreflect.Message
- func (x *MediateKXRequest) Reset()
- func (x *MediateKXRequest) String() string
- type MediateKXResponse
- type MessageMode
- func (MessageMode) Descriptor() protoreflect.EnumDescriptor
- func (x MessageMode) Enum() *MessageMode
- func (MessageMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x MessageMode) Number() protoreflect.EnumNumber
- func (x MessageMode) String() string
- func (MessageMode) Type() protoreflect.EnumType
- type MethodDefn
- type OOBPublicIdentityInvite
- func (*OOBPublicIdentityInvite) Descriptor() ([]byte, []int)deprecated
- func (x *OOBPublicIdentityInvite) GetInitialRendezvous() []byte
- func (x *OOBPublicIdentityInvite) GetPublic() *PublicIdentity
- func (x *OOBPublicIdentityInvite) GetResetRendezvous() []byte
- func (*OOBPublicIdentityInvite) ProtoMessage()
- func (x *OOBPublicIdentityInvite) ProtoReflect() protoreflect.Message
- func (x *OOBPublicIdentityInvite) Reset()
- func (x *OOBPublicIdentityInvite) String() string
- type PMRequest
- type PMResponse
- type PMStreamRequest
- type PaymentsServiceClient
- type PaymentsServiceServer
- type PostMetadata
- func (*PostMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *PostMetadata) GetAttributes() map[string]string
- func (x *PostMetadata) GetVersion() uint64
- func (*PostMetadata) ProtoMessage()
- func (x *PostMetadata) ProtoReflect() protoreflect.Message
- func (x *PostMetadata) Reset()
- func (x *PostMetadata) String() string
- type PostMetadataStatus
- func (*PostMetadataStatus) Descriptor() ([]byte, []int)deprecated
- func (x *PostMetadataStatus) GetAttributes() map[string]string
- func (x *PostMetadataStatus) GetFrom() string
- func (x *PostMetadataStatus) GetLink() string
- func (x *PostMetadataStatus) GetVersion() uint64
- func (*PostMetadataStatus) ProtoMessage()
- func (x *PostMetadataStatus) ProtoReflect() protoreflect.Message
- func (x *PostMetadataStatus) Reset()
- func (x *PostMetadataStatus) String() string
- type PostSummary
- func (*PostSummary) Descriptor() ([]byte, []int)deprecated
- func (x *PostSummary) GetAuthorId() []byte
- func (x *PostSummary) GetAuthorNick() string
- func (x *PostSummary) GetDate() int64
- func (x *PostSummary) GetFrom() []byte
- func (x *PostSummary) GetId() []byte
- func (x *PostSummary) GetLastStatusTs() int64
- func (x *PostSummary) GetTitle() string
- func (*PostSummary) ProtoMessage()
- func (x *PostSummary) ProtoReflect() protoreflect.Message
- func (x *PostSummary) Reset()
- func (x *PostSummary) String() string
- type PostsServiceClient
- type PostsServiceServer
- type PostsService_PostsStatusStreamClient
- type PostsService_PostsStatusStreamServer
- type PostsService_PostsStreamClient
- type PostsService_PostsStreamServer
- type PostsStatusStreamRequest
- func (*PostsStatusStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PostsStatusStreamRequest) GetUnackedFrom() uint64
- func (*PostsStatusStreamRequest) ProtoMessage()
- func (x *PostsStatusStreamRequest) ProtoReflect() protoreflect.Message
- func (x *PostsStatusStreamRequest) Reset()
- func (x *PostsStatusStreamRequest) String() string
- type PostsStreamRequest
- func (*PostsStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PostsStreamRequest) GetUnackedFrom() uint64
- func (*PostsStreamRequest) ProtoMessage()
- func (x *PostsStreamRequest) ProtoReflect() protoreflect.Message
- func (x *PostsStreamRequest) Reset()
- func (x *PostsStreamRequest) String() string
- type PublicIdentity
- func (*PublicIdentity) Descriptor() ([]byte, []int)deprecated
- func (x *PublicIdentity) GetDigest() []byte
- func (x *PublicIdentity) GetIdentity() []byte
- func (x *PublicIdentity) GetKey() []byte
- func (x *PublicIdentity) GetName() string
- func (x *PublicIdentity) GetNick() string
- func (x *PublicIdentity) GetSigKey() []byte
- func (x *PublicIdentity) GetSignature() []byte
- func (*PublicIdentity) ProtoMessage()
- func (x *PublicIdentity) ProtoReflect() protoreflect.Message
- func (x *PublicIdentity) Reset()
- func (x *PublicIdentity) String() string
- type RMGroupInvite
- func (*RMGroupInvite) Descriptor() ([]byte, []int)deprecated
- func (x *RMGroupInvite) GetDescription() string
- func (x *RMGroupInvite) GetExpires() int64
- func (x *RMGroupInvite) GetId() []byte
- func (x *RMGroupInvite) GetName() string
- func (x *RMGroupInvite) GetToken() uint64
- func (x *RMGroupInvite) GetVersion() uint32
- func (*RMGroupInvite) ProtoMessage()
- func (x *RMGroupInvite) ProtoReflect() protoreflect.Message
- func (x *RMGroupInvite) Reset()
- func (x *RMGroupInvite) String() string
- type RMGroupList
- func (*RMGroupList) Descriptor() ([]byte, []int)deprecated
- func (x *RMGroupList) GetExtraAdmins() [][]byte
- func (x *RMGroupList) GetGeneration() uint64
- func (x *RMGroupList) GetId() []byte
- func (x *RMGroupList) GetMembers() [][]byte
- func (x *RMGroupList) GetName() string
- func (x *RMGroupList) GetTimestamp() int64
- func (x *RMGroupList) GetVersion() uint32
- func (*RMGroupList) ProtoMessage()
- func (x *RMGroupList) ProtoReflect() protoreflect.Message
- func (x *RMGroupList) Reset()
- func (x *RMGroupList) String() string
- type RMGroupMessage
- func (*RMGroupMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RMGroupMessage) GetGeneration() uint64
- func (x *RMGroupMessage) GetId() []byte
- func (x *RMGroupMessage) GetMessage() string
- func (x *RMGroupMessage) GetMode() MessageMode
- func (*RMGroupMessage) ProtoMessage()
- func (x *RMGroupMessage) ProtoReflect() protoreflect.Message
- func (x *RMGroupMessage) Reset()
- func (x *RMGroupMessage) String() string
- type RMPrivateMessage
- func (*RMPrivateMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RMPrivateMessage) GetMessage() string
- func (x *RMPrivateMessage) GetMode() MessageMode
- func (*RMPrivateMessage) ProtoMessage()
- func (x *RMPrivateMessage) ProtoReflect() protoreflect.Message
- func (x *RMPrivateMessage) Reset()
- func (x *RMPrivateMessage) String() string
- type ReceivedGCInvite
- func (*ReceivedGCInvite) Descriptor() ([]byte, []int)deprecated
- func (x *ReceivedGCInvite) GetInvite() *RMGroupInvite
- func (x *ReceivedGCInvite) GetInviteId() uint64
- func (x *ReceivedGCInvite) GetInviterNick() string
- func (x *ReceivedGCInvite) GetInviterUid() []byte
- func (x *ReceivedGCInvite) GetSequenceId() uint64
- func (*ReceivedGCInvite) ProtoMessage()
- func (x *ReceivedGCInvite) ProtoReflect() protoreflect.Message
- func (x *ReceivedGCInvite) Reset()
- func (x *ReceivedGCInvite) String() string
- type ReceivedGCInvitesRequest
- func (*ReceivedGCInvitesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReceivedGCInvitesRequest) GetUnackedFrom() uint64
- func (*ReceivedGCInvitesRequest) ProtoMessage()
- func (x *ReceivedGCInvitesRequest) ProtoReflect() protoreflect.Message
- func (x *ReceivedGCInvitesRequest) Reset()
- func (x *ReceivedGCInvitesRequest) String() string
- type ReceivedPM
- func (*ReceivedPM) Descriptor() ([]byte, []int)deprecated
- func (x *ReceivedPM) GetMsg() *RMPrivateMessage
- func (x *ReceivedPM) GetNick() string
- func (x *ReceivedPM) GetSequenceId() uint64
- func (x *ReceivedPM) GetTimestampMs() int64
- func (x *ReceivedPM) GetUid() []byte
- func (*ReceivedPM) ProtoMessage()
- func (x *ReceivedPM) ProtoReflect() protoreflect.Message
- func (x *ReceivedPM) Reset()
- func (x *ReceivedPM) String() string
- type ReceivedPost
- func (*ReceivedPost) Descriptor() ([]byte, []int)deprecated
- func (x *ReceivedPost) GetPost() *PostMetadata
- func (x *ReceivedPost) GetRelayerId() []byte
- func (x *ReceivedPost) GetSequenceId() uint64
- func (x *ReceivedPost) GetSummary() *PostSummary
- func (*ReceivedPost) ProtoMessage()
- func (x *ReceivedPost) ProtoReflect() protoreflect.Message
- func (x *ReceivedPost) Reset()
- func (x *ReceivedPost) String() string
- type ReceivedPostStatus
- func (*ReceivedPostStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ReceivedPostStatus) GetPostId() []byte
- func (x *ReceivedPostStatus) GetRelayerId() []byte
- func (x *ReceivedPostStatus) GetSequenceId() uint64
- func (x *ReceivedPostStatus) GetStatus() *PostMetadataStatus
- func (x *ReceivedPostStatus) GetStatusFrom() []byte
- func (x *ReceivedPostStatus) GetStatusFromNick() string
- func (*ReceivedPostStatus) ProtoMessage()
- func (x *ReceivedPostStatus) ProtoReflect() protoreflect.Message
- func (x *ReceivedPostStatus) Reset()
- func (x *ReceivedPostStatus) String() string
- type SendFileRequest
- func (*SendFileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendFileRequest) GetFilename() string
- func (x *SendFileRequest) GetUser() string
- func (*SendFileRequest) ProtoMessage()
- func (x *SendFileRequest) ProtoReflect() protoreflect.Message
- func (x *SendFileRequest) Reset()
- func (x *SendFileRequest) String() string
- type SendFileResponse
- type ServerStream
- type ServersMap
- type ServiceDefn
- type SubscribeToPostsRequest
- func (*SubscribeToPostsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeToPostsRequest) GetUser() string
- func (*SubscribeToPostsRequest) ProtoMessage()
- func (x *SubscribeToPostsRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeToPostsRequest) Reset()
- func (x *SubscribeToPostsRequest) String() string
- type SubscribeToPostsResponse
- type TipUserRequest
- func (*TipUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TipUserRequest) GetDcrAmount() float64
- func (x *TipUserRequest) GetUser() string
- func (*TipUserRequest) ProtoMessage()
- func (x *TipUserRequest) ProtoReflect() protoreflect.Message
- func (x *TipUserRequest) Reset()
- func (x *TipUserRequest) String() string
- type TipUserResponse
- type UnsubscribeToPostsRequest
- func (*UnsubscribeToPostsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnsubscribeToPostsRequest) GetUser() string
- func (*UnsubscribeToPostsRequest) ProtoMessage()
- func (x *UnsubscribeToPostsRequest) ProtoReflect() protoreflect.Message
- func (x *UnsubscribeToPostsRequest) Reset()
- func (x *UnsubscribeToPostsRequest) String() string
- type UnsubscribeToPostsResponse
- type UserAndNick
- func (*UserAndNick) Descriptor() ([]byte, []int)deprecated
- func (x *UserAndNick) GetKnown() bool
- func (x *UserAndNick) GetNick() string
- func (x *UserAndNick) GetUid() []byte
- func (*UserAndNick) ProtoMessage()
- func (x *UserAndNick) ProtoReflect() protoreflect.Message
- func (x *UserAndNick) Reset()
- func (x *UserAndNick) String() string
- type VersionRequest
- type VersionResponse
- func (*VersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *VersionResponse) GetAppName() string
- func (x *VersionResponse) GetAppVersion() string
- func (x *VersionResponse) GetGoRuntime() string
- func (*VersionResponse) ProtoMessage()
- func (x *VersionResponse) ProtoReflect() protoreflect.Message
- func (x *VersionResponse) Reset()
- func (x *VersionResponse) String() string
- type VersionServiceClient
- type VersionServiceServer
- type VersionService_KeepaliveStreamClient
- type VersionService_KeepaliveStreamServer
- type WriteNewInviteRequest
- type WriteNewInviteResponse
- func (*WriteNewInviteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WriteNewInviteResponse) GetInvite() *OOBPublicIdentityInvite
- func (x *WriteNewInviteResponse) GetInviteBytes() []byte
- func (*WriteNewInviteResponse) ProtoMessage()
- func (x *WriteNewInviteResponse) ProtoReflect() protoreflect.Message
- func (x *WriteNewInviteResponse) Reset()
- func (x *WriteNewInviteResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( MessageMode_name = map[int32]string{ 0: "MESSAGE_MODE_NORMAL", 1: "MESSAGE_MODE_ME", } MessageMode_value = map[string]int32{ "MESSAGE_MODE_NORMAL": 0, "MESSAGE_MODE_ME": 1, } )
Enum value maps for MessageMode.
var File_clientrpc_proto protoreflect.FileDescriptor
Functions ¶
func DebugSequenceID ¶
DebugSequenceID returns a debug string for a given sequence ID.
func HelpForMessage ¶
HelpForMessage returns the top-level help defined for the given proto message.
func HelpForMessageField ¶
HelpForMessageField returns the help message defined for the specified message field.
Types ¶
type AcceptGCInviteRequest ¶ added in v0.1.6
type AcceptGCInviteRequest struct { // invite_id is the id to use to join the invite. InviteId uint64 `protobuf:"varint,1,opt,name=invite_id,json=inviteId,proto3" json:"invite_id,omitempty"` // contains filtered or unexported fields }
AcceptGCInviteRequest is the request to accept an invite to join a GC.
func (*AcceptGCInviteRequest) Descriptor
deprecated
added in
v0.1.6
func (*AcceptGCInviteRequest) Descriptor() ([]byte, []int)
Deprecated: Use AcceptGCInviteRequest.ProtoReflect.Descriptor instead.
func (*AcceptGCInviteRequest) GetInviteId ¶ added in v0.1.6
func (x *AcceptGCInviteRequest) GetInviteId() uint64
func (*AcceptGCInviteRequest) ProtoMessage ¶ added in v0.1.6
func (*AcceptGCInviteRequest) ProtoMessage()
func (*AcceptGCInviteRequest) ProtoReflect ¶ added in v0.1.6
func (x *AcceptGCInviteRequest) ProtoReflect() protoreflect.Message
func (*AcceptGCInviteRequest) Reset ¶ added in v0.1.6
func (x *AcceptGCInviteRequest) Reset()
func (*AcceptGCInviteRequest) String ¶ added in v0.1.6
func (x *AcceptGCInviteRequest) String() string
type AcceptGCInviteResponse ¶ added in v0.1.6
type AcceptGCInviteResponse struct {
// contains filtered or unexported fields
}
AcceptGCInviteResponse is the response to accept an invite to join a GC.
func (*AcceptGCInviteResponse) Descriptor
deprecated
added in
v0.1.6
func (*AcceptGCInviteResponse) Descriptor() ([]byte, []int)
Deprecated: Use AcceptGCInviteResponse.ProtoReflect.Descriptor instead.
func (*AcceptGCInviteResponse) ProtoMessage ¶ added in v0.1.6
func (*AcceptGCInviteResponse) ProtoMessage()
func (*AcceptGCInviteResponse) ProtoReflect ¶ added in v0.1.6
func (x *AcceptGCInviteResponse) ProtoReflect() protoreflect.Message
func (*AcceptGCInviteResponse) Reset ¶ added in v0.1.6
func (x *AcceptGCInviteResponse) Reset()
func (*AcceptGCInviteResponse) String ¶ added in v0.1.6
func (x *AcceptGCInviteResponse) String() string
type AcceptInviteRequest ¶ added in v0.1.6
type AcceptInviteRequest struct { // invite_bytes is the raw invite. InviteBytes []byte `protobuf:"bytes,1,opt,name=invite_bytes,json=inviteBytes,proto3" json:"invite_bytes,omitempty"` // contains filtered or unexported fields }
AcceptInviteRequest is the request to accept an invite to KX with an user.
func (*AcceptInviteRequest) Descriptor
deprecated
added in
v0.1.6
func (*AcceptInviteRequest) Descriptor() ([]byte, []int)
Deprecated: Use AcceptInviteRequest.ProtoReflect.Descriptor instead.
func (*AcceptInviteRequest) GetInviteBytes ¶ added in v0.1.6
func (x *AcceptInviteRequest) GetInviteBytes() []byte
func (*AcceptInviteRequest) ProtoMessage ¶ added in v0.1.6
func (*AcceptInviteRequest) ProtoMessage()
func (*AcceptInviteRequest) ProtoReflect ¶ added in v0.1.6
func (x *AcceptInviteRequest) ProtoReflect() protoreflect.Message
func (*AcceptInviteRequest) Reset ¶ added in v0.1.6
func (x *AcceptInviteRequest) Reset()
func (*AcceptInviteRequest) String ¶ added in v0.1.6
func (x *AcceptInviteRequest) String() string
type AcceptInviteResponse ¶ added in v0.1.6
type AcceptInviteResponse struct { // invite is the decoded invite accepted. Invite *OOBPublicIdentityInvite `protobuf:"bytes,1,opt,name=invite,proto3" json:"invite,omitempty"` // contains filtered or unexported fields }
AcceptInviteResponse is the response to accepting an invite to KX with an user.
func (*AcceptInviteResponse) Descriptor
deprecated
added in
v0.1.6
func (*AcceptInviteResponse) Descriptor() ([]byte, []int)
Deprecated: Use AcceptInviteResponse.ProtoReflect.Descriptor instead.
func (*AcceptInviteResponse) GetInvite ¶ added in v0.1.6
func (x *AcceptInviteResponse) GetInvite() *OOBPublicIdentityInvite
func (*AcceptInviteResponse) ProtoMessage ¶ added in v0.1.6
func (*AcceptInviteResponse) ProtoMessage()
func (*AcceptInviteResponse) ProtoReflect ¶ added in v0.1.6
func (x *AcceptInviteResponse) ProtoReflect() protoreflect.Message
func (*AcceptInviteResponse) Reset ¶ added in v0.1.6
func (x *AcceptInviteResponse) Reset()
func (*AcceptInviteResponse) String ¶ added in v0.1.6
func (x *AcceptInviteResponse) String() string
type AckRequest ¶
type AckRequest struct { // sequence_id is the ID up to which messages have been processed. SequenceId uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // contains filtered or unexported fields }
AckRequest is a request to ack that a type of message up to a sequence ID has been processed.
func (*AckRequest) Descriptor
deprecated
func (*AckRequest) Descriptor() ([]byte, []int)
Deprecated: Use AckRequest.ProtoReflect.Descriptor instead.
func (*AckRequest) GetSequenceId ¶
func (x *AckRequest) GetSequenceId() uint64
func (*AckRequest) ProtoMessage ¶
func (*AckRequest) ProtoMessage()
func (*AckRequest) ProtoReflect ¶
func (x *AckRequest) ProtoReflect() protoreflect.Message
func (*AckRequest) Reset ¶
func (x *AckRequest) Reset()
func (*AckRequest) String ¶
func (x *AckRequest) String() string
type AckResponse ¶
type AckResponse struct {
// contains filtered or unexported fields
}
AckResponse is the response to an ack request.
func (*AckResponse) Descriptor
deprecated
func (*AckResponse) Descriptor() ([]byte, []int)
Deprecated: Use AckResponse.ProtoReflect.Descriptor instead.
func (*AckResponse) ProtoMessage ¶
func (*AckResponse) ProtoMessage()
func (*AckResponse) ProtoReflect ¶
func (x *AckResponse) ProtoReflect() protoreflect.Message
func (*AckResponse) Reset ¶
func (x *AckResponse) Reset()
func (*AckResponse) String ¶
func (x *AckResponse) String() string
type ChatServiceClient ¶
type ChatServiceClient interface { // PM sends a private message to a user of the client. PM(ctx context.Context, in *PMRequest, out *PMResponse) error // PMStream returns a stream that gets PMs received by the client. PMStream(ctx context.Context, in *PMStreamRequest) (ChatService_PMStreamClient, error) // AckReceivedPM acks to the server that PMs up to a sequence ID have been // processed. AckReceivedPM(ctx context.Context, in *AckRequest, out *AckResponse) error // GCM sends a message in a GC. GCM(ctx context.Context, in *GCMRequest, out *GCMResponse) error // GCMStream returns a stream that gets GC messages received by the client. GCMStream(ctx context.Context, in *GCMStreamRequest) (ChatService_GCMStreamClient, error) // AckReceivedGCM acks to the server that GCMs up to a sequence ID have been // processed. AckReceivedGCM(ctx context.Context, in *AckRequest, out *AckResponse) error // MediateKX requests a transitive mediate KX with a mediator, towards a // target user. MediateKX(ctx context.Context, in *MediateKXRequest, out *MediateKXResponse) error // KXStream returns a stream that gets notifications of completed KXs. Both // new users and KXs resulting from a reset trigger a new event in this // stream. KXStream(ctx context.Context, in *KXStreamRequest) (ChatService_KXStreamClient, error) // AckKXCompleted acks to the server that KXs up to the sequence ID have been // processed. AckKXCompleted(ctx context.Context, in *AckRequest, out *AckResponse) error // WriteNewInvite writes an invite to be sent (out-of-band) to an user to // perform KX with. WriteNewInvite(ctx context.Context, in *WriteNewInviteRequest, out *WriteNewInviteResponse) error // AcceptInvite accepts an invite to kx with the user-provided invite. AcceptInvite(ctx context.Context, in *AcceptInviteRequest, out *AcceptInviteResponse) error // SendFile sends a file to a user. SendFile(ctx context.Context, in *SendFileRequest, out *SendFileResponse) error }
ChatServiceClient is the client API for ChatService service.
func NewChatServiceClient ¶
func NewChatServiceClient(c ClientConn) ChatServiceClient
type ChatServiceServer ¶
type ChatServiceServer interface { // PM sends a private message to a user of the client. PM(context.Context, *PMRequest, *PMResponse) error // PMStream returns a stream that gets PMs received by the client. PMStream(context.Context, *PMStreamRequest, ChatService_PMStreamServer) error // AckReceivedPM acks to the server that PMs up to a sequence ID have been // processed. AckReceivedPM(context.Context, *AckRequest, *AckResponse) error // GCM sends a message in a GC. GCM(context.Context, *GCMRequest, *GCMResponse) error // GCMStream returns a stream that gets GC messages received by the client. GCMStream(context.Context, *GCMStreamRequest, ChatService_GCMStreamServer) error // AckReceivedGCM acks to the server that GCMs up to a sequence ID have been // processed. AckReceivedGCM(context.Context, *AckRequest, *AckResponse) error // MediateKX requests a transitive mediate KX with a mediator, towards a // target user. MediateKX(context.Context, *MediateKXRequest, *MediateKXResponse) error // KXStream returns a stream that gets notifications of completed KXs. Both // new users and KXs resulting from a reset trigger a new event in this // stream. KXStream(context.Context, *KXStreamRequest, ChatService_KXStreamServer) error // AckKXCompleted acks to the server that KXs up to the sequence ID have been // processed. AckKXCompleted(context.Context, *AckRequest, *AckResponse) error // WriteNewInvite writes an invite to be sent (out-of-band) to an user to // perform KX with. WriteNewInvite(context.Context, *WriteNewInviteRequest, *WriteNewInviteResponse) error // AcceptInvite accepts an invite to kx with the user-provided invite. AcceptInvite(context.Context, *AcceptInviteRequest, *AcceptInviteResponse) error // SendFile sends a file to a user. SendFile(context.Context, *SendFileRequest, *SendFileResponse) error }
ChatServiceServer is the server API for ChatService service.
type ChatService_GCMStreamClient ¶
type ChatService_GCMStreamClient interface {
Recv(*GCReceivedMsg) error
}
type ChatService_GCMStreamServer ¶
type ChatService_GCMStreamServer interface {
Send(m *GCReceivedMsg) error
}
type ChatService_KXStreamClient ¶ added in v0.1.5
type ChatService_KXStreamClient interface {
Recv(*KXCompleted) error
}
type ChatService_KXStreamServer ¶ added in v0.1.5
type ChatService_KXStreamServer interface {
Send(m *KXCompleted) error
}
type ChatService_PMStreamClient ¶
type ChatService_PMStreamClient interface {
Recv(*ReceivedPM) error
}
type ChatService_PMStreamServer ¶
type ChatService_PMStreamServer interface {
Send(m *ReceivedPM) error
}
type ClientConn ¶
type ClientConn interface { Request(ctx context.Context, method string, request, response proto.Message) error Stream(ctx context.Context, method string, request proto.Message) (ClientStream, error) }
ClientConn abstracts the necessary functions from an underlying transport of messages.
type ClientStream ¶
ClientStream abstracts the necessary functions of a client-side stream.
type GCMRequest ¶
type GCMRequest struct { // gc is either an hex-encoded GCID or a GC alias. Gc string `protobuf:"bytes,1,opt,name=gc,proto3" json:"gc,omitempty"` // msg is the text payload of the message. Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` // contains filtered or unexported fields }
GCMRequest is a request to send a GC message.
func (*GCMRequest) Descriptor
deprecated
func (*GCMRequest) Descriptor() ([]byte, []int)
Deprecated: Use GCMRequest.ProtoReflect.Descriptor instead.
func (*GCMRequest) GetGc ¶
func (x *GCMRequest) GetGc() string
func (*GCMRequest) GetMsg ¶
func (x *GCMRequest) GetMsg() string
func (*GCMRequest) ProtoMessage ¶
func (*GCMRequest) ProtoMessage()
func (*GCMRequest) ProtoReflect ¶
func (x *GCMRequest) ProtoReflect() protoreflect.Message
func (*GCMRequest) Reset ¶
func (x *GCMRequest) Reset()
func (*GCMRequest) String ¶
func (x *GCMRequest) String() string
type GCMResponse ¶
type GCMResponse struct {
// contains filtered or unexported fields
}
GCMResponse is the response to sending a GC message.
func (*GCMResponse) Descriptor
deprecated
func (*GCMResponse) Descriptor() ([]byte, []int)
Deprecated: Use GCMResponse.ProtoReflect.Descriptor instead.
func (*GCMResponse) ProtoMessage ¶
func (*GCMResponse) ProtoMessage()
func (*GCMResponse) ProtoReflect ¶
func (x *GCMResponse) ProtoReflect() protoreflect.Message
func (*GCMResponse) Reset ¶
func (x *GCMResponse) Reset()
func (*GCMResponse) String ¶
func (x *GCMResponse) String() string
type GCMStreamRequest ¶
type GCMStreamRequest struct { // unacked_from specifies to the server the sequence_id of the last processed // GCM. GCMs received by the server that have a higher sequence_id will be // streamed back to the client. UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"` // contains filtered or unexported fields }
GCMStreamRequest is a request to a stream of received GC messages.
func (*GCMStreamRequest) Descriptor
deprecated
func (*GCMStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use GCMStreamRequest.ProtoReflect.Descriptor instead.
func (*GCMStreamRequest) GetUnackedFrom ¶
func (x *GCMStreamRequest) GetUnackedFrom() uint64
func (*GCMStreamRequest) ProtoMessage ¶
func (*GCMStreamRequest) ProtoMessage()
func (*GCMStreamRequest) ProtoReflect ¶
func (x *GCMStreamRequest) ProtoReflect() protoreflect.Message
func (*GCMStreamRequest) Reset ¶
func (x *GCMStreamRequest) Reset()
func (*GCMStreamRequest) String ¶
func (x *GCMStreamRequest) String() string
type GCMembersAddedEvent ¶ added in v0.1.6
type GCMembersAddedEvent struct { // sequence_id is an opaque sequential ID. SequenceId uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // gc is the ID of the GC. Gc []byte `protobuf:"bytes,2,opt,name=gc,proto3" json:"gc,omitempty"` // gc_name is the local alias of the GC. GcName string `protobuf:"bytes,3,opt,name=gc_name,json=gcName,proto3" json:"gc_name,omitempty"` // users is the list of users added to the GC. Users []*UserAndNick `protobuf:"bytes,4,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
GCMembersAddedEvent are events received when a GC has new members.
func (*GCMembersAddedEvent) Descriptor
deprecated
added in
v0.1.6
func (*GCMembersAddedEvent) Descriptor() ([]byte, []int)
Deprecated: Use GCMembersAddedEvent.ProtoReflect.Descriptor instead.
func (*GCMembersAddedEvent) GetGc ¶ added in v0.1.6
func (x *GCMembersAddedEvent) GetGc() []byte
func (*GCMembersAddedEvent) GetGcName ¶ added in v0.1.6
func (x *GCMembersAddedEvent) GetGcName() string
func (*GCMembersAddedEvent) GetSequenceId ¶ added in v0.1.6
func (x *GCMembersAddedEvent) GetSequenceId() uint64
func (*GCMembersAddedEvent) GetUsers ¶ added in v0.1.6
func (x *GCMembersAddedEvent) GetUsers() []*UserAndNick
func (*GCMembersAddedEvent) ProtoMessage ¶ added in v0.1.6
func (*GCMembersAddedEvent) ProtoMessage()
func (*GCMembersAddedEvent) ProtoReflect ¶ added in v0.1.6
func (x *GCMembersAddedEvent) ProtoReflect() protoreflect.Message
func (*GCMembersAddedEvent) Reset ¶ added in v0.1.6
func (x *GCMembersAddedEvent) Reset()
func (*GCMembersAddedEvent) String ¶ added in v0.1.6
func (x *GCMembersAddedEvent) String() string
type GCMembersAddedRequest ¶ added in v0.1.6
type GCMembersAddedRequest struct { // unacked_from specifies to the server the sequence_id of the last received // GC members added event. Events received by the server that have a higher // sequence_id will be streamed back to the client. UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"` // contains filtered or unexported fields }
GCMembersAddedRequest is the request sent to create a stream that receives GC members added events.
func (*GCMembersAddedRequest) Descriptor
deprecated
added in
v0.1.6
func (*GCMembersAddedRequest) Descriptor() ([]byte, []int)
Deprecated: Use GCMembersAddedRequest.ProtoReflect.Descriptor instead.
func (*GCMembersAddedRequest) GetUnackedFrom ¶ added in v0.1.6
func (x *GCMembersAddedRequest) GetUnackedFrom() uint64
func (*GCMembersAddedRequest) ProtoMessage ¶ added in v0.1.6
func (*GCMembersAddedRequest) ProtoMessage()
func (*GCMembersAddedRequest) ProtoReflect ¶ added in v0.1.6
func (x *GCMembersAddedRequest) ProtoReflect() protoreflect.Message
func (*GCMembersAddedRequest) Reset ¶ added in v0.1.6
func (x *GCMembersAddedRequest) Reset()
func (*GCMembersAddedRequest) String ¶ added in v0.1.6
func (x *GCMembersAddedRequest) String() string
type GCMembersRemovedEvent ¶ added in v0.1.6
type GCMembersRemovedEvent struct { // sequence_id is an opaque sequential ID. SequenceId uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // gc is the ID of the GC. Gc []byte `protobuf:"bytes,2,opt,name=gc,proto3" json:"gc,omitempty"` // gc_name is the local alias of the GC. GcName string `protobuf:"bytes,3,opt,name=gc_name,json=gcName,proto3" json:"gc_name,omitempty"` // users is the list of users removed from the GC. Users []*UserAndNick `protobuf:"bytes,4,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
GCMembersRemovedEvent is an event received when members are removed from a GC.
func (*GCMembersRemovedEvent) Descriptor
deprecated
added in
v0.1.6
func (*GCMembersRemovedEvent) Descriptor() ([]byte, []int)
Deprecated: Use GCMembersRemovedEvent.ProtoReflect.Descriptor instead.
func (*GCMembersRemovedEvent) GetGc ¶ added in v0.1.6
func (x *GCMembersRemovedEvent) GetGc() []byte
func (*GCMembersRemovedEvent) GetGcName ¶ added in v0.1.6
func (x *GCMembersRemovedEvent) GetGcName() string
func (*GCMembersRemovedEvent) GetSequenceId ¶ added in v0.1.6
func (x *GCMembersRemovedEvent) GetSequenceId() uint64
func (*GCMembersRemovedEvent) GetUsers ¶ added in v0.1.6
func (x *GCMembersRemovedEvent) GetUsers() []*UserAndNick
func (*GCMembersRemovedEvent) ProtoMessage ¶ added in v0.1.6
func (*GCMembersRemovedEvent) ProtoMessage()
func (*GCMembersRemovedEvent) ProtoReflect ¶ added in v0.1.6
func (x *GCMembersRemovedEvent) ProtoReflect() protoreflect.Message
func (*GCMembersRemovedEvent) Reset ¶ added in v0.1.6
func (x *GCMembersRemovedEvent) Reset()
func (*GCMembersRemovedEvent) String ¶ added in v0.1.6
func (x *GCMembersRemovedEvent) String() string
type GCMembersRemovedRequest ¶ added in v0.1.6
type GCMembersRemovedRequest struct { // unacked_from specifies to the server the sequence_id of the last received // GC members removed event. Events received by the server that have a higher // sequence_id will be streamed back to the client. UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"` // contains filtered or unexported fields }
GCMembersRemovedRequest is the request to create a stream to receive GC members removed events.
func (*GCMembersRemovedRequest) Descriptor
deprecated
added in
v0.1.6
func (*GCMembersRemovedRequest) Descriptor() ([]byte, []int)
Deprecated: Use GCMembersRemovedRequest.ProtoReflect.Descriptor instead.
func (*GCMembersRemovedRequest) GetUnackedFrom ¶ added in v0.1.6
func (x *GCMembersRemovedRequest) GetUnackedFrom() uint64
func (*GCMembersRemovedRequest) ProtoMessage ¶ added in v0.1.6
func (*GCMembersRemovedRequest) ProtoMessage()
func (*GCMembersRemovedRequest) ProtoReflect ¶ added in v0.1.6
func (x *GCMembersRemovedRequest) ProtoReflect() protoreflect.Message
func (*GCMembersRemovedRequest) Reset ¶ added in v0.1.6
func (x *GCMembersRemovedRequest) Reset()
func (*GCMembersRemovedRequest) String ¶ added in v0.1.6
func (x *GCMembersRemovedRequest) String() string
type GCReceivedMsg ¶
type GCReceivedMsg struct { // uid is the source user ID. Uid []byte `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // nick is the source user nick/alias. Nick string `protobuf:"bytes,2,opt,name=nick,proto3" json:"nick,omitempty"` // gc_alias is the local alias of the GC where the message was sent. GcAlias string `protobuf:"bytes,3,opt,name=gc_alias,json=gcAlias,proto3" json:"gc_alias,omitempty"` // msg is the received message. Msg *RMGroupMessage `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"` // timestamp_ms is the server timestamp of the message with millisecond precision. TimestampMs int64 `protobuf:"varint,5,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"` // sequence_id is an opaque sequential ID. SequenceId uint64 `protobuf:"varint,6,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // contains filtered or unexported fields }
GCReceivedMsg is a GC message received from a remote user.
func (*GCReceivedMsg) Descriptor
deprecated
func (*GCReceivedMsg) Descriptor() ([]byte, []int)
Deprecated: Use GCReceivedMsg.ProtoReflect.Descriptor instead.
func (*GCReceivedMsg) GetGcAlias ¶
func (x *GCReceivedMsg) GetGcAlias() string
func (*GCReceivedMsg) GetMsg ¶
func (x *GCReceivedMsg) GetMsg() *RMGroupMessage
func (*GCReceivedMsg) GetNick ¶
func (x *GCReceivedMsg) GetNick() string
func (*GCReceivedMsg) GetSequenceId ¶
func (x *GCReceivedMsg) GetSequenceId() uint64
func (*GCReceivedMsg) GetTimestampMs ¶
func (x *GCReceivedMsg) GetTimestampMs() int64
func (*GCReceivedMsg) GetUid ¶
func (x *GCReceivedMsg) GetUid() []byte
func (*GCReceivedMsg) ProtoMessage ¶
func (*GCReceivedMsg) ProtoMessage()
func (*GCReceivedMsg) ProtoReflect ¶
func (x *GCReceivedMsg) ProtoReflect() protoreflect.Message
func (*GCReceivedMsg) Reset ¶
func (x *GCReceivedMsg) Reset()
func (*GCReceivedMsg) String ¶
func (x *GCReceivedMsg) String() string
type GCServiceClient ¶ added in v0.1.6
type GCServiceClient interface { // InviteToGC invites an user to join a GC. The local user must have admin // privileges in the gc. InviteToGC(ctx context.Context, in *InviteToGCRequest, out *InviteToGCResponse) error // AcceptGCInvite accepts an invitation to join a GC. AcceptGCInvite(ctx context.Context, in *AcceptGCInviteRequest, out *AcceptGCInviteResponse) error // KickFromGC kicks an user from a GC. The local user must have admin // privileges in the GC. KickFromGC(ctx context.Context, in *KickFromGCRequest, out *KickFromGCResponse) error // GetGC returns the full definition for a GC. GetGC(ctx context.Context, in *GetGCRequest, out *GetGCResponse) error // List returns a list with all GCs. List(ctx context.Context, in *ListGCsRequest, out *ListGCsResponse) error // ReceivedGCInvites returns a stream that gets sent invitations that remote // users make for the local client to join GCs. ReceivedGCInvites(ctx context.Context, in *ReceivedGCInvitesRequest) (GCService_ReceivedGCInvitesClient, error) // AckReceivedGCInvites acks received gc invite events. AckReceivedGCInvites(ctx context.Context, in *AckRequest, out *AckResponse) error // MembersAdded returns a stream that gets sent events about members added // to GCs the local client participates in. MembersAdded(ctx context.Context, in *GCMembersAddedRequest) (GCService_MembersAddedClient, error) // AckMembersAdded acks received members added events. AckMembersAdded(ctx context.Context, in *AckRequest, out *AckResponse) error // MembersRemoved returns a stream that gets sent events about members removed // from GCs the local client participates in. MembersRemoved(ctx context.Context, in *GCMembersRemovedRequest) (GCService_MembersRemovedClient, error) // AckMembersRemoved acks received members removed events. AckMembersRemoved(ctx context.Context, in *AckRequest, out *AckResponse) error // JoinedGCs returns a stream that gets sent events about GCs the local client // has joined. JoinedGCs(ctx context.Context, in *JoinedGCsRequest) (GCService_JoinedGCsClient, error) // AckJoinedGCs acks received joined gc events. AckJoinedGCs(ctx context.Context, in *AckRequest, out *AckResponse) error }
GCServiceClient is the client API for GCService service.
func NewGCServiceClient ¶ added in v0.1.6
func NewGCServiceClient(c ClientConn) GCServiceClient
type GCServiceServer ¶ added in v0.1.6
type GCServiceServer interface { // InviteToGC invites an user to join a GC. The local user must have admin // privileges in the gc. InviteToGC(context.Context, *InviteToGCRequest, *InviteToGCResponse) error // AcceptGCInvite accepts an invitation to join a GC. AcceptGCInvite(context.Context, *AcceptGCInviteRequest, *AcceptGCInviteResponse) error // KickFromGC kicks an user from a GC. The local user must have admin // privileges in the GC. KickFromGC(context.Context, *KickFromGCRequest, *KickFromGCResponse) error // GetGC returns the full definition for a GC. GetGC(context.Context, *GetGCRequest, *GetGCResponse) error // List returns a list with all GCs. List(context.Context, *ListGCsRequest, *ListGCsResponse) error // ReceivedGCInvites returns a stream that gets sent invitations that remote // users make for the local client to join GCs. ReceivedGCInvites(context.Context, *ReceivedGCInvitesRequest, GCService_ReceivedGCInvitesServer) error // AckReceivedGCInvites acks received gc invite events. AckReceivedGCInvites(context.Context, *AckRequest, *AckResponse) error // MembersAdded returns a stream that gets sent events about members added // to GCs the local client participates in. MembersAdded(context.Context, *GCMembersAddedRequest, GCService_MembersAddedServer) error // AckMembersAdded acks received members added events. AckMembersAdded(context.Context, *AckRequest, *AckResponse) error // MembersRemoved returns a stream that gets sent events about members removed // from GCs the local client participates in. MembersRemoved(context.Context, *GCMembersRemovedRequest, GCService_MembersRemovedServer) error // AckMembersRemoved acks received members removed events. AckMembersRemoved(context.Context, *AckRequest, *AckResponse) error // JoinedGCs returns a stream that gets sent events about GCs the local client // has joined. JoinedGCs(context.Context, *JoinedGCsRequest, GCService_JoinedGCsServer) error // AckJoinedGCs acks received joined gc events. AckJoinedGCs(context.Context, *AckRequest, *AckResponse) error }
GCServiceServer is the server API for GCService service.
type GCService_JoinedGCsClient ¶ added in v0.1.6
type GCService_JoinedGCsClient interface {
Recv(*JoinedGCEvent) error
}
type GCService_JoinedGCsServer ¶ added in v0.1.6
type GCService_JoinedGCsServer interface {
Send(m *JoinedGCEvent) error
}
type GCService_MembersAddedClient ¶ added in v0.1.6
type GCService_MembersAddedClient interface {
Recv(*GCMembersAddedEvent) error
}
type GCService_MembersAddedServer ¶ added in v0.1.6
type GCService_MembersAddedServer interface {
Send(m *GCMembersAddedEvent) error
}
type GCService_MembersRemovedClient ¶ added in v0.1.6
type GCService_MembersRemovedClient interface {
Recv(*GCMembersRemovedEvent) error
}
type GCService_MembersRemovedServer ¶ added in v0.1.6
type GCService_MembersRemovedServer interface {
Send(m *GCMembersRemovedEvent) error
}
type GCService_ReceivedGCInvitesClient ¶ added in v0.1.6
type GCService_ReceivedGCInvitesClient interface {
Recv(*ReceivedGCInvite) error
}
type GCService_ReceivedGCInvitesServer ¶ added in v0.1.6
type GCService_ReceivedGCInvitesServer interface {
Send(m *ReceivedGCInvite) error
}
type GetGCRequest ¶ added in v0.1.6
type GetGCRequest struct { // gc is the hex-encoded ID or alias of the target GC. Gc string `protobuf:"bytes,1,opt,name=gc,proto3" json:"gc,omitempty"` // contains filtered or unexported fields }
GetGCRequest is the request to get GC datails.
func (*GetGCRequest) Descriptor
deprecated
added in
v0.1.6
func (*GetGCRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetGCRequest.ProtoReflect.Descriptor instead.
func (*GetGCRequest) GetGc ¶ added in v0.1.6
func (x *GetGCRequest) GetGc() string
func (*GetGCRequest) ProtoMessage ¶ added in v0.1.6
func (*GetGCRequest) ProtoMessage()
func (*GetGCRequest) ProtoReflect ¶ added in v0.1.6
func (x *GetGCRequest) ProtoReflect() protoreflect.Message
func (*GetGCRequest) Reset ¶ added in v0.1.6
func (x *GetGCRequest) Reset()
func (*GetGCRequest) String ¶ added in v0.1.6
func (x *GetGCRequest) String() string
type GetGCResponse ¶ added in v0.1.6
type GetGCResponse struct { // gc is the gc definition. Gc *RMGroupList `protobuf:"bytes,1,opt,name=gc,proto3" json:"gc,omitempty"` // contains filtered or unexported fields }
GetGCResponse is the response to a request to get GC details.
func (*GetGCResponse) Descriptor
deprecated
added in
v0.1.6
func (*GetGCResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetGCResponse.ProtoReflect.Descriptor instead.
func (*GetGCResponse) GetGc ¶ added in v0.1.6
func (x *GetGCResponse) GetGc() *RMGroupList
func (*GetGCResponse) ProtoMessage ¶ added in v0.1.6
func (*GetGCResponse) ProtoMessage()
func (*GetGCResponse) ProtoReflect ¶ added in v0.1.6
func (x *GetGCResponse) ProtoReflect() protoreflect.Message
func (*GetGCResponse) Reset ¶ added in v0.1.6
func (x *GetGCResponse) Reset()
func (*GetGCResponse) String ¶ added in v0.1.6
func (x *GetGCResponse) String() string
type InviteToGCRequest ¶ added in v0.1.6
type InviteToGCRequest struct { // gc is the hex-encoded ID or the alias of the GC in the local client. Gc string `protobuf:"bytes,1,opt,name=gc,proto3" json:"gc,omitempty"` // user is the hex-encoded ID of the user or its nick. User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
InviteToGCRequest is the request to invite an user to a GC.
func (*InviteToGCRequest) Descriptor
deprecated
added in
v0.1.6
func (*InviteToGCRequest) Descriptor() ([]byte, []int)
Deprecated: Use InviteToGCRequest.ProtoReflect.Descriptor instead.
func (*InviteToGCRequest) GetGc ¶ added in v0.1.6
func (x *InviteToGCRequest) GetGc() string
func (*InviteToGCRequest) GetUser ¶ added in v0.1.6
func (x *InviteToGCRequest) GetUser() string
func (*InviteToGCRequest) ProtoMessage ¶ added in v0.1.6
func (*InviteToGCRequest) ProtoMessage()
func (*InviteToGCRequest) ProtoReflect ¶ added in v0.1.6
func (x *InviteToGCRequest) ProtoReflect() protoreflect.Message
func (*InviteToGCRequest) Reset ¶ added in v0.1.6
func (x *InviteToGCRequest) Reset()
func (*InviteToGCRequest) String ¶ added in v0.1.6
func (x *InviteToGCRequest) String() string
type InviteToGCResponse ¶ added in v0.1.6
type InviteToGCResponse struct {
// contains filtered or unexported fields
}
InviteToGCResponse is the response to the request to invite an user to a GC.
func (*InviteToGCResponse) Descriptor
deprecated
added in
v0.1.6
func (*InviteToGCResponse) Descriptor() ([]byte, []int)
Deprecated: Use InviteToGCResponse.ProtoReflect.Descriptor instead.
func (*InviteToGCResponse) ProtoMessage ¶ added in v0.1.6
func (*InviteToGCResponse) ProtoMessage()
func (*InviteToGCResponse) ProtoReflect ¶ added in v0.1.6
func (x *InviteToGCResponse) ProtoReflect() protoreflect.Message
func (*InviteToGCResponse) Reset ¶ added in v0.1.6
func (x *InviteToGCResponse) Reset()
func (*InviteToGCResponse) String ¶ added in v0.1.6
func (x *InviteToGCResponse) String() string
type JoinedGCEvent ¶ added in v0.1.6
type JoinedGCEvent struct { // sequence_id is an opaque sequential ID. SequenceId uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // gc is the GC definition. Gc *RMGroupList `protobuf:"bytes,2,opt,name=gc,proto3" json:"gc,omitempty"` // contains filtered or unexported fields }
JoinedGCEvent is the event received when the local client joins a GC.
func (*JoinedGCEvent) Descriptor
deprecated
added in
v0.1.6
func (*JoinedGCEvent) Descriptor() ([]byte, []int)
Deprecated: Use JoinedGCEvent.ProtoReflect.Descriptor instead.
func (*JoinedGCEvent) GetGc ¶ added in v0.1.6
func (x *JoinedGCEvent) GetGc() *RMGroupList
func (*JoinedGCEvent) GetSequenceId ¶ added in v0.1.6
func (x *JoinedGCEvent) GetSequenceId() uint64
func (*JoinedGCEvent) ProtoMessage ¶ added in v0.1.6
func (*JoinedGCEvent) ProtoMessage()
func (*JoinedGCEvent) ProtoReflect ¶ added in v0.1.6
func (x *JoinedGCEvent) ProtoReflect() protoreflect.Message
func (*JoinedGCEvent) Reset ¶ added in v0.1.6
func (x *JoinedGCEvent) Reset()
func (*JoinedGCEvent) String ¶ added in v0.1.6
func (x *JoinedGCEvent) String() string
type JoinedGCsRequest ¶ added in v0.1.6
type JoinedGCsRequest struct { // unacked_from specifies to the server the sequence_id of the last received // GC joined event. Events received by the server that have a higher // sequence_id will be streamed back to the client. UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"` // contains filtered or unexported fields }
JoinedGCsRequest is the request to create a stream that receives events about GCs the local client has joined.
func (*JoinedGCsRequest) Descriptor
deprecated
added in
v0.1.6
func (*JoinedGCsRequest) Descriptor() ([]byte, []int)
Deprecated: Use JoinedGCsRequest.ProtoReflect.Descriptor instead.
func (*JoinedGCsRequest) GetUnackedFrom ¶ added in v0.1.6
func (x *JoinedGCsRequest) GetUnackedFrom() uint64
func (*JoinedGCsRequest) ProtoMessage ¶ added in v0.1.6
func (*JoinedGCsRequest) ProtoMessage()
func (*JoinedGCsRequest) ProtoReflect ¶ added in v0.1.6
func (x *JoinedGCsRequest) ProtoReflect() protoreflect.Message
func (*JoinedGCsRequest) Reset ¶ added in v0.1.6
func (x *JoinedGCsRequest) Reset()
func (*JoinedGCsRequest) String ¶ added in v0.1.6
func (x *JoinedGCsRequest) String() string
type KXCompleted ¶ added in v0.1.5
type KXCompleted struct { // sequence_id is an opaque sequential ID. SequenceId uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // uid is the raw ID of the KX'd user. Uid []byte `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // nick is the nick of the KX'd user. Nick string `protobuf:"bytes,3,opt,name=nick,proto3" json:"nick,omitempty"` // contains filtered or unexported fields }
KXCompleted is the information about a completed KX event.
func (*KXCompleted) Descriptor
deprecated
added in
v0.1.5
func (*KXCompleted) Descriptor() ([]byte, []int)
Deprecated: Use KXCompleted.ProtoReflect.Descriptor instead.
func (*KXCompleted) GetNick ¶ added in v0.1.5
func (x *KXCompleted) GetNick() string
func (*KXCompleted) GetSequenceId ¶ added in v0.1.5
func (x *KXCompleted) GetSequenceId() uint64
func (*KXCompleted) GetUid ¶ added in v0.1.5
func (x *KXCompleted) GetUid() []byte
func (*KXCompleted) ProtoMessage ¶ added in v0.1.5
func (*KXCompleted) ProtoMessage()
func (*KXCompleted) ProtoReflect ¶ added in v0.1.5
func (x *KXCompleted) ProtoReflect() protoreflect.Message
func (*KXCompleted) Reset ¶ added in v0.1.5
func (x *KXCompleted) Reset()
func (*KXCompleted) String ¶ added in v0.1.5
func (x *KXCompleted) String() string
type KXStreamRequest ¶ added in v0.1.5
type KXStreamRequest struct { // unacked_from specifies to the server the sequence_id of the last completed // KX. KXs completed by the server that have a higher sequence_id will be // streamed back to the client. UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"` // contains filtered or unexported fields }
KXStreamRequest is the request sent when obtaining a stream of KX notifications.
func (*KXStreamRequest) Descriptor
deprecated
added in
v0.1.5
func (*KXStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use KXStreamRequest.ProtoReflect.Descriptor instead.
func (*KXStreamRequest) GetUnackedFrom ¶ added in v0.1.5
func (x *KXStreamRequest) GetUnackedFrom() uint64
func (*KXStreamRequest) ProtoMessage ¶ added in v0.1.5
func (*KXStreamRequest) ProtoMessage()
func (*KXStreamRequest) ProtoReflect ¶ added in v0.1.5
func (x *KXStreamRequest) ProtoReflect() protoreflect.Message
func (*KXStreamRequest) Reset ¶ added in v0.1.5
func (x *KXStreamRequest) Reset()
func (*KXStreamRequest) String ¶ added in v0.1.5
func (x *KXStreamRequest) String() string
type KeepaliveEvent ¶
type KeepaliveEvent struct { // timestamp is the unix timestamp on the server, with second precision. Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
KeepaliveEvent is a single keepalive event.
func (*KeepaliveEvent) Descriptor
deprecated
func (*KeepaliveEvent) Descriptor() ([]byte, []int)
Deprecated: Use KeepaliveEvent.ProtoReflect.Descriptor instead.
func (*KeepaliveEvent) GetTimestamp ¶
func (x *KeepaliveEvent) GetTimestamp() int64
func (*KeepaliveEvent) ProtoMessage ¶
func (*KeepaliveEvent) ProtoMessage()
func (*KeepaliveEvent) ProtoReflect ¶
func (x *KeepaliveEvent) ProtoReflect() protoreflect.Message
func (*KeepaliveEvent) Reset ¶
func (x *KeepaliveEvent) Reset()
func (*KeepaliveEvent) String ¶
func (x *KeepaliveEvent) String() string
type KeepaliveStreamRequest ¶
type KeepaliveStreamRequest struct { // interval is how often to send the keepalive (in milliseconds). // // A minimum of 1 second is imposed, regardless of the value passed as // interval. Interval int64 `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"` // contains filtered or unexported fields }
KeepaliveStreamRequest is the request for a new keepalive stream.
func (*KeepaliveStreamRequest) Descriptor
deprecated
func (*KeepaliveStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use KeepaliveStreamRequest.ProtoReflect.Descriptor instead.
func (*KeepaliveStreamRequest) GetInterval ¶
func (x *KeepaliveStreamRequest) GetInterval() int64
func (*KeepaliveStreamRequest) ProtoMessage ¶
func (*KeepaliveStreamRequest) ProtoMessage()
func (*KeepaliveStreamRequest) ProtoReflect ¶
func (x *KeepaliveStreamRequest) ProtoReflect() protoreflect.Message
func (*KeepaliveStreamRequest) Reset ¶
func (x *KeepaliveStreamRequest) Reset()
func (*KeepaliveStreamRequest) String ¶
func (x *KeepaliveStreamRequest) String() string
type KickFromGCRequest ¶ added in v0.1.6
type KickFromGCRequest struct { // gc is the hex-encoded ID or alias of the target GC. Gc string `protobuf:"bytes,1,opt,name=gc,proto3" json:"gc,omitempty"` // user is the hex-encoded ID or nick of the target user. User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` // reason is an optional reason to send for the kick. Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
KickFromGCRequest is the request to kick an user from a GC.
func (*KickFromGCRequest) Descriptor
deprecated
added in
v0.1.6
func (*KickFromGCRequest) Descriptor() ([]byte, []int)
Deprecated: Use KickFromGCRequest.ProtoReflect.Descriptor instead.
func (*KickFromGCRequest) GetGc ¶ added in v0.1.6
func (x *KickFromGCRequest) GetGc() string
func (*KickFromGCRequest) GetReason ¶ added in v0.1.6
func (x *KickFromGCRequest) GetReason() string
func (*KickFromGCRequest) GetUser ¶ added in v0.1.6
func (x *KickFromGCRequest) GetUser() string
func (*KickFromGCRequest) ProtoMessage ¶ added in v0.1.6
func (*KickFromGCRequest) ProtoMessage()
func (*KickFromGCRequest) ProtoReflect ¶ added in v0.1.6
func (x *KickFromGCRequest) ProtoReflect() protoreflect.Message
func (*KickFromGCRequest) Reset ¶ added in v0.1.6
func (x *KickFromGCRequest) Reset()
func (*KickFromGCRequest) String ¶ added in v0.1.6
func (x *KickFromGCRequest) String() string
type KickFromGCResponse ¶ added in v0.1.6
type KickFromGCResponse struct {
// contains filtered or unexported fields
}
KickFromGCResponse is the response to a kick request.
func (*KickFromGCResponse) Descriptor
deprecated
added in
v0.1.6
func (*KickFromGCResponse) Descriptor() ([]byte, []int)
Deprecated: Use KickFromGCResponse.ProtoReflect.Descriptor instead.
func (*KickFromGCResponse) ProtoMessage ¶ added in v0.1.6
func (*KickFromGCResponse) ProtoMessage()
func (*KickFromGCResponse) ProtoReflect ¶ added in v0.1.6
func (x *KickFromGCResponse) ProtoReflect() protoreflect.Message
func (*KickFromGCResponse) Reset ¶ added in v0.1.6
func (x *KickFromGCResponse) Reset()
func (*KickFromGCResponse) String ¶ added in v0.1.6
func (x *KickFromGCResponse) String() string
type ListGCsRequest ¶ added in v0.1.6
type ListGCsRequest struct {
// contains filtered or unexported fields
}
ListGCsRequest is the request to list GC data.
func (*ListGCsRequest) Descriptor
deprecated
added in
v0.1.6
func (*ListGCsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListGCsRequest.ProtoReflect.Descriptor instead.
func (*ListGCsRequest) ProtoMessage ¶ added in v0.1.6
func (*ListGCsRequest) ProtoMessage()
func (*ListGCsRequest) ProtoReflect ¶ added in v0.1.6
func (x *ListGCsRequest) ProtoReflect() protoreflect.Message
func (*ListGCsRequest) Reset ¶ added in v0.1.6
func (x *ListGCsRequest) Reset()
func (*ListGCsRequest) String ¶ added in v0.1.6
func (x *ListGCsRequest) String() string
type ListGCsResponse ¶ added in v0.1.6
type ListGCsResponse struct { // gcs is the list of GCs for the local client. Gcs []*ListGCsResponse_GCInfo `protobuf:"bytes,1,rep,name=gcs,proto3" json:"gcs,omitempty"` // contains filtered or unexported fields }
ListGCsResponse is the response to a request to list GC data.
func (*ListGCsResponse) Descriptor
deprecated
added in
v0.1.6
func (*ListGCsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListGCsResponse.ProtoReflect.Descriptor instead.
func (*ListGCsResponse) GetGcs ¶ added in v0.1.6
func (x *ListGCsResponse) GetGcs() []*ListGCsResponse_GCInfo
func (*ListGCsResponse) ProtoMessage ¶ added in v0.1.6
func (*ListGCsResponse) ProtoMessage()
func (*ListGCsResponse) ProtoReflect ¶ added in v0.1.6
func (x *ListGCsResponse) ProtoReflect() protoreflect.Message
func (*ListGCsResponse) Reset ¶ added in v0.1.6
func (x *ListGCsResponse) Reset()
func (*ListGCsResponse) String ¶ added in v0.1.6
func (x *ListGCsResponse) String() string
type ListGCsResponse_GCInfo ¶ added in v0.1.6
type ListGCsResponse_GCInfo struct { // id is the unique GC ID. Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // name is the local name/alias for the GC. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // version is the current version the GC definition is on. Version uint32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"` // timestamp is the timestamp of the last modification to the GC definition. Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // nb_members is the total number of members in the GC. NbMembers uint32 `protobuf:"varint,5,opt,name=nb_members,json=nbMembers,proto3" json:"nb_members,omitempty"` // contains filtered or unexported fields }
GCInfo is the summary info for a GC.
func (*ListGCsResponse_GCInfo) Descriptor
deprecated
added in
v0.1.6
func (*ListGCsResponse_GCInfo) Descriptor() ([]byte, []int)
Deprecated: Use ListGCsResponse_GCInfo.ProtoReflect.Descriptor instead.
func (*ListGCsResponse_GCInfo) GetId ¶ added in v0.1.6
func (x *ListGCsResponse_GCInfo) GetId() []byte
func (*ListGCsResponse_GCInfo) GetName ¶ added in v0.1.6
func (x *ListGCsResponse_GCInfo) GetName() string
func (*ListGCsResponse_GCInfo) GetNbMembers ¶ added in v0.1.6
func (x *ListGCsResponse_GCInfo) GetNbMembers() uint32
func (*ListGCsResponse_GCInfo) GetTimestamp ¶ added in v0.1.6
func (x *ListGCsResponse_GCInfo) GetTimestamp() int64
func (*ListGCsResponse_GCInfo) GetVersion ¶ added in v0.1.6
func (x *ListGCsResponse_GCInfo) GetVersion() uint32
func (*ListGCsResponse_GCInfo) ProtoMessage ¶ added in v0.1.6
func (*ListGCsResponse_GCInfo) ProtoMessage()
func (*ListGCsResponse_GCInfo) ProtoReflect ¶ added in v0.1.6
func (x *ListGCsResponse_GCInfo) ProtoReflect() protoreflect.Message
func (*ListGCsResponse_GCInfo) Reset ¶ added in v0.1.6
func (x *ListGCsResponse_GCInfo) Reset()
func (*ListGCsResponse_GCInfo) String ¶ added in v0.1.6
func (x *ListGCsResponse_GCInfo) String() string
type MediateKXRequest ¶ added in v0.1.5
type MediateKXRequest struct { // mediator is the nick or hex ID of the mediator user (which must already be // KX'd with). Mediator string `protobuf:"bytes,1,opt,name=mediator,proto3" json:"mediator,omitempty"` // target is the hex ID of the target user to KX with. Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` // contains filtered or unexported fields }
MediateKXRequest is the request to perform a transitive KX with a given user.
func (*MediateKXRequest) Descriptor
deprecated
added in
v0.1.5
func (*MediateKXRequest) Descriptor() ([]byte, []int)
Deprecated: Use MediateKXRequest.ProtoReflect.Descriptor instead.
func (*MediateKXRequest) GetMediator ¶ added in v0.1.5
func (x *MediateKXRequest) GetMediator() string
func (*MediateKXRequest) GetTarget ¶ added in v0.1.5
func (x *MediateKXRequest) GetTarget() string
func (*MediateKXRequest) ProtoMessage ¶ added in v0.1.5
func (*MediateKXRequest) ProtoMessage()
func (*MediateKXRequest) ProtoReflect ¶ added in v0.1.5
func (x *MediateKXRequest) ProtoReflect() protoreflect.Message
func (*MediateKXRequest) Reset ¶ added in v0.1.5
func (x *MediateKXRequest) Reset()
func (*MediateKXRequest) String ¶ added in v0.1.5
func (x *MediateKXRequest) String() string
type MediateKXResponse ¶ added in v0.1.5
type MediateKXResponse struct {
// contains filtered or unexported fields
}
MediateKXResponse is the response to a mediate KX request.
func (*MediateKXResponse) Descriptor
deprecated
added in
v0.1.5
func (*MediateKXResponse) Descriptor() ([]byte, []int)
Deprecated: Use MediateKXResponse.ProtoReflect.Descriptor instead.
func (*MediateKXResponse) ProtoMessage ¶ added in v0.1.5
func (*MediateKXResponse) ProtoMessage()
func (*MediateKXResponse) ProtoReflect ¶ added in v0.1.5
func (x *MediateKXResponse) ProtoReflect() protoreflect.Message
func (*MediateKXResponse) Reset ¶ added in v0.1.5
func (x *MediateKXResponse) Reset()
func (*MediateKXResponse) String ¶ added in v0.1.5
func (x *MediateKXResponse) String() string
type MessageMode ¶
type MessageMode int32
const ( // MESSAGE_MODE_NORMAL is the standard mode for messages. MessageMode_MESSAGE_MODE_NORMAL MessageMode = 0 // MESSAGE_MODE_ME are messages sent in the passive voice (i.e. with /me). MessageMode_MESSAGE_MODE_ME MessageMode = 1 )
func (MessageMode) Descriptor ¶
func (MessageMode) Descriptor() protoreflect.EnumDescriptor
func (MessageMode) Enum ¶
func (x MessageMode) Enum() *MessageMode
func (MessageMode) EnumDescriptor
deprecated
func (MessageMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use MessageMode.Descriptor instead.
func (MessageMode) Number ¶
func (x MessageMode) Number() protoreflect.EnumNumber
func (MessageMode) String ¶
func (x MessageMode) String() string
func (MessageMode) Type ¶
func (MessageMode) Type() protoreflect.EnumType
type MethodDefn ¶
type MethodDefn struct { NewRequest func() proto.Message NewResponse func() proto.Message RequestDefn func() protoreflect.MessageDescriptor ResponseDefn func() protoreflect.MessageDescriptor ServerHandler func(x interface{}, ctx context.Context, request, response proto.Message) error ServerStreamHandler func(x interface{}, ctx context.Context, request proto.Message, stream ServerStream) error ClientHandler func(conn ClientConn, ctx context.Context, request, response proto.Message) error ClientStreamHandler func(conn ClientConn, ctx context.Context, request proto.Message) (ClientStream, error) Help string IsStreaming bool }
MethodDefn tracks information about an RPC method.
type OOBPublicIdentityInvite ¶ added in v0.1.6
type OOBPublicIdentityInvite struct { // public is the public identity of the inviter. Public *PublicIdentity `protobuf:"bytes,1,opt,name=public,proto3" json:"public,omitempty"` // initial_rendezvous is the initial random RV where key exchange will happen. InitialRendezvous []byte `protobuf:"bytes,2,opt,name=initial_rendezvous,json=initialrendezvous,proto3" json:"initial_rendezvous,omitempty"` // reset_rendezvous is the inviter's reset RV in case of ratchet reset actions. ResetRendezvous []byte `protobuf:"bytes,3,opt,name=reset_rendezvous,json=resetrendezvous,proto3" json:"reset_rendezvous,omitempty"` // contains filtered or unexported fields }
OOBPublicIdentityInvite is an out-of-band invite to perform a KX.
func (*OOBPublicIdentityInvite) Descriptor
deprecated
added in
v0.1.6
func (*OOBPublicIdentityInvite) Descriptor() ([]byte, []int)
Deprecated: Use OOBPublicIdentityInvite.ProtoReflect.Descriptor instead.
func (*OOBPublicIdentityInvite) GetInitialRendezvous ¶ added in v0.1.6
func (x *OOBPublicIdentityInvite) GetInitialRendezvous() []byte
func (*OOBPublicIdentityInvite) GetPublic ¶ added in v0.1.6
func (x *OOBPublicIdentityInvite) GetPublic() *PublicIdentity
func (*OOBPublicIdentityInvite) GetResetRendezvous ¶ added in v0.1.6
func (x *OOBPublicIdentityInvite) GetResetRendezvous() []byte
func (*OOBPublicIdentityInvite) ProtoMessage ¶ added in v0.1.6
func (*OOBPublicIdentityInvite) ProtoMessage()
func (*OOBPublicIdentityInvite) ProtoReflect ¶ added in v0.1.6
func (x *OOBPublicIdentityInvite) ProtoReflect() protoreflect.Message
func (*OOBPublicIdentityInvite) Reset ¶ added in v0.1.6
func (x *OOBPublicIdentityInvite) Reset()
func (*OOBPublicIdentityInvite) String ¶ added in v0.1.6
func (x *OOBPublicIdentityInvite) String() string
type PMRequest ¶
type PMRequest struct { // user is either the nick, alias or an hex-encoded user ID of the destination. User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // msg is the message to be sent. Msg *RMPrivateMessage `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` // contains filtered or unexported fields }
PMRequest is a request to send a new private message.
func (*PMRequest) Descriptor
deprecated
func (*PMRequest) GetMsg ¶
func (x *PMRequest) GetMsg() *RMPrivateMessage
func (*PMRequest) ProtoMessage ¶
func (*PMRequest) ProtoMessage()
func (*PMRequest) ProtoReflect ¶
func (x *PMRequest) ProtoReflect() protoreflect.Message
type PMResponse ¶
type PMResponse struct {
// contains filtered or unexported fields
}
PMResponse is the response of the client for a new message.
func (*PMResponse) Descriptor
deprecated
func (*PMResponse) Descriptor() ([]byte, []int)
Deprecated: Use PMResponse.ProtoReflect.Descriptor instead.
func (*PMResponse) ProtoMessage ¶
func (*PMResponse) ProtoMessage()
func (*PMResponse) ProtoReflect ¶
func (x *PMResponse) ProtoReflect() protoreflect.Message
func (*PMResponse) Reset ¶
func (x *PMResponse) Reset()
func (*PMResponse) String ¶
func (x *PMResponse) String() string
type PMStreamRequest ¶
type PMStreamRequest struct { // unacked_from specifies to the server the sequence_id of the last processed // PM. PMs received by the server that have a higher sequence_id will be // streamed back to the client. UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"` // contains filtered or unexported fields }
PMStreamRequest is the request for a new private message reception stream.
func (*PMStreamRequest) Descriptor
deprecated
func (*PMStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use PMStreamRequest.ProtoReflect.Descriptor instead.
func (*PMStreamRequest) GetUnackedFrom ¶
func (x *PMStreamRequest) GetUnackedFrom() uint64
func (*PMStreamRequest) ProtoMessage ¶
func (*PMStreamRequest) ProtoMessage()
func (*PMStreamRequest) ProtoReflect ¶
func (x *PMStreamRequest) ProtoReflect() protoreflect.Message
func (*PMStreamRequest) Reset ¶
func (x *PMStreamRequest) Reset()
func (*PMStreamRequest) String ¶
func (x *PMStreamRequest) String() string
type PaymentsServiceClient ¶
type PaymentsServiceClient interface { // TipUser attempts to send a tip to a user. The user must be or come online // for this to complete. TipUser(ctx context.Context, in *TipUserRequest, out *TipUserResponse) error }
PaymentsServiceClient is the client API for PaymentsService service.
func NewPaymentsServiceClient ¶
func NewPaymentsServiceClient(c ClientConn) PaymentsServiceClient
type PaymentsServiceServer ¶
type PaymentsServiceServer interface { // TipUser attempts to send a tip to a user. The user must be or come online // for this to complete. TipUser(context.Context, *TipUserRequest, *TipUserResponse) error }
PaymentsServiceServer is the server API for PaymentsService service.
type PostMetadata ¶
type PostMetadata struct { // version defines the available fields within attributes. Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` // attributes defines the available post attributes. Attributes map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
PostMetadata is the network-level post data.
func (*PostMetadata) Descriptor
deprecated
func (*PostMetadata) Descriptor() ([]byte, []int)
Deprecated: Use PostMetadata.ProtoReflect.Descriptor instead.
func (*PostMetadata) GetAttributes ¶
func (x *PostMetadata) GetAttributes() map[string]string
func (*PostMetadata) GetVersion ¶
func (x *PostMetadata) GetVersion() uint64
func (*PostMetadata) ProtoMessage ¶
func (*PostMetadata) ProtoMessage()
func (*PostMetadata) ProtoReflect ¶
func (x *PostMetadata) ProtoReflect() protoreflect.Message
func (*PostMetadata) Reset ¶
func (x *PostMetadata) Reset()
func (*PostMetadata) String ¶
func (x *PostMetadata) String() string
type PostMetadataStatus ¶
type PostMetadataStatus struct { // version defines the available fields within attributes. Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` // from is the UID of the original status creator. From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` // link is the ID of the post. Link string `protobuf:"bytes,3,opt,name=link,proto3" json:"link,omitempty"` // attributes is the list of post update attributes. Attributes map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
PostMetadataStatus is the network-level post status update data.
func (*PostMetadataStatus) Descriptor
deprecated
func (*PostMetadataStatus) Descriptor() ([]byte, []int)
Deprecated: Use PostMetadataStatus.ProtoReflect.Descriptor instead.
func (*PostMetadataStatus) GetAttributes ¶
func (x *PostMetadataStatus) GetAttributes() map[string]string
func (*PostMetadataStatus) GetFrom ¶
func (x *PostMetadataStatus) GetFrom() string
func (*PostMetadataStatus) GetLink ¶
func (x *PostMetadataStatus) GetLink() string
func (*PostMetadataStatus) GetVersion ¶
func (x *PostMetadataStatus) GetVersion() uint64
func (*PostMetadataStatus) ProtoMessage ¶
func (*PostMetadataStatus) ProtoMessage()
func (*PostMetadataStatus) ProtoReflect ¶
func (x *PostMetadataStatus) ProtoReflect() protoreflect.Message
func (*PostMetadataStatus) Reset ¶
func (x *PostMetadataStatus) Reset()
func (*PostMetadataStatus) String ¶
func (x *PostMetadataStatus) String() string
type PostSummary ¶
type PostSummary struct { // id is the post ID (hash of the post metadata). Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // from is the id of the relayer of the post (who the local client received // the post from). From []byte `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` // author_id is the id of the author of the post. AuthorId []byte `protobuf:"bytes,3,opt,name=author_id,json=authorId,proto3" json:"author_id,omitempty"` // author_nick is the reported nick of the author of the post. AuthorNick string `protobuf:"bytes,4,opt,name=author_nick,json=authorNick,proto3" json:"author_nick,omitempty"` // date is the unix timestamp of the post. Date int64 `protobuf:"varint,5,opt,name=date,proto3" json:"date,omitempty"` // last_status_ts is the timestamp of the last recorded status update of the // post. LastStatusTs int64 `protobuf:"varint,6,opt,name=last_status_ts,json=lastStatusTs,proto3" json:"last_status_ts,omitempty"` // title is either the included or suggested title of the post. Title string `protobuf:"bytes,7,opt,name=title,proto3" json:"title,omitempty"` // contains filtered or unexported fields }
PostSummary is the summary information about a post.
func (*PostSummary) Descriptor
deprecated
func (*PostSummary) Descriptor() ([]byte, []int)
Deprecated: Use PostSummary.ProtoReflect.Descriptor instead.
func (*PostSummary) GetAuthorId ¶
func (x *PostSummary) GetAuthorId() []byte
func (*PostSummary) GetAuthorNick ¶
func (x *PostSummary) GetAuthorNick() string
func (*PostSummary) GetDate ¶
func (x *PostSummary) GetDate() int64
func (*PostSummary) GetFrom ¶
func (x *PostSummary) GetFrom() []byte
func (*PostSummary) GetId ¶
func (x *PostSummary) GetId() []byte
func (*PostSummary) GetLastStatusTs ¶
func (x *PostSummary) GetLastStatusTs() int64
func (*PostSummary) GetTitle ¶
func (x *PostSummary) GetTitle() string
func (*PostSummary) ProtoMessage ¶
func (*PostSummary) ProtoMessage()
func (*PostSummary) ProtoReflect ¶
func (x *PostSummary) ProtoReflect() protoreflect.Message
func (*PostSummary) Reset ¶
func (x *PostSummary) Reset()
func (*PostSummary) String ¶
func (x *PostSummary) String() string
type PostsServiceClient ¶
type PostsServiceClient interface { // SubscribeToPosts makes the local client subscribe to a remote user's posts. SubscribeToPosts(ctx context.Context, in *SubscribeToPostsRequest, out *SubscribeToPostsResponse) error // UnsubscribeToPosts makes the local client unsubscribe from a remote user's posts. UnsubscribeToPosts(ctx context.Context, in *UnsubscribeToPostsRequest, out *UnsubscribeToPostsResponse) error // PostsStream creates a stream that receives updates about posts received // from remote users the local client is subscribed to. PostsStream(ctx context.Context, in *PostsStreamRequest) (PostsService_PostsStreamClient, error) // AckReceivedPost acknowledges posts received up to a given sequence_id have // been processed. AckReceivedPost(ctx context.Context, in *AckRequest, out *AckResponse) error // PostsStatusStream creates a stream that receives updates about post status // events (comments, replies, etc). PostsStatusStream(ctx context.Context, in *PostsStatusStreamRequest) (PostsService_PostsStatusStreamClient, error) // AckReceivedPostStatus acknowledges post status received up to a given // sequence_id have been processed. AckReceivedPostStatus(ctx context.Context, in *AckRequest, out *AckResponse) error }
PostsServiceClient is the client API for PostsService service.
func NewPostsServiceClient ¶
func NewPostsServiceClient(c ClientConn) PostsServiceClient
type PostsServiceServer ¶
type PostsServiceServer interface { // SubscribeToPosts makes the local client subscribe to a remote user's posts. SubscribeToPosts(context.Context, *SubscribeToPostsRequest, *SubscribeToPostsResponse) error // UnsubscribeToPosts makes the local client unsubscribe from a remote user's posts. UnsubscribeToPosts(context.Context, *UnsubscribeToPostsRequest, *UnsubscribeToPostsResponse) error // PostsStream creates a stream that receives updates about posts received // from remote users the local client is subscribed to. PostsStream(context.Context, *PostsStreamRequest, PostsService_PostsStreamServer) error // AckReceivedPost acknowledges posts received up to a given sequence_id have // been processed. AckReceivedPost(context.Context, *AckRequest, *AckResponse) error // PostsStatusStream creates a stream that receives updates about post status // events (comments, replies, etc). PostsStatusStream(context.Context, *PostsStatusStreamRequest, PostsService_PostsStatusStreamServer) error // AckReceivedPostStatus acknowledges post status received up to a given // sequence_id have been processed. AckReceivedPostStatus(context.Context, *AckRequest, *AckResponse) error }
PostsServiceServer is the server API for PostsService service.
type PostsService_PostsStatusStreamClient ¶
type PostsService_PostsStatusStreamClient interface {
Recv(*ReceivedPostStatus) error
}
type PostsService_PostsStatusStreamServer ¶
type PostsService_PostsStatusStreamServer interface {
Send(m *ReceivedPostStatus) error
}
type PostsService_PostsStreamClient ¶
type PostsService_PostsStreamClient interface {
Recv(*ReceivedPost) error
}
type PostsService_PostsStreamServer ¶
type PostsService_PostsStreamServer interface {
Send(m *ReceivedPost) error
}
type PostsStatusStreamRequest ¶
type PostsStatusStreamRequest struct { // unacked_from specifies to the server the sequence_id of the last processed // Post Status. Post Status received by the server that have a higher // sequence_id will be streamed back to the client. UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"` // contains filtered or unexported fields }
PostsStatusStreamRequest is a request to establish a stream that receives post status updates received by the local client.
func (*PostsStatusStreamRequest) Descriptor
deprecated
func (*PostsStatusStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use PostsStatusStreamRequest.ProtoReflect.Descriptor instead.
func (*PostsStatusStreamRequest) GetUnackedFrom ¶
func (x *PostsStatusStreamRequest) GetUnackedFrom() uint64
func (*PostsStatusStreamRequest) ProtoMessage ¶
func (*PostsStatusStreamRequest) ProtoMessage()
func (*PostsStatusStreamRequest) ProtoReflect ¶
func (x *PostsStatusStreamRequest) ProtoReflect() protoreflect.Message
func (*PostsStatusStreamRequest) Reset ¶
func (x *PostsStatusStreamRequest) Reset()
func (*PostsStatusStreamRequest) String ¶
func (x *PostsStatusStreamRequest) String() string
type PostsStreamRequest ¶
type PostsStreamRequest struct { // unacked_from specifies to the server the sequence_id of the last processed // post. Posts received by the server that have a higher sequence_id will be // streamed back to the client. UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"` // contains filtered or unexported fields }
PostsStreamRequest is the request to establish a stream of received post events.
func (*PostsStreamRequest) Descriptor
deprecated
func (*PostsStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use PostsStreamRequest.ProtoReflect.Descriptor instead.
func (*PostsStreamRequest) GetUnackedFrom ¶
func (x *PostsStreamRequest) GetUnackedFrom() uint64
func (*PostsStreamRequest) ProtoMessage ¶
func (*PostsStreamRequest) ProtoMessage()
func (*PostsStreamRequest) ProtoReflect ¶
func (x *PostsStreamRequest) ProtoReflect() protoreflect.Message
func (*PostsStreamRequest) Reset ¶
func (x *PostsStreamRequest) Reset()
func (*PostsStreamRequest) String ¶
func (x *PostsStreamRequest) String() string
type PublicIdentity ¶ added in v0.1.6
type PublicIdentity struct { // name is the name of the user. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // nick is the short name/alias of the user. Nick string `protobuf:"bytes,2,opt,name=nick,proto3" json:"nick,omitempty"` // sig_key is the signature key used to authenticate messages from the user. SigKey []byte `protobuf:"bytes,3,opt,name=sig_key,json=sigKey,proto3" json:"sig_key,omitempty"` // key is the NTRU public key of the user. Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"` // identity is the public ID of the user. Identity []byte `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"` // digest is a hash of the user's public information. Digest []byte `protobuf:"bytes,6,opt,name=digest,proto3" json:"digest,omitempty"` // signature is a signature of the user's public information. Signature []byte `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
PublicIdentity is the lowlevel public identity.
func (*PublicIdentity) Descriptor
deprecated
added in
v0.1.6
func (*PublicIdentity) Descriptor() ([]byte, []int)
Deprecated: Use PublicIdentity.ProtoReflect.Descriptor instead.
func (*PublicIdentity) GetDigest ¶ added in v0.1.6
func (x *PublicIdentity) GetDigest() []byte
func (*PublicIdentity) GetIdentity ¶ added in v0.1.6
func (x *PublicIdentity) GetIdentity() []byte
func (*PublicIdentity) GetKey ¶ added in v0.1.6
func (x *PublicIdentity) GetKey() []byte
func (*PublicIdentity) GetName ¶ added in v0.1.6
func (x *PublicIdentity) GetName() string
func (*PublicIdentity) GetNick ¶ added in v0.1.6
func (x *PublicIdentity) GetNick() string
func (*PublicIdentity) GetSigKey ¶ added in v0.1.6
func (x *PublicIdentity) GetSigKey() []byte
func (*PublicIdentity) GetSignature ¶ added in v0.1.6
func (x *PublicIdentity) GetSignature() []byte
func (*PublicIdentity) ProtoMessage ¶ added in v0.1.6
func (*PublicIdentity) ProtoMessage()
func (*PublicIdentity) ProtoReflect ¶ added in v0.1.6
func (x *PublicIdentity) ProtoReflect() protoreflect.Message
func (*PublicIdentity) Reset ¶ added in v0.1.6
func (x *PublicIdentity) Reset()
func (*PublicIdentity) String ¶ added in v0.1.6
func (x *PublicIdentity) String() string
type RMGroupInvite ¶ added in v0.1.6
type RMGroupInvite struct { // id is the ID of the GC. Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // name is the name of the GC. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // token is a random number that must be sent back by the invitee to the inviter. Token uint64 `protobuf:"varint,3,opt,name=token,proto3" json:"token,omitempty"` // description is a description of the GC. Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` // expires is a timestamp for when the invitation expires. Expires int64 `protobuf:"varint,5,opt,name=expires,proto3" json:"expires,omitempty"` // version is the version of the current definition of the GC. Version uint32 `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
RMGroupInvite is the information about an invite to join a GC.
func (*RMGroupInvite) Descriptor
deprecated
added in
v0.1.6
func (*RMGroupInvite) Descriptor() ([]byte, []int)
Deprecated: Use RMGroupInvite.ProtoReflect.Descriptor instead.
func (*RMGroupInvite) GetDescription ¶ added in v0.1.6
func (x *RMGroupInvite) GetDescription() string
func (*RMGroupInvite) GetExpires ¶ added in v0.1.6
func (x *RMGroupInvite) GetExpires() int64
func (*RMGroupInvite) GetId ¶ added in v0.1.6
func (x *RMGroupInvite) GetId() []byte
func (*RMGroupInvite) GetName ¶ added in v0.1.6
func (x *RMGroupInvite) GetName() string
func (*RMGroupInvite) GetToken ¶ added in v0.1.6
func (x *RMGroupInvite) GetToken() uint64
func (*RMGroupInvite) GetVersion ¶ added in v0.1.6
func (x *RMGroupInvite) GetVersion() uint32
func (*RMGroupInvite) ProtoMessage ¶ added in v0.1.6
func (*RMGroupInvite) ProtoMessage()
func (*RMGroupInvite) ProtoReflect ¶ added in v0.1.6
func (x *RMGroupInvite) ProtoReflect() protoreflect.Message
func (*RMGroupInvite) Reset ¶ added in v0.1.6
func (x *RMGroupInvite) Reset()
func (*RMGroupInvite) String ¶ added in v0.1.6
func (x *RMGroupInvite) String() string
type RMGroupList ¶ added in v0.1.6
type RMGroupList struct { // id is the ID of the GC. Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // name is the name of the GC. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // generation is a monotonically increasing count of GC changes. Generation uint64 `protobuf:"varint,3,opt,name=generation,proto3" json:"generation,omitempty"` // timestamp is the timestamp for the last modification of the GC defintions. Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // version is the GC rules version. Version uint32 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"` // members is the list of user IDs that are in the GC. Members [][]byte `protobuf:"bytes,6,rep,name=members,proto3" json:"members,omitempty"` // extra_admins is the list of user IDs that are additional admins of the GC. ExtraAdmins [][]byte `protobuf:"bytes,7,rep,name=extra_admins,proto3" json:"extra_admins,omitempty"` // contains filtered or unexported fields }
RMGroupList is the full definition of a GC.
func (*RMGroupList) Descriptor
deprecated
added in
v0.1.6
func (*RMGroupList) Descriptor() ([]byte, []int)
Deprecated: Use RMGroupList.ProtoReflect.Descriptor instead.
func (*RMGroupList) GetExtraAdmins ¶ added in v0.1.6
func (x *RMGroupList) GetExtraAdmins() [][]byte
func (*RMGroupList) GetGeneration ¶ added in v0.1.6
func (x *RMGroupList) GetGeneration() uint64
func (*RMGroupList) GetId ¶ added in v0.1.6
func (x *RMGroupList) GetId() []byte
func (*RMGroupList) GetMembers ¶ added in v0.1.6
func (x *RMGroupList) GetMembers() [][]byte
func (*RMGroupList) GetName ¶ added in v0.1.6
func (x *RMGroupList) GetName() string
func (*RMGroupList) GetTimestamp ¶ added in v0.1.6
func (x *RMGroupList) GetTimestamp() int64
func (*RMGroupList) GetVersion ¶ added in v0.1.6
func (x *RMGroupList) GetVersion() uint32
func (*RMGroupList) ProtoMessage ¶ added in v0.1.6
func (*RMGroupList) ProtoMessage()
func (*RMGroupList) ProtoReflect ¶ added in v0.1.6
func (x *RMGroupList) ProtoReflect() protoreflect.Message
func (*RMGroupList) Reset ¶ added in v0.1.6
func (x *RMGroupList) Reset()
func (*RMGroupList) String ¶ added in v0.1.6
func (x *RMGroupList) String() string
type RMGroupMessage ¶
type RMGroupMessage struct { // id is the group chat id where the message was sent. Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // generation is the internal generation of the group chat metadata when the // sender sent this message. Generation uint64 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"` // message is the textual content. Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` // mode is the mode of the message. Mode MessageMode `protobuf:"varint,4,opt,name=mode,proto3,enum=MessageMode" json:"mode,omitempty"` // contains filtered or unexported fields }
RMGroupMessage is the network-level routed group message.
func (*RMGroupMessage) Descriptor
deprecated
func (*RMGroupMessage) Descriptor() ([]byte, []int)
Deprecated: Use RMGroupMessage.ProtoReflect.Descriptor instead.
func (*RMGroupMessage) GetGeneration ¶
func (x *RMGroupMessage) GetGeneration() uint64
func (*RMGroupMessage) GetId ¶
func (x *RMGroupMessage) GetId() []byte
func (*RMGroupMessage) GetMessage ¶
func (x *RMGroupMessage) GetMessage() string
func (*RMGroupMessage) GetMode ¶
func (x *RMGroupMessage) GetMode() MessageMode
func (*RMGroupMessage) ProtoMessage ¶
func (*RMGroupMessage) ProtoMessage()
func (*RMGroupMessage) ProtoReflect ¶
func (x *RMGroupMessage) ProtoReflect() protoreflect.Message
func (*RMGroupMessage) Reset ¶
func (x *RMGroupMessage) Reset()
func (*RMGroupMessage) String ¶
func (x *RMGroupMessage) String() string
type RMPrivateMessage ¶
type RMPrivateMessage struct { // message is the private message payload. Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // mode is the message mode. Mode MessageMode `protobuf:"varint,2,opt,name=mode,proto3,enum=MessageMode" json:"mode,omitempty"` // contains filtered or unexported fields }
RMPrivateMessage is the network-level routed private message.
func (*RMPrivateMessage) Descriptor
deprecated
func (*RMPrivateMessage) Descriptor() ([]byte, []int)
Deprecated: Use RMPrivateMessage.ProtoReflect.Descriptor instead.
func (*RMPrivateMessage) GetMessage ¶
func (x *RMPrivateMessage) GetMessage() string
func (*RMPrivateMessage) GetMode ¶
func (x *RMPrivateMessage) GetMode() MessageMode
func (*RMPrivateMessage) ProtoMessage ¶
func (*RMPrivateMessage) ProtoMessage()
func (*RMPrivateMessage) ProtoReflect ¶
func (x *RMPrivateMessage) ProtoReflect() protoreflect.Message
func (*RMPrivateMessage) Reset ¶
func (x *RMPrivateMessage) Reset()
func (*RMPrivateMessage) String ¶
func (x *RMPrivateMessage) String() string
type ReceivedGCInvite ¶ added in v0.1.6
type ReceivedGCInvite struct { // sequence_id is an opaque sequential ID. SequenceId uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // inviter_uid is the UID of the user that sent the invitation. InviterUid []byte `protobuf:"bytes,2,opt,name=inviter_uid,json=inviterUid,proto3" json:"inviter_uid,omitempty"` // inviter_nick is the nick of the user that sent the invitation. InviterNick string `protobuf:"bytes,3,opt,name=inviter_nick,json=inviterNick,proto3" json:"inviter_nick,omitempty"` // invite_id is the unique invite ID that must be spcecified when accepting // the invitation. InviteId uint64 `protobuf:"varint,4,opt,name=invite_id,json=inviteId,proto3" json:"invite_id,omitempty"` // invite is the invite information. Invite *RMGroupInvite `protobuf:"bytes,5,opt,name=invite,proto3" json:"invite,omitempty"` // contains filtered or unexported fields }
ReceivedGCInvite is the event sent when an invitation to join a GC is received.
func (*ReceivedGCInvite) Descriptor
deprecated
added in
v0.1.6
func (*ReceivedGCInvite) Descriptor() ([]byte, []int)
Deprecated: Use ReceivedGCInvite.ProtoReflect.Descriptor instead.
func (*ReceivedGCInvite) GetInvite ¶ added in v0.1.6
func (x *ReceivedGCInvite) GetInvite() *RMGroupInvite
func (*ReceivedGCInvite) GetInviteId ¶ added in v0.1.6
func (x *ReceivedGCInvite) GetInviteId() uint64
func (*ReceivedGCInvite) GetInviterNick ¶ added in v0.1.6
func (x *ReceivedGCInvite) GetInviterNick() string
func (*ReceivedGCInvite) GetInviterUid ¶ added in v0.1.6
func (x *ReceivedGCInvite) GetInviterUid() []byte
func (*ReceivedGCInvite) GetSequenceId ¶ added in v0.1.6
func (x *ReceivedGCInvite) GetSequenceId() uint64
func (*ReceivedGCInvite) ProtoMessage ¶ added in v0.1.6
func (*ReceivedGCInvite) ProtoMessage()
func (*ReceivedGCInvite) ProtoReflect ¶ added in v0.1.6
func (x *ReceivedGCInvite) ProtoReflect() protoreflect.Message
func (*ReceivedGCInvite) Reset ¶ added in v0.1.6
func (x *ReceivedGCInvite) Reset()
func (*ReceivedGCInvite) String ¶ added in v0.1.6
func (x *ReceivedGCInvite) String() string
type ReceivedGCInvitesRequest ¶ added in v0.1.6
type ReceivedGCInvitesRequest struct { // unacked_from specifies to the server the sequence_id of the last received // GC invite. Invites received by the server that have a higher sequence_id // will be streamed back to the client. UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"` // contains filtered or unexported fields }
ReceivedGCInvitesRequest is the request to start receiving GC invite events.
func (*ReceivedGCInvitesRequest) Descriptor
deprecated
added in
v0.1.6
func (*ReceivedGCInvitesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReceivedGCInvitesRequest.ProtoReflect.Descriptor instead.
func (*ReceivedGCInvitesRequest) GetUnackedFrom ¶ added in v0.1.6
func (x *ReceivedGCInvitesRequest) GetUnackedFrom() uint64
func (*ReceivedGCInvitesRequest) ProtoMessage ¶ added in v0.1.6
func (*ReceivedGCInvitesRequest) ProtoMessage()
func (*ReceivedGCInvitesRequest) ProtoReflect ¶ added in v0.1.6
func (x *ReceivedGCInvitesRequest) ProtoReflect() protoreflect.Message
func (*ReceivedGCInvitesRequest) Reset ¶ added in v0.1.6
func (x *ReceivedGCInvitesRequest) Reset()
func (*ReceivedGCInvitesRequest) String ¶ added in v0.1.6
func (x *ReceivedGCInvitesRequest) String() string
type ReceivedPM ¶
type ReceivedPM struct { // uid is the source user ID in raw format. Uid []byte `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // nick is the source's nick or alias. Nick string `protobuf:"bytes,2,opt,name=nick,proto3" json:"nick,omitempty"` // msg is the received message payload. Msg *RMPrivateMessage `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"` // timestamp_ms is the timestamp from unix epoch with millisecond precision. TimestampMs int64 `protobuf:"varint,4,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"` // sequence_id is an opaque sequential ID. SequenceId uint64 `protobuf:"varint,5,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // contains filtered or unexported fields }
ReceivedPM is a private message received by the client.
func (*ReceivedPM) Descriptor
deprecated
func (*ReceivedPM) Descriptor() ([]byte, []int)
Deprecated: Use ReceivedPM.ProtoReflect.Descriptor instead.
func (*ReceivedPM) GetMsg ¶
func (x *ReceivedPM) GetMsg() *RMPrivateMessage
func (*ReceivedPM) GetNick ¶
func (x *ReceivedPM) GetNick() string
func (*ReceivedPM) GetSequenceId ¶
func (x *ReceivedPM) GetSequenceId() uint64
func (*ReceivedPM) GetTimestampMs ¶
func (x *ReceivedPM) GetTimestampMs() int64
func (*ReceivedPM) GetUid ¶
func (x *ReceivedPM) GetUid() []byte
func (*ReceivedPM) ProtoMessage ¶
func (*ReceivedPM) ProtoMessage()
func (*ReceivedPM) ProtoReflect ¶
func (x *ReceivedPM) ProtoReflect() protoreflect.Message
func (*ReceivedPM) Reset ¶
func (x *ReceivedPM) Reset()
func (*ReceivedPM) String ¶
func (x *ReceivedPM) String() string
type ReceivedPost ¶
type ReceivedPost struct { // sequence_id is an opaque sequential ID. SequenceId uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // relayer_id is the id of the user we received the post from (may not be the // same as the author). RelayerId []byte `protobuf:"bytes,2,opt,name=relayer_id,json=relayerId,proto3" json:"relayer_id,omitempty"` // summary is the summary information about the post. Summary *PostSummary `protobuf:"bytes,3,opt,name=summary,proto3" json:"summary,omitempty"` // post is the full post data. Post *PostMetadata `protobuf:"bytes,4,opt,name=post,proto3" json:"post,omitempty"` // contains filtered or unexported fields }
ReceivedPost is a post received by the local client.
func (*ReceivedPost) Descriptor
deprecated
func (*ReceivedPost) Descriptor() ([]byte, []int)
Deprecated: Use ReceivedPost.ProtoReflect.Descriptor instead.
func (*ReceivedPost) GetPost ¶
func (x *ReceivedPost) GetPost() *PostMetadata
func (*ReceivedPost) GetRelayerId ¶
func (x *ReceivedPost) GetRelayerId() []byte
func (*ReceivedPost) GetSequenceId ¶
func (x *ReceivedPost) GetSequenceId() uint64
func (*ReceivedPost) GetSummary ¶
func (x *ReceivedPost) GetSummary() *PostSummary
func (*ReceivedPost) ProtoMessage ¶
func (*ReceivedPost) ProtoMessage()
func (*ReceivedPost) ProtoReflect ¶
func (x *ReceivedPost) ProtoReflect() protoreflect.Message
func (*ReceivedPost) Reset ¶
func (x *ReceivedPost) Reset()
func (*ReceivedPost) String ¶
func (x *ReceivedPost) String() string
type ReceivedPostStatus ¶
type ReceivedPostStatus struct { // sequence_id is an opaque sequential ID. SequenceId uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` // relayer_id is the id of the sender of the client that sent the update. RelayerId []byte `protobuf:"bytes,2,opt,name=relayer_id,json=relayerId,proto3" json:"relayer_id,omitempty"` // post_id is the id of the corresponding post. PostId []byte `protobuf:"bytes,3,opt,name=post_id,json=postId,proto3" json:"post_id,omitempty"` // status_from is the original author of the status. StatusFrom []byte `protobuf:"bytes,4,opt,name=status_from,json=statusFrom,proto3" json:"status_from,omitempty"` // status is the full status data. Status *PostMetadataStatus `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"` // status_from_nick is the nick of the original author of the status. StatusFromNick string `protobuf:"bytes,6,opt,name=status_from_nick,json=statusFromNick,proto3" json:"status_from_nick,omitempty"` // contains filtered or unexported fields }
ReceivedPostStatus is a post status update received by the local client.
func (*ReceivedPostStatus) Descriptor
deprecated
func (*ReceivedPostStatus) Descriptor() ([]byte, []int)
Deprecated: Use ReceivedPostStatus.ProtoReflect.Descriptor instead.
func (*ReceivedPostStatus) GetPostId ¶
func (x *ReceivedPostStatus) GetPostId() []byte
func (*ReceivedPostStatus) GetRelayerId ¶
func (x *ReceivedPostStatus) GetRelayerId() []byte
func (*ReceivedPostStatus) GetSequenceId ¶
func (x *ReceivedPostStatus) GetSequenceId() uint64
func (*ReceivedPostStatus) GetStatus ¶
func (x *ReceivedPostStatus) GetStatus() *PostMetadataStatus
func (*ReceivedPostStatus) GetStatusFrom ¶
func (x *ReceivedPostStatus) GetStatusFrom() []byte
func (*ReceivedPostStatus) GetStatusFromNick ¶ added in v0.1.5
func (x *ReceivedPostStatus) GetStatusFromNick() string
func (*ReceivedPostStatus) ProtoMessage ¶
func (*ReceivedPostStatus) ProtoMessage()
func (*ReceivedPostStatus) ProtoReflect ¶
func (x *ReceivedPostStatus) ProtoReflect() protoreflect.Message
func (*ReceivedPostStatus) Reset ¶
func (x *ReceivedPostStatus) Reset()
func (*ReceivedPostStatus) String ¶
func (x *ReceivedPostStatus) String() string
type SendFileRequest ¶ added in v0.1.6
type SendFileRequest struct { // user is the hex-encoded ID of the user or its nick. User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // filename is the absolute path to the file. Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"` // contains filtered or unexported fields }
SendFileRequest is the request to send a file to a user.
func (*SendFileRequest) Descriptor
deprecated
added in
v0.1.6
func (*SendFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendFileRequest.ProtoReflect.Descriptor instead.
func (*SendFileRequest) GetFilename ¶ added in v0.1.6
func (x *SendFileRequest) GetFilename() string
func (*SendFileRequest) GetUser ¶ added in v0.1.6
func (x *SendFileRequest) GetUser() string
func (*SendFileRequest) ProtoMessage ¶ added in v0.1.6
func (*SendFileRequest) ProtoMessage()
func (*SendFileRequest) ProtoReflect ¶ added in v0.1.6
func (x *SendFileRequest) ProtoReflect() protoreflect.Message
func (*SendFileRequest) Reset ¶ added in v0.1.6
func (x *SendFileRequest) Reset()
func (*SendFileRequest) String ¶ added in v0.1.6
func (x *SendFileRequest) String() string
type SendFileResponse ¶ added in v0.1.6
type SendFileResponse struct {
// contains filtered or unexported fields
}
SendFileResponse is the response to sending a file to a user.
func (*SendFileResponse) Descriptor
deprecated
added in
v0.1.6
func (*SendFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use SendFileResponse.ProtoReflect.Descriptor instead.
func (*SendFileResponse) ProtoMessage ¶ added in v0.1.6
func (*SendFileResponse) ProtoMessage()
func (*SendFileResponse) ProtoReflect ¶ added in v0.1.6
func (x *SendFileResponse) ProtoReflect() protoreflect.Message
func (*SendFileResponse) Reset ¶ added in v0.1.6
func (x *SendFileResponse) Reset()
func (*SendFileResponse) String ¶ added in v0.1.6
func (x *SendFileResponse) String() string
type ServerStream ¶
ServerStream abstracts the necessary functions of a server-side stream.
type ServersMap ¶
type ServersMap struct {
// contains filtered or unexported fields
}
ServersMap is a concurent-safe map for services.
func (*ServersMap) Bind ¶
func (sm *ServersMap) Bind(name string, defn ServiceDefn, impl interface{})
Bind the service server to the specified name.
func (*ServersMap) SvcForMethod ¶
func (sm *ServersMap) SvcForMethod(method string) (*ServiceDefn, interface{}, *MethodDefn, error)
SvcForMethod return the service and method name given a Service.Method name.
type ServiceDefn ¶
type ServiceDefn struct { Name string Methods map[string]MethodDefn }
ServiceDefn tracks information about a service.
func ChatServiceDefn ¶
func ChatServiceDefn() ServiceDefn
func GCServiceDefn ¶ added in v0.1.6
func GCServiceDefn() ServiceDefn
func PaymentsServiceDefn ¶
func PaymentsServiceDefn() ServiceDefn
func PostsServiceDefn ¶
func PostsServiceDefn() ServiceDefn
func Services ¶
func Services() []ServiceDefn
Services returns the full list of service definitions defined in this package.
func VersionServiceDefn ¶
func VersionServiceDefn() ServiceDefn
type SubscribeToPostsRequest ¶
type SubscribeToPostsRequest struct { // user is the nick or hex-encoded ID of the user to subscribe to. User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
SubscribeToPostsRequest is a request to subscribe to a remote user's posts.
func (*SubscribeToPostsRequest) Descriptor
deprecated
func (*SubscribeToPostsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeToPostsRequest.ProtoReflect.Descriptor instead.
func (*SubscribeToPostsRequest) GetUser ¶
func (x *SubscribeToPostsRequest) GetUser() string
func (*SubscribeToPostsRequest) ProtoMessage ¶
func (*SubscribeToPostsRequest) ProtoMessage()
func (*SubscribeToPostsRequest) ProtoReflect ¶
func (x *SubscribeToPostsRequest) ProtoReflect() protoreflect.Message
func (*SubscribeToPostsRequest) Reset ¶
func (x *SubscribeToPostsRequest) Reset()
func (*SubscribeToPostsRequest) String ¶
func (x *SubscribeToPostsRequest) String() string
type SubscribeToPostsResponse ¶
type SubscribeToPostsResponse struct {
// contains filtered or unexported fields
}
SubscribeToPostsResponse is the response to subscribing to a remote user's posts.
func (*SubscribeToPostsResponse) Descriptor
deprecated
func (*SubscribeToPostsResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeToPostsResponse.ProtoReflect.Descriptor instead.
func (*SubscribeToPostsResponse) ProtoMessage ¶
func (*SubscribeToPostsResponse) ProtoMessage()
func (*SubscribeToPostsResponse) ProtoReflect ¶
func (x *SubscribeToPostsResponse) ProtoReflect() protoreflect.Message
func (*SubscribeToPostsResponse) Reset ¶
func (x *SubscribeToPostsResponse) Reset()
func (*SubscribeToPostsResponse) String ¶
func (x *SubscribeToPostsResponse) String() string
type TipUserRequest ¶
type TipUserRequest struct { // user is the remote user nick or hex-encoded ID. User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // dcr_amount is the DCR amount to send as tip. DcrAmount float64 `protobuf:"fixed64,2,opt,name=dcr_amount,json=dcrAmount,proto3" json:"dcr_amount,omitempty"` // contains filtered or unexported fields }
TipUserRequest is a request to tip a remote user.
func (*TipUserRequest) Descriptor
deprecated
func (*TipUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use TipUserRequest.ProtoReflect.Descriptor instead.
func (*TipUserRequest) GetDcrAmount ¶
func (x *TipUserRequest) GetDcrAmount() float64
func (*TipUserRequest) GetUser ¶
func (x *TipUserRequest) GetUser() string
func (*TipUserRequest) ProtoMessage ¶
func (*TipUserRequest) ProtoMessage()
func (*TipUserRequest) ProtoReflect ¶
func (x *TipUserRequest) ProtoReflect() protoreflect.Message
func (*TipUserRequest) Reset ¶
func (x *TipUserRequest) Reset()
func (*TipUserRequest) String ¶
func (x *TipUserRequest) String() string
type TipUserResponse ¶
type TipUserResponse struct {
// contains filtered or unexported fields
}
TipUserResponse is the response to a tip user request.
func (*TipUserResponse) Descriptor
deprecated
func (*TipUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use TipUserResponse.ProtoReflect.Descriptor instead.
func (*TipUserResponse) ProtoMessage ¶
func (*TipUserResponse) ProtoMessage()
func (*TipUserResponse) ProtoReflect ¶
func (x *TipUserResponse) ProtoReflect() protoreflect.Message
func (*TipUserResponse) Reset ¶
func (x *TipUserResponse) Reset()
func (*TipUserResponse) String ¶
func (x *TipUserResponse) String() string
type UnsubscribeToPostsRequest ¶
type UnsubscribeToPostsRequest struct { // user is the nick or hex-encoded ID of the user to unsubscribe from. User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
UnsubscribeToPostsRequest is a request to unsubscribe from a remote user's posts.
func (*UnsubscribeToPostsRequest) Descriptor
deprecated
func (*UnsubscribeToPostsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeToPostsRequest.ProtoReflect.Descriptor instead.
func (*UnsubscribeToPostsRequest) GetUser ¶
func (x *UnsubscribeToPostsRequest) GetUser() string
func (*UnsubscribeToPostsRequest) ProtoMessage ¶
func (*UnsubscribeToPostsRequest) ProtoMessage()
func (*UnsubscribeToPostsRequest) ProtoReflect ¶
func (x *UnsubscribeToPostsRequest) ProtoReflect() protoreflect.Message
func (*UnsubscribeToPostsRequest) Reset ¶
func (x *UnsubscribeToPostsRequest) Reset()
func (*UnsubscribeToPostsRequest) String ¶
func (x *UnsubscribeToPostsRequest) String() string
type UnsubscribeToPostsResponse ¶
type UnsubscribeToPostsResponse struct {
// contains filtered or unexported fields
}
UnsubscribeToPostsResponse is the response to an unsubscribe request.
func (*UnsubscribeToPostsResponse) Descriptor
deprecated
func (*UnsubscribeToPostsResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeToPostsResponse.ProtoReflect.Descriptor instead.
func (*UnsubscribeToPostsResponse) ProtoMessage ¶
func (*UnsubscribeToPostsResponse) ProtoMessage()
func (*UnsubscribeToPostsResponse) ProtoReflect ¶
func (x *UnsubscribeToPostsResponse) ProtoReflect() protoreflect.Message
func (*UnsubscribeToPostsResponse) Reset ¶
func (x *UnsubscribeToPostsResponse) Reset()
func (*UnsubscribeToPostsResponse) String ¶
func (x *UnsubscribeToPostsResponse) String() string
type UserAndNick ¶ added in v0.1.6
type UserAndNick struct { // uid is the unique user ID. Uid []byte `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // nick is the local alias or nick of the user. Nick string `protobuf:"bytes,2,opt,name=nick,proto3" json:"nick,omitempty"` // known flags whether the local client is KX'd with this user. Known bool `protobuf:"varint,3,opt,name=known,proto3" json:"known,omitempty"` // contains filtered or unexported fields }
UserAndNick groups users and nicks when used in lists.
func (*UserAndNick) Descriptor
deprecated
added in
v0.1.6
func (*UserAndNick) Descriptor() ([]byte, []int)
Deprecated: Use UserAndNick.ProtoReflect.Descriptor instead.
func (*UserAndNick) GetKnown ¶ added in v0.1.6
func (x *UserAndNick) GetKnown() bool
func (*UserAndNick) GetNick ¶ added in v0.1.6
func (x *UserAndNick) GetNick() string
func (*UserAndNick) GetUid ¶ added in v0.1.6
func (x *UserAndNick) GetUid() []byte
func (*UserAndNick) ProtoMessage ¶ added in v0.1.6
func (*UserAndNick) ProtoMessage()
func (*UserAndNick) ProtoReflect ¶ added in v0.1.6
func (x *UserAndNick) ProtoReflect() protoreflect.Message
func (*UserAndNick) Reset ¶ added in v0.1.6
func (x *UserAndNick) Reset()
func (*UserAndNick) String ¶ added in v0.1.6
func (x *UserAndNick) String() string
type VersionRequest ¶
type VersionRequest struct {
// contains filtered or unexported fields
}
func (*VersionRequest) Descriptor
deprecated
func (*VersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.
func (*VersionRequest) ProtoMessage ¶
func (*VersionRequest) ProtoMessage()
func (*VersionRequest) ProtoReflect ¶
func (x *VersionRequest) ProtoReflect() protoreflect.Message
func (*VersionRequest) Reset ¶
func (x *VersionRequest) Reset()
func (*VersionRequest) String ¶
func (x *VersionRequest) String() string
type VersionResponse ¶
type VersionResponse struct { // app_version is the version of the application. AppVersion string `protobuf:"bytes,1,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"` // go_runtime is the Go version the server was compiled with. GoRuntime string `protobuf:"bytes,2,opt,name=go_runtime,json=goRuntime,proto3" json:"go_runtime,omitempty"` // app_name is the name of the underlying app running the server. AppName string `protobuf:"bytes,3,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"` // contains filtered or unexported fields }
VersionResponse is the information about the running RPC server.
func (*VersionResponse) Descriptor
deprecated
func (*VersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.
func (*VersionResponse) GetAppName ¶
func (x *VersionResponse) GetAppName() string
func (*VersionResponse) GetAppVersion ¶
func (x *VersionResponse) GetAppVersion() string
func (*VersionResponse) GetGoRuntime ¶
func (x *VersionResponse) GetGoRuntime() string
func (*VersionResponse) ProtoMessage ¶
func (*VersionResponse) ProtoMessage()
func (*VersionResponse) ProtoReflect ¶
func (x *VersionResponse) ProtoReflect() protoreflect.Message
func (*VersionResponse) Reset ¶
func (x *VersionResponse) Reset()
func (*VersionResponse) String ¶
func (x *VersionResponse) String() string
type VersionServiceClient ¶
type VersionServiceClient interface { // Version returns version information about the server. Version(ctx context.Context, in *VersionRequest, out *VersionResponse) error // KeepaliveStream returns a stream where the server continuously writes // keepalive events. // // The stream only terminates if the client requests it or the connection to // the server is closed. KeepaliveStream(ctx context.Context, in *KeepaliveStreamRequest) (VersionService_KeepaliveStreamClient, error) }
VersionServiceClient is the client API for VersionService service.
func NewVersionServiceClient ¶
func NewVersionServiceClient(c ClientConn) VersionServiceClient
type VersionServiceServer ¶
type VersionServiceServer interface { // Version returns version information about the server. Version(context.Context, *VersionRequest, *VersionResponse) error // KeepaliveStream returns a stream where the server continuously writes // keepalive events. // // The stream only terminates if the client requests it or the connection to // the server is closed. KeepaliveStream(context.Context, *KeepaliveStreamRequest, VersionService_KeepaliveStreamServer) error }
VersionServiceServer is the server API for VersionService service.
type VersionService_KeepaliveStreamClient ¶
type VersionService_KeepaliveStreamClient interface {
Recv(*KeepaliveEvent) error
}
type VersionService_KeepaliveStreamServer ¶
type VersionService_KeepaliveStreamServer interface {
Send(m *KeepaliveEvent) error
}
type WriteNewInviteRequest ¶ added in v0.1.6
type WriteNewInviteRequest struct {
// contains filtered or unexported fields
}
WriteNewInviteRequest is the request to add a new invite.
func (*WriteNewInviteRequest) Descriptor
deprecated
added in
v0.1.6
func (*WriteNewInviteRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteNewInviteRequest.ProtoReflect.Descriptor instead.
func (*WriteNewInviteRequest) ProtoMessage ¶ added in v0.1.6
func (*WriteNewInviteRequest) ProtoMessage()
func (*WriteNewInviteRequest) ProtoReflect ¶ added in v0.1.6
func (x *WriteNewInviteRequest) ProtoReflect() protoreflect.Message
func (*WriteNewInviteRequest) Reset ¶ added in v0.1.6
func (x *WriteNewInviteRequest) Reset()
func (*WriteNewInviteRequest) String ¶ added in v0.1.6
func (x *WriteNewInviteRequest) String() string
type WriteNewInviteResponse ¶ added in v0.1.6
type WriteNewInviteResponse struct { // invite_bytes is the raw invite. InviteBytes []byte `protobuf:"bytes,1,opt,name=invite_bytes,json=inviteBytes,proto3" json:"invite_bytes,omitempty"` // invite is the data contained in the raw invite. Invite *OOBPublicIdentityInvite `protobuf:"bytes,2,opt,name=invite,proto3" json:"invite,omitempty"` // contains filtered or unexported fields }
WriteNewInviteResponse is an invite that can be sent (out-of-band) to an user the local client wishes to KX with.
func (*WriteNewInviteResponse) Descriptor
deprecated
added in
v0.1.6
func (*WriteNewInviteResponse) Descriptor() ([]byte, []int)
Deprecated: Use WriteNewInviteResponse.ProtoReflect.Descriptor instead.
func (*WriteNewInviteResponse) GetInvite ¶ added in v0.1.6
func (x *WriteNewInviteResponse) GetInvite() *OOBPublicIdentityInvite
func (*WriteNewInviteResponse) GetInviteBytes ¶ added in v0.1.6
func (x *WriteNewInviteResponse) GetInviteBytes() []byte
func (*WriteNewInviteResponse) ProtoMessage ¶ added in v0.1.6
func (*WriteNewInviteResponse) ProtoMessage()
func (*WriteNewInviteResponse) ProtoReflect ¶ added in v0.1.6
func (x *WriteNewInviteResponse) ProtoReflect() protoreflect.Message
func (*WriteNewInviteResponse) Reset ¶ added in v0.1.6
func (x *WriteNewInviteResponse) Reset()
func (*WriteNewInviteResponse) String ¶ added in v0.1.6
func (x *WriteNewInviteResponse) String() string