types

type AckRequest struct {

	// sequence_id is the ID up to which messages have been processed.
	SequenceId uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
	// contains filtered or unexported fields
}

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

type ChatServiceClient interface {
	// 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
}

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
}

type ChatService_GCMStreamClient interface {
	Recv(*GCReceivedMsg) error
}

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

type ChatService_PMStreamClient interface {
	Recv(*ReceivedPM) error
}

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

type ClientConn interface {
	Request(ctx context.Context, method string, request, response proto.Message) error
	Stream(ctx context.Context, method string, request proto.Message) (ClientStream, error)
}

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

type GCMRequest struct {

	// gc is either an hex-encoded GCID or a GC alias.
	Gc string `protobuf:"bytes,1,opt,name=gc,proto3" json:"gc,omitempty"`
	// msg is the text payload of the message.
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

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

type GCMStreamRequest struct {

	// unacked_from specifies to the server the sequence_id of the last processed
	// GCM. GCMs received by the server that have a higher sequence_id will be
	// streamed back to the client.
	UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"`
	// contains filtered or unexported fields
}

type GCReceivedMsg struct {

	// uid is the source user ID.
	Uid []byte `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// nick is the source user nick/alias.
	Nick string `protobuf:"bytes,2,opt,name=nick,proto3" json:"nick,omitempty"`
	// gc_alias is the local alias of the GC where the message was sent.
	GcAlias string `protobuf:"bytes,3,opt,name=gc_alias,json=gcAlias,proto3" json:"gc_alias,omitempty"`
	// msg is the received message.
	Msg *RMGroupMessage `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	// timestamp_ms is the server timestamp of the message with millisecond precision.
	TimestampMs int64 `protobuf:"varint,5,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
	// sequence_id is an opaque sequential ID.
	SequenceId uint64 `protobuf:"varint,6,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
	// contains filtered or unexported fields
}

type KeepaliveEvent struct {

	// timestamp is the unix timestamp on the server, with second precision.
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type KeepaliveStreamRequest struct {

	// interval is how often to send the keepalive (in milliseconds).
	//
	// A minimum of 1 second is imposed, regardless of the value passed as
	// interval.
	Interval int64 `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

type MessageMode int32

type MethodDefn struct {
	NewRequest   func() proto.Message
	NewResponse  func() proto.Message
	RequestDefn  func() protoreflect.MessageDescriptor
	ResponseDefn func() protoreflect.MessageDescriptor

	ServerHandler       func(x interface{}, ctx context.Context, request, response proto.Message) error
	ServerStreamHandler func(x interface{}, ctx context.Context, request proto.Message, stream ServerStream) error
	ClientHandler       func(conn ClientConn, ctx context.Context, request, response proto.Message) error
	ClientStreamHandler func(conn ClientConn, ctx context.Context, request proto.Message) (ClientStream, error)

	Help        string
	IsStreaming bool
}

type PMRequest struct {

	// user is either the nick, alias or an hex-encoded user ID of the destination.
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// msg is the message to be sent.
	Msg *RMPrivateMessage `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

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

type PMStreamRequest struct {

	// unacked_from specifies to the server the sequence_id of the last processed
	// PM. PMs received by the server that have a higher sequence_id will be
	// streamed back to the client.
	UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"`
	// contains filtered or unexported fields
}

type PaymentsServiceClient interface {
	// TipUser attempts to send a tip to a user. The user must be or come online
	// for this to complete.
	TipUser(ctx context.Context, in *TipUserRequest, out *TipUserResponse) error
}

type PaymentsServiceServer interface {
	// TipUser attempts to send a tip to a user. The user must be or come online
	// for this to complete.
	TipUser(context.Context, *TipUserRequest, *TipUserResponse) error
}

type PostMetadata struct {

	// version defines the available fields within attributes.
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// attributes defines the available post attributes.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PostMetadataStatus struct {

	// version defines the available fields within attributes.
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// from is the UID of the original status creator.
	From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	// link is the ID of the post.
	Link string `protobuf:"bytes,3,opt,name=link,proto3" json:"link,omitempty"`
	// attributes is the list of post update attributes.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PostSummary struct {

	// id is the post ID (hash of the post metadata).
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// from is the id of the relayer of the post (who the local client received
	// the post from).
	From []byte `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	// author_id is the id of the author of the post.
	AuthorId []byte `protobuf:"bytes,3,opt,name=author_id,json=authorId,proto3" json:"author_id,omitempty"`
	// author_nick is the reported nick of the author of the post.
	AuthorNick string `protobuf:"bytes,4,opt,name=author_nick,json=authorNick,proto3" json:"author_nick,omitempty"`
	// date is the unix timestamp of the post.
	Date int64 `protobuf:"varint,5,opt,name=date,proto3" json:"date,omitempty"`
	// last_status_ts is the timestamp of the last recorded status update of the
	// post.
	LastStatusTs int64 `protobuf:"varint,6,opt,name=last_status_ts,json=lastStatusTs,proto3" json:"last_status_ts,omitempty"`
	// title is either the included or suggested title of the post.
	Title string `protobuf:"bytes,7,opt,name=title,proto3" json:"title,omitempty"`
	// contains filtered or unexported fields
}

type PostsServiceClient interface {
	// SubscribeToPosts makes the local client subscribe to a remote user's posts.
	SubscribeToPosts(ctx context.Context, in *SubscribeToPostsRequest, out *SubscribeToPostsResponse) error
	// UnsubscribeToPosts makes the local client unsubscribe from a remote user's posts.
	UnsubscribeToPosts(ctx context.Context, in *UnsubscribeToPostsRequest, out *UnsubscribeToPostsResponse) error
	// PostsStream creates a stream that receives updates about posts received
	// from remote users the local client is subscribed to.
	PostsStream(ctx context.Context, in *PostsStreamRequest) (PostsService_PostsStreamClient, error)
	// AckReceivedPost acknowledges posts received up to a given sequence_id have
	// been processed.
	AckReceivedPost(ctx context.Context, in *AckRequest, out *AckResponse) error
	// PostsStatusStream creates a stream that receives updates about post status
	// events (comments, replies, etc).
	PostsStatusStream(ctx context.Context, in *PostsStatusStreamRequest) (PostsService_PostsStatusStreamClient, error)
	// AckReceivedPostStatus acknowledges post status received up to a given
	// sequence_id have been processed.
	AckReceivedPostStatus(ctx context.Context, in *AckRequest, out *AckResponse) error
}

type PostsServiceServer interface {
	// SubscribeToPosts makes the local client subscribe to a remote user's posts.
	SubscribeToPosts(context.Context, *SubscribeToPostsRequest, *SubscribeToPostsResponse) error
	// UnsubscribeToPosts makes the local client unsubscribe from a remote user's posts.
	UnsubscribeToPosts(context.Context, *UnsubscribeToPostsRequest, *UnsubscribeToPostsResponse) error
	// PostsStream creates a stream that receives updates about posts received
	// from remote users the local client is subscribed to.
	PostsStream(context.Context, *PostsStreamRequest, PostsService_PostsStreamServer) error
	// AckReceivedPost acknowledges posts received up to a given sequence_id have
	// been processed.
	AckReceivedPost(context.Context, *AckRequest, *AckResponse) error
	// PostsStatusStream creates a stream that receives updates about post status
	// events (comments, replies, etc).
	PostsStatusStream(context.Context, *PostsStatusStreamRequest, PostsService_PostsStatusStreamServer) error
	// AckReceivedPostStatus acknowledges post status received up to a given
	// sequence_id have been processed.
	AckReceivedPostStatus(context.Context, *AckRequest, *AckResponse) error
}

type PostsService_PostsStatusStreamClient interface {
	Recv(*ReceivedPostStatus) error
}

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

type PostsService_PostsStreamClient interface {
	Recv(*ReceivedPost) error
}

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

type PostsStatusStreamRequest struct {

	// unacked_from specifies to the server the sequence_id of the last processed
	// Post Status. Post Status received by the server that have a higher
	// sequence_id will be streamed back to the client.
	UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"`
	// contains filtered or unexported fields
}

type PostsStreamRequest struct {

	// unacked_from specifies to the server the sequence_id of the last processed
	// post. Posts received by the server that have a higher sequence_id will be
	// streamed back to the client.
	UnackedFrom uint64 `protobuf:"varint,1,opt,name=unacked_from,json=unackedFrom,proto3" json:"unacked_from,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

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
}

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
}

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"`
	// contains filtered or unexported fields
}

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

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

type ServiceDefn struct {
	Name    string
	Methods map[string]MethodDefn
}

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
}

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

type TipUserRequest struct {

	// user is the remote user nick or hex-encoded ID.
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// dcr_amount is the DCR amount to send as tip.
	DcrAmount float64 `protobuf:"fixed64,2,opt,name=dcr_amount,json=dcrAmount,proto3" json:"dcr_amount,omitempty"`
	// contains filtered or unexported fields
}

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

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
}

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

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

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
}

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

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
}

type VersionService_KeepaliveStreamClient interface {
	Recv(*KeepaliveEvent) error
}

type VersionService_KeepaliveStreamServer interface {
	Send(m *KeepaliveEvent) error
}