types

package
v0.1.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 17, 2024 License: ISC Imports: 8 Imported by: 0

README

Bison Relay clientrpc types

This package defines the types used within the clientrpc protocol for Bison Relay client automation.

The majority of the code in this package is automatically generated, based on the definitions on the clientrpc.proto file.

End-users are usually interested in the definitions for the client side of the services defined in the proto file. Following are links for documentation about the currently available service clients:

  • VersionServiceClient: Provides functions to fetch metadata about the clientrpc server (i.e. the underlying brclient).
  • ChatServiceClient: Provides functions to interact with the chat services of the clientrpc server.

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
var File_clientrpc_proto protoreflect.FileDescriptor

Functions

func DebugSequenceID

func DebugSequenceID(seq uint64) string

DebugSequenceID returns a debug string for a given sequence ID.

func HelpForMessage

func HelpForMessage(name string) string

HelpForMessage returns the top-level help defined for the given proto message.

func HelpForMessageField

func HelpForMessageField(message, field string) string

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 (*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.
	// 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
}

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.
	// TODO: move to ContentService.
	SendFile(context.Context, *SendFileRequest, *SendFileResponse) error
	// UserNick returns the nick of an user.
	UserNick(context.Context, *UserNickRequest, *UserNickResponse) 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

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

ClientStream abstracts the necessary functions of a client-side stream.

type ContentServiceClient added in v0.1.10

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
}

ContentServiceClient is the client API for ContentService service.

func NewContentServiceClient added in v0.1.10

func NewContentServiceClient(c ClientConn) ContentServiceClient

type ContentServiceServer added in v0.1.10

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
}

ContentServiceServer is the server API for ContentService service.

type ContentService_DownloadsCompletedStreamClient added in v0.1.10

type ContentService_DownloadsCompletedStreamClient interface {
	Recv(*DownloadCompletedResponse) error
}

type ContentService_DownloadsCompletedStreamServer added in v0.1.10

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

type DownloadCompletedResponse added in v0.1.10

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
}

DownloadCompletedResponse is the data about one completed file download.

func (*DownloadCompletedResponse) Descriptor deprecated added in v0.1.10

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

Deprecated: Use DownloadCompletedResponse.ProtoReflect.Descriptor instead.

func (*DownloadCompletedResponse) GetDiskPath added in v0.1.10

func (x *DownloadCompletedResponse) GetDiskPath() string

func (*DownloadCompletedResponse) GetFileMetadata added in v0.1.10

func (x *DownloadCompletedResponse) GetFileMetadata() *FileMetadata

func (*DownloadCompletedResponse) GetNick added in v0.1.10

func (x *DownloadCompletedResponse) GetNick() string

func (*DownloadCompletedResponse) GetSequenceId added in v0.1.10

func (x *DownloadCompletedResponse) GetSequenceId() uint64

func (*DownloadCompletedResponse) GetUid added in v0.1.10

func (x *DownloadCompletedResponse) GetUid() []byte

func (*DownloadCompletedResponse) ProtoMessage added in v0.1.10

func (*DownloadCompletedResponse) ProtoMessage()

func (*DownloadCompletedResponse) ProtoReflect added in v0.1.10

func (*DownloadCompletedResponse) Reset added in v0.1.10

func (x *DownloadCompletedResponse) Reset()

func (*DownloadCompletedResponse) String added in v0.1.10

func (x *DownloadCompletedResponse) String() string

type DownloadsCompletedStreamRequest added in v0.1.10

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
}

DownloadsCompletedRequest is the request sent when obtaining a stream of completed downloads notifications.

func (*DownloadsCompletedStreamRequest) Descriptor deprecated added in v0.1.10

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

Deprecated: Use DownloadsCompletedStreamRequest.ProtoReflect.Descriptor instead.

func (*DownloadsCompletedStreamRequest) GetUnackedFrom added in v0.1.10

func (x *DownloadsCompletedStreamRequest) GetUnackedFrom() uint64

func (*DownloadsCompletedStreamRequest) ProtoMessage added in v0.1.10

