types

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
}

type AcceptGCInviteResponse struct {
	// contains filtered or unexported fields
}

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
}

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
}

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
}

type AckResponse struct {
	// contains filtered or unexported fields
}

type ChatServiceClient interface {
	// UserPublicIdentity returns public information from user's br client
	UserPublicIdentity(ctx context.Context, in *PublicIdentityReq, out *PublicIdentity) error
	// 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.
	// TODO: move to ContentService.
	SendFile(ctx context.Context, in *SendFileRequest, out *SendFileResponse) error
	// UserNick returns the nick of an user.
	UserNick(ctx context.Context, in *UserNickRequest, out *UserNickResponse) error
}

type ChatServiceServer interface {
	// UserPublicIdentity returns public information from user's br client
	UserPublicIdentity(context.Context, *PublicIdentityReq, *PublicIdentity) error
	// 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.
	// TODO: move to ContentService.
	SendFile(context.Context, *SendFileRequest, *SendFileResponse) error
	// UserNick returns the nick of an user.
	UserNick(context.Context, *UserNickRequest, *UserNickResponse) error
}

type ChatService_GCMStreamClient interface {
	Recv(*GCReceivedMsg) error
}

type ChatService_GCMStreamServer interface {
	Send(m *GCReceivedMsg) error
}

type ChatService_KXStreamClient interface {
	Recv(*KXCompleted) error
}

type ChatService_KXStreamServer interface {
	Send(m *KXCompleted) error
}

type ChatService_PMStreamClient interface {
	Recv(*ReceivedPM) error
}

type ChatService_PMStreamServer interface {
	Send(m *ReceivedPM) error
}

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)
}

type ClientStream interface {
	Recv(proto.Message) error
}

type ContentServiceClient interface {
	// DownloadsCompletedStream streams completed downloads (file transfers) made
	// by the local client. This includes both downloads initiated by the local
	// client and pushed by remote clients.
	DownloadsCompletedStream(ctx context.Context, in *DownloadsCompletedStreamRequest) (ContentService_DownloadsCompletedStreamClient, error)
	// AckDownloadCompleted acks download completed events.
	AckDownloadCompleted(ctx context.Context, in *AckRequest, out *AckResponse) error
}

type ContentServiceServer interface {
	// DownloadsCompletedStream streams completed downloads (file transfers) made
	// by the local client. This includes both downloads initiated by the local
	// client and pushed by remote clients.
	DownloadsCompletedStream(context.Context, *DownloadsCompletedStreamRequest, ContentService_DownloadsCompletedStreamServer) error
	// AckDownloadCompleted acks download completed events.
	AckDownloadCompleted(context.Context, *AckRequest, *AckResponse) error
}

type ContentService_DownloadsCompletedStreamClient interface {
	Recv(*DownloadCompletedResponse) error
}

type ContentService_DownloadsCompletedStreamServer interface {
	Send(m *DownloadCompletedResponse) error
}

type DownloadCompletedResponse 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 User ID of the client that sent the file.
	Uid []byte `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// nick is the nick of the client that sent the resource.
	Nick string `protobuf:"bytes,3,opt,name=nick,proto3" json:"nick,omitempty"`
	// disk_path is the path of the file in the local client's disk.
	DiskPath string `protobuf:"bytes,4,opt,name=disk_path,json=diskPath,proto3" json:"disk_path,omitempty"`
	// file_metadata is the metadata about the file.
	FileMetadata *FileMetadata `protobuf:"bytes,5,opt,name=file_metadata,json=fileMetadata,proto3" json:"file_metadata,omitempty"`
	// contains filtered or unexported fields
}

type DownloadsCompletedStreamRequest struct {

	// unacked_from specifies to the server the sequence_id of the last completed
	// download. Downloads 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
}

type FileManifest struct {

	// index is the position of this manifest item on the file metadata manifest.
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// size is the size of this chunk.
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// hash is the hash of the chunk data.
	Hash []byte `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

type FileMetadata struct {

	// version of the metadata.
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// cost (in milliatoms) to download the file.
	Cost uint64 `protobuf:"varint,2,opt,name=cost,proto3" json:"cost,omitempty"`
	// size (in bytes) of the file.
	Size uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// directory where the file is stored in the source.
	Directory string `protobuf:"bytes,4,opt,name=directory,proto3" json:"directory,omitempty"`
	// filename of the file.
	Filename string `protobuf:"bytes,5,opt,name=filename,proto3" json:"filename,omitempty"`
	// description of the file.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// hash of the file contents.
	Hash string `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"`
	// manifest of the chunks that compose the file.
	Manifest []*FileManifest `protobuf:"bytes,8,rep,name=manifest,proto3" json:"manifest,omitempty"`
	// signature of the file by the host.
	Signature string `protobuf:"bytes,9,opt,name=signature,proto3" json:"signature,omitempty"`
	// attributes of the file.
	Attributes map[string]string `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

type FulfillResourceRequest struct {

	// id must be the corresponding request received by the clientrpc client.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// error_msg is an optional error message to fail the request with.
	ErrorMsg string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// response is the actual resource that should be sent to the remote client.
	Response *RMFetchResourceReply `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

type FulfillResourceRequestResponse struct {
	// contains filtered or unexported fields
}

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
}