func (*DownloadsCompletedStreamRequest) ProtoMessage()

func (*DownloadsCompletedStreamRequest) ProtoReflect added in v0.1.10

func (*DownloadsCompletedStreamRequest) Reset added in v0.1.10

func (*DownloadsCompletedStreamRequest) String added in v0.1.10

type FileManifest added in v0.1.10

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
}

FileManifest is metadata about a chunk of the file.

func (*FileManifest) Descriptor deprecated added in v0.1.10

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

Deprecated: Use FileManifest.ProtoReflect.Descriptor instead.

func (*FileManifest) GetHash added in v0.1.10

func (x *FileManifest) GetHash() []byte

func (*FileManifest) GetIndex added in v0.1.10

func (x *FileManifest) GetIndex() uint64

func (*FileManifest) GetSize added in v0.1.10

func (x *FileManifest) GetSize() uint64

func (*FileManifest) ProtoMessage added in v0.1.10

func (*FileManifest) ProtoMessage()

func (*FileManifest) ProtoReflect added in v0.1.10

func (x *FileManifest) ProtoReflect() protoreflect.Message

func (*FileManifest) Reset added in v0.1.10

func (x *FileManifest) Reset()

func (*FileManifest) String added in v0.1.10

func (x *FileManifest) String() string

type FileMetadata added in v0.1.10

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
}

FileMetadata is metadata about a file in the file transfer subsystem.

func (*FileMetadata) Descriptor deprecated added in v0.1.10

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

Deprecated: Use FileMetadata.ProtoReflect.Descriptor instead.

func (*FileMetadata) GetAttributes added in v0.1.10

func (x *FileMetadata) GetAttributes() map[string]string

func (*FileMetadata) GetCost added in v0.1.10

func (x *FileMetadata) GetCost() uint64

func (*FileMetadata) GetDescription added in v0.1.10

func (x *FileMetadata) GetDescription() string

func (*FileMetadata) GetDirectory added in v0.1.10

func (x *FileMetadata) GetDirectory() string

func (*FileMetadata) GetFilename added in v0.1.10

func (x *FileMetadata) GetFilename() string

func (*FileMetadata) GetHash added in v0.1.10

func (x *FileMetadata) GetHash() string

func (*FileMetadata) GetManifest added in v0.1.10

func (x *FileMetadata) GetManifest() []*FileManifest

func (*FileMetadata) GetSignature added in v0.1.10

func (x *FileMetadata) GetSignature() string

func (*FileMetadata) GetSize added in v0.1.10

func (x *FileMetadata) GetSize() uint64

func (*FileMetadata) GetVersion added in v0.1.10

func (x *FileMetadata) GetVersion() uint64

func (*FileMetadata) ProtoMessage added in v0.1.10

func (*FileMetadata) ProtoMessage()

func (*FileMetadata) ProtoReflect added in v0.1.10

func (x *FileMetadata) ProtoReflect() protoreflect.Message

func (*FileMetadata) Reset added in v0.1.10

func (x *FileMetadata) Reset()

func (*FileMetadata) String added in v0.1.10

func (x *FileMetadata) String() string

type FulfillResourceRequest added in v0.1.8

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
}

FulfillResourceRequest fulfills a remote request for a local client resource.

func (*FulfillResourceRequest) Descriptor deprecated added in v0.1.8

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

Deprecated: Use FulfillResourceRequest.ProtoReflect.Descriptor instead.

func (*FulfillResourceRequest) GetErrorMsg added in v0.1.8

func (x *FulfillResourceRequest) GetErrorMsg() string

func (*FulfillResourceRequest) GetId added in v0.1.8

func (x *FulfillResourceRequest) GetId() uint64

func (*FulfillResourceRequest) GetResponse added in v0.1.8

func (x *FulfillResourceRequest) GetResponse() *RMFetchResourceReply

func (*FulfillResourceRequest) ProtoMessage added in v0.1.8

func (*FulfillResourceRequest) ProtoMessage()

func (*FulfillResourceRequest) ProtoReflect added in v0.1.8

func (x *FulfillResourceRequest) ProtoReflect() protoreflect.Message

func (*FulfillResourceRequest) Reset added in v0.1.8

func (x *FulfillResourceRequest) Reset()

func (*FulfillResourceRequest) String added in v0.1.8

func (x *FulfillResourceRequest) String() string

type FulfillResourceRequestResponse added in v0.1.8

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

FulfillResourceRequestResponse is the response to a FulfillResourceResquest call.

func (*FulfillResourceRequestResponse) Descriptor deprecated added in v0.1.8

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

Deprecated: Use FulfillResourceRequestResponse.ProtoReflect.Descriptor instead.

func (*FulfillResourceRequestResponse) ProtoMessage added in v0.1.8

func (*FulfillResourceRequestResponse) ProtoMessage()

func (*FulfillResourceRequestResponse) ProtoReflect added in v0.1.8

func (*FulfillResourceRequestResponse) Reset added in v0.1.8

func (x *FulfillResourceRequestResponse) Reset()

func (*FulfillResourceRequestResponse) String added in v0.1.8

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 InviteFunds added in v0.1.7

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
}

InviteFunds is the lowlevel information about funds added to an invite.

func (*InviteFunds) Descriptor deprecated added in v0.1.7

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

Deprecated: Use InviteFunds.ProtoReflect.Descriptor instead.

func (*InviteFunds) GetAddress added in v0.1.7

func (x *InviteFunds) GetAddress() string

func (*InviteFunds) GetHeightHint added in v0.1.7

func (x *InviteFunds) GetHeightHint() uint32

func (*InviteFunds) GetIndex added in v0.1.7

func (x *InviteFunds) GetIndex() uint32

func (*InviteFunds) GetPrivateKey added in v0.1.7

func (x *InviteFunds) GetPrivateKey() string

func (*InviteFunds) GetTree added in v0.1.7

func (x *InviteFunds) GetTree() int32

func (*InviteFunds) GetTx added in v0.1.7

func (x *InviteFunds) GetTx() string

func (*InviteFunds) ProtoMessage added in v0.1.7

func (*InviteFunds) ProtoMessage()

func (*InviteFunds) ProtoReflect added in v0.1.7

func (x *InviteFunds) ProtoReflect() protoreflect.Message

func (*InviteFunds) Reset added in v0.1.7

func (x *InviteFunds) Reset()

func (*InviteFunds) String added in v0.1.7

func (x *InviteFunds) 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"`
	// 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
}

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) GetInitialRendezvous added in v0.1.6

func (x *KXCompleted) GetInitialRendezvous() []byte

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

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"`
	// 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
}

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) GetFunds added in v0.1.7

func (x *OOBPublicIdentityInvite) GetFunds() *InviteFunds

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) Descriptor() ([]byte, []int)

Deprecated: Use PMRequest.ProtoReflect.Descriptor instead.

func (*PMRequest) GetMsg

func (x *PMRequest) GetMsg() *RMPrivateMessage

func (*PMRequest) GetUser

func (x *PMRequest) GetUser() string

func (*PMRequest) ProtoMessage

func (*PMRequest) ProtoMessage()

func (*PMRequest) ProtoReflect

func (x *PMRequest) ProtoReflect() protoreflect.Message

func (*PMRequest) Reset

func (x *PMRequest) Reset()

func (*PMRequest) String

func (x *PMRequest) String() string

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

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

PaymentsServiceServer is the server API for PaymentsService service.

type PaymentsService_TipProgressClient added in v0.1.7

type PaymentsService_TipProgressClient interface {
	Recv(*TipProgressEvent) error
}