type GCMResponse struct {
	// contains filtered or unexported fields
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

type GCService_JoinedGCsClient interface {
	Recv(*JoinedGCEvent) error
}

type GCService_JoinedGCsServer interface {
	Send(m *JoinedGCEvent) error
}

type GCService_MembersAddedClient interface {
	Recv(*GCMembersAddedEvent) error
}

type GCService_MembersAddedServer interface {
	Send(m *GCMembersAddedEvent) error
}

type GCService_MembersRemovedClient interface {
	Recv(*GCMembersRemovedEvent) error
}

type GCService_MembersRemovedServer interface {
	Send(m *GCMembersRemovedEvent) error
}

type GCService_ReceivedGCInvitesClient interface {
	Recv(*ReceivedGCInvite) error
}

type GCService_ReceivedGCInvitesServer interface {
	Send(m *ReceivedGCInvite) error
}

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
}

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
}

type InviteFunds struct {

	// tx is the hash of the transaction that includes the funds.
	Tx string `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// index is the output index of the transaction that includes the funds.
	Index uint32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// tree is the tree of the transaction that includes the funds.
	Tree int32 `protobuf:"varint,3,opt,name=tree,proto3" json:"tree,omitempty"`
	// private_key is the private key needed to redeem the funds in the transaction.
	PrivateKey string `protobuf:"bytes,4,opt,name=private_key,proto3" json:"private_key,omitempty"`
	// height_hint is a height at or before the transaction that includes the funds
	// is mined in.
	HeightHint uint32 `protobuf:"varint,5,opt,name=height_hint,json=heightHint,proto3" json:"height_hint,omitempty"`
	// address is the public address that the funds were sent to.
	Address string `protobuf:"bytes,6,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

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
}

type InviteToGCResponse struct {
	// contains filtered or unexported fields
}

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
}

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
}

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"`
	// initial_rendezvous is the initial random RV the key exchange happened.
	InitialRendezvous []byte `protobuf:"bytes,4,opt,name=initial_rendezvous,json=initialRendezvous,proto3" json:"initial_rendezvous,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

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
}

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
}

type KickFromGCResponse struct {
	// contains filtered or unexported fields
}

type ListGCsRequest struct {
	// contains filtered or unexported fields
}

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
}

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
}

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
}

type MediateKXResponse struct {
	// contains filtered or unexported fields
}

type MessageMode int32

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
}

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"`
	// funds are funds that may be included in the invite and are redeemable by
	// the invitee.
	Funds *InviteFunds `protobuf:"bytes,4,opt,name=funds,proto3" json:"funds,omitempty"`
	// contains filtered or unexported fields
}

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
}

type PMResponse struct {
	// contains filtered or unexported fields
}

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
}

type PaymentsServiceClient interface {
	// TipUser attempts to send a tip to a user. The user must be or come online
	// for this to complete. The request to tip is persisted and may continue
	// after a client restart.
	TipUser(ctx context.Context, in *TipUserRequest, out *TipUserResponse) error
	// TipProgress starts a stream that receives events about the progress of
	// TipUser requests. Multiple events for the same request may be received.
	TipProgress(ctx context.Context, in *TipProgressRequest) (PaymentsService_TipProgressClient, error)
	// AckTipProgress acknowledges events received up to a given
	// sequence_id have been processed.
	AckTipProgress(ctx context.Context, in *AckRequest, out *AckResponse) error
	// TipStream returns a stream that gets tips received by the client.
	TipStream(ctx context.Context, in *TipStreamRequest) (PaymentsService_TipStreamClient, error)
	// AckTipReceived acknowledges events received up to a given
	// sequence_id have been processed.
	AckTipReceived(ctx context.Context, in *AckRequest, out *AckResponse) error
}

type PaymentsServiceServer interface {
	// TipUser attempts to send a tip to a user. The user must be or come online
	// for this to complete. The request to tip is persisted and may continue
	// after a client restart.
	TipUser(context.Context, *TipUserRequest, *TipUserResponse) error
	// TipProgress starts a stream that receives events about the progress of
	// TipUser requests. Multiple events for the same request may be received.
	TipProgress(context.Context, *TipProgressRequest, PaymentsService_TipProgressServer) error
	// AckTipProgress acknowledges events received up to a given
	// sequence_id have been processed.
	AckTipProgress(context.Context, *AckRequest, *AckResponse) error
	// TipStream returns a stream that gets tips received by the client.
	TipStream(context.Context, *TipStreamRequest, PaymentsService_TipStreamServer) error
	// AckTipReceived acknowledges events received up to a given
	// sequence_id have been processed.
	AckTipReceived(context.Context, *AckRequest, *AckResponse) error
}

type PaymentsService_TipProgressClient interface {
	Recv(*TipProgressEvent) error
}

type PaymentsService_TipProgressServer interface {
	Send(m *TipProgressEvent) error
}

type PaymentsService_TipStreamClient interface {
	Recv(*ReceivedTip) error
}

type PaymentsService_TipStreamServer interface {
	Send(m *ReceivedTip) error
}

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
}

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
}

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
}

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
}

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
}

type PostsService_PostsStatusStreamClient interface {
	Recv(*ReceivedPostStatus) error
}

type PostsService_PostsStatusStreamServer interface {
	Send(m *ReceivedPostStatus) error
}

type PostsService_PostsStreamClient interface {
	Recv(*ReceivedPost) error
}

type PostsService_PostsStreamServer interface {
	Send(m *ReceivedPost) error
}

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
}

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
}