type PaymentsService_TipProgressServer added in v0.1.7

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

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 (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 RMFetchResource added in v0.1.8

type RMFetchResource struct {

	// path is the resource's path (already split into segments).
	Path []string `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"`
	// meta is metadata associated with the request.
	Meta map[string]string `` /* 149-byte string literal not displayed */
	// tag is a unique tag that should be relayed back on the reply.
	Tag uint64 `protobuf:"varint,3,opt,name=tag,proto3" json:"tag,omitempty"`
	// data is raw request data.
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// index is used in chunked/multipart requests.
	Index uint32 `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	// count is the total number of chunks in multipart requests.
	Count uint32 `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

RMFetchResource is the lowlevel request to fetch a resource.

func (*RMFetchResource) Descriptor deprecated added in v0.1.8

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

Deprecated: Use RMFetchResource.ProtoReflect.Descriptor instead.

func (*RMFetchResource) GetCount added in v0.1.8

func (x *RMFetchResource) GetCount() uint32

func (*RMFetchResource) GetData added in v0.1.8

func (x *RMFetchResource) GetData() []byte

func (*RMFetchResource) GetIndex added in v0.1.8

func (x *RMFetchResource) GetIndex() uint32

func (*RMFetchResource) GetMeta added in v0.1.8

func (x *RMFetchResource) GetMeta() map[string]string

func (*RMFetchResource) GetPath added in v0.1.8

func (x *RMFetchResource) GetPath() []string

func (*RMFetchResource) GetTag added in v0.1.8

func (x *RMFetchResource) GetTag() uint64

func (*RMFetchResource) ProtoMessage added in v0.1.8

func (*RMFetchResource) ProtoMessage()

func (*RMFetchResource) ProtoReflect added in v0.1.8

func (x *RMFetchResource) ProtoReflect() protoreflect.Message

func (*RMFetchResource) Reset added in v0.1.8

func (x *RMFetchResource) Reset()

func (*RMFetchResource) String added in v0.1.8

func (x *RMFetchResource) String() string

type RMFetchResourceReply added in v0.1.8

type RMFetchResourceReply struct {

	// tag is the same as the request tag.
	Tag uint64 `protobuf:"varint,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// status is the general status of the response.
	Status uint32 `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	// meta is additional response metadata.
	Meta map[string]string `` /* 149-byte string literal not displayed */
	// data is the raw response data.
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// index is used in chunked/multipart responses.
	Index uint32 `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	// count is the total number of chunks in multipart responses.
	Count uint32 `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

RMFetchResourceReply is the lowlevel resource response.

func (*RMFetchResourceReply) Descriptor deprecated added in v0.1.8

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

Deprecated: Use RMFetchResourceReply.ProtoReflect.Descriptor instead.

func (*RMFetchResourceReply) GetCount added in v0.1.8

func (x *RMFetchResourceReply) GetCount() uint32

func (*RMFetchResourceReply) GetData added in v0.1.8

func (x *RMFetchResourceReply) GetData() []byte

func (*RMFetchResourceReply) GetIndex added in v0.1.8

func (x *RMFetchResourceReply) GetIndex() uint32

func (*RMFetchResourceReply) GetMeta added in v0.1.8

func (x *RMFetchResourceReply) GetMeta() map[string]string

func (*RMFetchResourceReply) GetStatus added in v0.1.8

func (x *RMFetchResourceReply) GetStatus() uint32

func (*RMFetchResourceReply) GetTag added in v0.1.8

func (x *RMFetchResourceReply) GetTag() uint64

func (*RMFetchResourceReply) ProtoMessage added in v0.1.8

func (*RMFetchResourceReply) ProtoMessage()

func (*RMFetchResourceReply) ProtoReflect added in v0.1.8

func (x *RMFetchResourceReply) ProtoReflect() protoreflect.Message

func (*RMFetchResourceReply) Reset added in v0.1.8

func (x *RMFetchResourceReply) Reset()

func (*RMFetchResourceReply) String added in v0.1.8

func (x *RMFetchResourceReply) 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 ResourceRequestsStreamRequest added in v0.1.8

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

ResourceRequestsStreamRequest is the request for a stream to receive resource requests.

func (*ResourceRequestsStreamRequest) Descriptor deprecated added in v0.1.8

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

Deprecated: Use ResourceRequestsStreamRequest.ProtoReflect.Descriptor instead.

func (*ResourceRequestsStreamRequest) ProtoMessage added in v0.1.8

func (*ResourceRequestsStreamRequest) ProtoMessage()

func (*ResourceRequestsStreamRequest) ProtoReflect added in v0.1.8

func (*ResourceRequestsStreamRequest) Reset added in v0.1.8

func (x *ResourceRequestsStreamRequest) Reset()

func (*ResourceRequestsStreamRequest) String added in v0.1.8

type ResourceRequestsStreamResponse added in v0.1.8

type ResourceRequestsStreamResponse struct {

	// id is an opaque ID to link requests and responses made through the clientrpc
	// interface.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// uid is the User ID of the client that requested the resource.
	Uid []byte `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// nick is the nick of the client that requested the resource.
	Nick string `protobuf:"bytes,3,opt,name=nick,proto3" json:"nick,omitempty"`
	// request is the actual request made by the remote client.
	Request *RMFetchResource `protobuf:"bytes,4,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

ResourceRequestsStreamResponse is the a request made by a remote client for one of the local client's resources.

func (*ResourceRequestsStreamResponse) Descriptor deprecated added in v0.1.8

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

Deprecated: Use ResourceRequestsStreamResponse.ProtoReflect.Descriptor instead.

func (*ResourceRequestsStreamResponse) GetId added in v0.1.8

func (*ResourceRequestsStreamResponse) GetNick added in v0.1.8

func (*ResourceRequestsStreamResponse) GetRequest added in v0.1.8

func (*ResourceRequestsStreamResponse) GetUid added in v0.1.8

func (x *ResourceRequestsStreamResponse) GetUid() []byte

func (*ResourceRequestsStreamResponse) ProtoMessage added in v0.1.8

func (*ResourceRequestsStreamResponse) ProtoMessage()

func (*ResourceRequestsStreamResponse) ProtoReflect added in v0.1.8

func (*ResourceRequestsStreamResponse) Reset added in v0.1.8

func (x *ResourceRequestsStreamResponse) Reset()

func (*ResourceRequestsStreamResponse) String added in v0.1.8

type ResourcesServiceClient added in v0.1.8

type ResourcesServiceClient interface {
	// RequestsStream streams requests made to the local client by remote clients
	// for resources and pages. A clientrpc client may send the responses by using
	// the FulfillRequest call.
	RequestsStream(ctx context.Context, in *ResourceRequestsStreamRequest) (ResourcesService_RequestsStreamClient, error)
	// FulfillRequest fulfills a previous request received from an user for a
	// local client resource.
	FulfillRequest(ctx context.Context, in *FulfillResourceRequest, out *FulfillResourceRequestResponse) error
}

ResourcesServiceClient is the client API for ResourcesService service.

func NewResourcesServiceClient added in v0.1.8

func NewResourcesServiceClient(c ClientConn) ResourcesServiceClient

type ResourcesServiceServer added in v0.1.8

type ResourcesServiceServer interface {
	// RequestsStream streams requests made to the local client by remote clients
	// for resources and pages. A clientrpc client may send the responses by using
	// the FulfillRequest call.
	RequestsStream(context.Context, *ResourceRequestsStreamRequest, ResourcesService_RequestsStreamServer) error
	// FulfillRequest fulfills a previous request received from an user for a
	// local client resource.
	FulfillRequest(context.Context, *FulfillResourceRequest, *FulfillResourceRequestResponse) error
}

ResourcesServiceServer is the server API for ResourcesService service.

type ResourcesService_RequestsStreamClient added in v0.1.8

type ResourcesService_RequestsStreamClient interface {
	Recv(*ResourceRequestsStreamResponse) error
}

type ResourcesService_RequestsStreamServer added in v0.1.8

type ResourcesService_RequestsStreamServer interface {
	Send(m *ResourceRequestsStreamResponse) error
}

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

type ServerStream interface {
	Send(proto.Message) error
}

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 ContentServiceDefn added in v0.1.10

func ContentServiceDefn() ServiceDefn

func GCServiceDefn added in v0.1.6

func GCServiceDefn() ServiceDefn

func PaymentsServiceDefn

func PaymentsServiceDefn() ServiceDefn

func PostsServiceDefn

func PostsServiceDefn() ServiceDefn

func ResourcesServiceDefn added in v0.1.8

func ResourcesServiceDefn() 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 TipProgressEvent added in v0.1.7

type TipProgressEvent 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 TipUser target.
	Uid []byte `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// nick is the nick of the TipUser target.
	Nick string `protobuf:"bytes,3,opt,name=nick,proto3" json:"nick,omitempty"`
	// amount_matoms is the amount being tipped in milli-atoms.
	AmountMatoms int64 `protobuf:"varint,4,opt,name=amount_matoms,json=amountMatoms,proto3" json:"amount_matoms,omitempty"`
	// completed flags whether the TipUser request was successfully completed
	// (i.e. if the tip was paid).
	Completed bool `protobuf:"varint,5,opt,name=completed,proto3" json:"completed,omitempty"`
	// attempt is the attempt number.
	Attempt int32 `protobuf:"varint,6,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// attempt_err is filled when the attempt to fetch an invoice or perform
	// the payment for a received invoice failed.
	AttemptErr string `protobuf:"bytes,7,opt,name=attempt_err,json=attemptErr,proto3" json:"attempt_err,omitempty"`
	// will_retry flags whether a new attempt to request an invoice and perform
	// a payment will be done or if no more attempts will happen.
	WillRetry bool `protobuf:"varint,8,opt,name=will_retry,json=willRetry,proto3" json:"will_retry,omitempty"`
	// contains filtered or unexported fields
}

TipProgressEvent details the progress of a TipUser request.

func (*TipProgressEvent) Descriptor deprecated added in v0.1.7

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

Deprecated: Use TipProgressEvent.ProtoReflect.Descriptor instead.

func (*TipProgressEvent) GetAmountMatoms added in v0.1.7

func (x *TipProgressEvent) GetAmountMatoms() int64

func (*TipProgressEvent) GetAttempt added in v0.1.7

func (x *TipProgressEvent) GetAttempt() int32

func (*TipProgressEvent) GetAttemptErr added in v0.1.7

func (x *TipProgressEvent) GetAttemptErr() string

func (*TipProgressEvent) GetCompleted added in v0.1.7

func (x *TipProgressEvent) GetCompleted() bool

func (*TipProgressEvent) GetNick added in v0.1.7

func (x *TipProgressEvent) GetNick() string

func (*TipProgressEvent) GetSequenceId added in v0.1.7

func (x *TipProgressEvent) GetSequenceId() uint64

func (*TipProgressEvent) GetUid added in v0.1.7

func (x *TipProgressEvent) GetUid() []byte

func (*TipProgressEvent) GetWillRetry added in v0.1.7

func (x *TipProgressEvent) GetWillRetry() bool

func (*TipProgressEvent) ProtoMessage added in v0.1.7

func (*TipProgressEvent) ProtoMessage()

func (*TipProgressEvent) ProtoReflect added in v0.1.7

func (x *TipProgressEvent) ProtoReflect() protoreflect.Message

func (*TipProgressEvent) Reset added in v0.1.7

func (x *TipProgressEvent) Reset()

func (*TipProgressEvent) String added in v0.1.7

func (x *TipProgressEvent) String() string

type TipProgressRequest added in v0.1.7

type TipProgressRequest struct {

	// unacked_from specifies to the server the sequence_id of the last received
	// tip progress 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
}

TipProgressRequest is the request to create a stream that receives events about the progress of TipUser requests.

func (*TipProgressRequest) Descriptor deprecated added in v0.1.7

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

Deprecated: Use TipProgressRequest.ProtoReflect.Descriptor instead.

func (*TipProgressRequest) GetUnackedFrom added in v0.1.7

func (x *TipProgressRequest) GetUnackedFrom() uint64

func (*TipProgressRequest) ProtoMessage added in v0.1.7

func (*TipProgressRequest) ProtoMessage()

func (*TipProgressRequest) ProtoReflect added in v0.1.7

func (x *TipProgressRequest) ProtoReflect() protoreflect.Message

func (*TipProgressRequest) Reset added in v0.1.7

func (x *TipProgressRequest) Reset()

func (*TipProgressRequest) String added in v0.1.7

func (x *TipProgressRequest) 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"`
	// max_attempts is the number of max attempts to try to send the tip.
	MaxAttempts int32 `protobuf:"varint,3,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,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) GetMaxAttempts added in v0.1.7

func (x *TipUserRequest) GetMaxAttempts() int32

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 (*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 (*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 UserNickRequest added in v0.1.10

type UserNickRequest struct {

	// uid is the uid in raw bytes format.
	Uid []byte `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// hex_uid is the uid in hex format.
	HexUid string `protobuf:"bytes,2,opt,name=hex_uid,json=hexUid,proto3" json:"hex_uid,omitempty"`
	// contains filtered or unexported fields
}

UserNickRequest is the request to fetch a user's nick.

func (*UserNickRequest) Descriptor deprecated added in v0.1.10

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

Deprecated: Use UserNickRequest.ProtoReflect.Descriptor instead.

func (*UserNickRequest) GetHexUid added in v0.1.10

func (x *UserNickRequest) GetHexUid() string

func (*UserNickRequest) GetUid added in v0.1.10

func (x *UserNickRequest) GetUid() []byte

func (*UserNickRequest) ProtoMessage added in v0.1.10

func (*UserNickRequest) ProtoMessage()

func (*UserNickRequest) ProtoReflect added in v0.1.10

func (x *UserNickRequest) ProtoReflect() protoreflect.Message

func (*UserNickRequest) Reset added in v0.1.10

func (x *UserNickRequest) Reset()

func (*UserNickRequest) String added in v0.1.10

func (x *UserNickRequest) String() string

type UserNickResponse added in v0.1.10

type UserNickResponse struct {

	// nick is the nick of the user.
	Nick string `protobuf:"bytes,1,opt,name=nick,proto3" json:"nick,omitempty"`
	// contains filtered or unexported fields
}

UserNickResponse is the response to fetch a user's nick.

func (*UserNickResponse) Descriptor deprecated added in v0.1.10

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

Deprecated: Use UserNickResponse.ProtoReflect.Descriptor instead.

func (*UserNickResponse) GetNick added in v0.1.10

func (x *UserNickResponse) GetNick() string

func (*UserNickResponse) ProtoMessage added in v0.1.10

func (*UserNickResponse) ProtoMessage()

func (*UserNickResponse) ProtoReflect added in v0.1.10

func (x *UserNickResponse) ProtoReflect() protoreflect.Message

func (*UserNickResponse) Reset added in v0.1.10

func (x *UserNickResponse) Reset()

func (*UserNickResponse) String added in v0.1.10

func (x *UserNickResponse) 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 {

	// 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"`
	// fund_amount is how much to send as funds in the invite. If zero, no funds
	// are included. Amount is in atoms.
	FundAmount uint64 `protobuf:"varint,2,opt,name=fund_amount,json=fundAmount,proto3" json:"fund_amount,omitempty"`
	// 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) GetFundAmount added in v0.1.7

func (x *WriteNewInviteRequest) GetFundAmount() uint64

func (*WriteNewInviteRequest) GetGc added in v0.1.7

func (x *WriteNewInviteRequest) GetGc() string

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"`
	// invite_key is the pre-paid invite key string that can be used to fetch the
	// invite from the server.
	InviteKey string `protobuf:"bytes,3,opt,name=invite_key,json=inviteKey,proto3" json:"invite_key,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 (*WriteNewInviteResponse) GetInviteBytes added in v0.1.6

func (x *WriteNewInviteResponse) GetInviteBytes() []byte

func (*WriteNewInviteResponse) GetInviteKey added in v0.1.7

func (x *WriteNewInviteResponse) GetInviteKey() string

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL