apiv1

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2024 License: MIT Imports: 19 Imported by: 0

Documentation

Overview

Package apiv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	MlsApi_SendGroupMessages_FullMethodName        = "/xmtp.mls.api.v1.MlsApi/SendGroupMessages"
	MlsApi_SendWelcomeMessages_FullMethodName      = "/xmtp.mls.api.v1.MlsApi/SendWelcomeMessages"
	MlsApi_RegisterInstallation_FullMethodName     = "/xmtp.mls.api.v1.MlsApi/RegisterInstallation"
	MlsApi_UploadKeyPackage_FullMethodName         = "/xmtp.mls.api.v1.MlsApi/UploadKeyPackage"
	MlsApi_FetchKeyPackages_FullMethodName         = "/xmtp.mls.api.v1.MlsApi/FetchKeyPackages"
	MlsApi_RevokeInstallation_FullMethodName       = "/xmtp.mls.api.v1.MlsApi/RevokeInstallation"
	MlsApi_GetIdentityUpdates_FullMethodName       = "/xmtp.mls.api.v1.MlsApi/GetIdentityUpdates"
	MlsApi_QueryGroupMessages_FullMethodName       = "/xmtp.mls.api.v1.MlsApi/QueryGroupMessages"
	MlsApi_QueryWelcomeMessages_FullMethodName     = "/xmtp.mls.api.v1.MlsApi/QueryWelcomeMessages"
	MlsApi_SubscribeGroupMessages_FullMethodName   = "/xmtp.mls.api.v1.MlsApi/SubscribeGroupMessages"
	MlsApi_SubscribeWelcomeMessages_FullMethodName = "/xmtp.mls.api.v1.MlsApi/SubscribeWelcomeMessages"
)

Variables

View Source 
var (
	SortDirection_name = map[int32]string{
		0: "SORT_DIRECTION_UNSPECIFIED",
		1: "SORT_DIRECTION_ASCENDING",
		2: "SORT_DIRECTION_DESCENDING",
	}
	SortDirection_value = map[string]int32{
		"SORT_DIRECTION_UNSPECIFIED": 0,
		"SORT_DIRECTION_ASCENDING":   1,
		"SORT_DIRECTION_DESCENDING":  2,
	}
)

Enum value maps for SortDirection.

View Source 
var File_mls_api_v1_mls_proto protoreflect.FileDescriptor
View Source 
var MlsApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "xmtp.mls.api.v1.MlsApi",
	HandlerType: (*MlsApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendGroupMessages",
			Handler:    _MlsApi_SendGroupMessages_Handler,
		},
		{
			MethodName: "SendWelcomeMessages",
			Handler:    _MlsApi_SendWelcomeMessages_Handler,
		},
		{
			MethodName: "RegisterInstallation",
			Handler:    _MlsApi_RegisterInstallation_Handler,
		},
		{
			MethodName: "UploadKeyPackage",
			Handler:    _MlsApi_UploadKeyPackage_Handler,
		},
		{
			MethodName: "FetchKeyPackages",
			Handler:    _MlsApi_FetchKeyPackages_Handler,
		},
		{
			MethodName: "RevokeInstallation",
			Handler:    _MlsApi_RevokeInstallation_Handler,
		},
		{
			MethodName: "GetIdentityUpdates",
			Handler:    _MlsApi_GetIdentityUpdates_Handler,
		},
		{
			MethodName: "QueryGroupMessages",
			Handler:    _MlsApi_QueryGroupMessages_Handler,
		},
		{
			MethodName: "QueryWelcomeMessages",
			Handler:    _MlsApi_QueryWelcomeMessages_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeGroupMessages",
			Handler:       _MlsApi_SubscribeGroupMessages_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeWelcomeMessages",
			Handler:       _MlsApi_SubscribeWelcomeMessages_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "mls/api/v1/mls.proto",
}

MlsApi_ServiceDesc is the grpc.ServiceDesc for MlsApi service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMlsApiHandler 

func RegisterMlsApiHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMlsApiHandler registers the http handlers for service MlsApi to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMlsApiHandlerClient 

func RegisterMlsApiHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MlsApiClient) error

RegisterMlsApiHandlerClient registers the http handlers for service MlsApi to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MlsApiClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MlsApiClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MlsApiClient" to call the correct interceptors.

func RegisterMlsApiHandlerFromEndpoint 

func RegisterMlsApiHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMlsApiHandlerFromEndpoint is same as RegisterMlsApiHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMlsApiHandlerServer 

func RegisterMlsApiHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MlsApiServer) error

RegisterMlsApiHandlerServer registers the http handlers for service MlsApi to "mux". UnaryRPC :call MlsApiServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMlsApiHandlerFromEndpoint instead.

func RegisterMlsApiServer 

func RegisterMlsApiServer(s grpc.ServiceRegistrar, srv MlsApiServer)

Types

type FetchKeyPackagesRequest 

type FetchKeyPackagesRequest struct {

	// The caller can provide an array of installation keys, and the API
	// will return one key package for each installation associated with each
	// installation key
	InstallationKeys [][]byte `protobuf:"bytes,1,rep,name=installation_keys,json=installationKeys,proto3" json:"installation_keys,omitempty"`
	// contains filtered or unexported fields
}

Fetch one or more key packages

func (*FetchKeyPackagesRequest) Descriptor deprecated 

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

Deprecated: Use FetchKeyPackagesRequest.ProtoReflect.Descriptor instead.

func (*FetchKeyPackagesRequest) GetInstallationKeys 

func (x *FetchKeyPackagesRequest) GetInstallationKeys() [][]byte

func (*FetchKeyPackagesRequest) ProtoMessage 

func (*FetchKeyPackagesRequest) ProtoMessage()

func (*FetchKeyPackagesRequest) ProtoReflect 

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

func (*FetchKeyPackagesRequest) Reset 

func (x *FetchKeyPackagesRequest) Reset()

func (*FetchKeyPackagesRequest) String 

func (x *FetchKeyPackagesRequest) String() string

type FetchKeyPackagesResponse 

type FetchKeyPackagesResponse struct {

	// Returns one key package per installation in the original order of the
	// request. If any installations are missing key packages, an empty entry is
	// left in their respective spots in the array.
	KeyPackages []*FetchKeyPackagesResponse_KeyPackage `protobuf:"bytes,1,rep,name=key_packages,json=keyPackages,proto3" json:"key_packages,omitempty"`
	// contains filtered or unexported fields
}

The response to a FetchKeyPackagesRequest

func (*FetchKeyPackagesResponse) Descriptor deprecated 

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

Deprecated: Use FetchKeyPackagesResponse.ProtoReflect.Descriptor instead.

func (*FetchKeyPackagesResponse) GetKeyPackages 

func (x *FetchKeyPackagesResponse) GetKeyPackages() []*FetchKeyPackagesResponse_KeyPackage

func (*FetchKeyPackagesResponse) ProtoMessage 

func (*FetchKeyPackagesResponse) ProtoMessage()

func (*FetchKeyPackagesResponse) ProtoReflect 

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

func (*FetchKeyPackagesResponse) Reset 

func (x *FetchKeyPackagesResponse) Reset()

func (*FetchKeyPackagesResponse) String 

func (x *FetchKeyPackagesResponse) String() string

type FetchKeyPackagesResponse_KeyPackage 

type FetchKeyPackagesResponse_KeyPackage struct {
	KeyPackageTlsSerialized []byte `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

An individual key package

func (*FetchKeyPackagesResponse_KeyPackage) Descriptor deprecated 

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

Deprecated: Use FetchKeyPackagesResponse_KeyPackage.ProtoReflect.Descriptor instead.

func (*FetchKeyPackagesResponse_KeyPackage) GetKeyPackageTlsSerialized 

func (x *FetchKeyPackagesResponse_KeyPackage) GetKeyPackageTlsSerialized() []byte

func (*FetchKeyPackagesResponse_KeyPackage) ProtoMessage 

func (*FetchKeyPackagesResponse_KeyPackage) ProtoMessage()

func (*FetchKeyPackagesResponse_KeyPackage) ProtoReflect 

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

func (*FetchKeyPackagesResponse_KeyPackage) Reset 

func (x *FetchKeyPackagesResponse_KeyPackage) Reset()

func (*FetchKeyPackagesResponse_KeyPackage) String 

func (x *FetchKeyPackagesResponse_KeyPackage) String() string

type GetIdentityUpdatesRequest 

type GetIdentityUpdatesRequest struct {
	AccountAddresses []string `protobuf:"bytes,1,rep,name=account_addresses,json=accountAddresses,proto3" json:"account_addresses,omitempty"`
	StartTimeNs      uint64   `protobuf:"varint,2,opt,name=start_time_ns,json=startTimeNs,proto3" json:"start_time_ns,omitempty"`
	// contains filtered or unexported fields
}

Get all updates for an identity since the specified time

func (*GetIdentityUpdatesRequest) Descriptor deprecated 

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

Deprecated: Use GetIdentityUpdatesRequest.ProtoReflect.Descriptor instead.

func (*GetIdentityUpdatesRequest) GetAccountAddresses 

func (x *GetIdentityUpdatesRequest) GetAccountAddresses() []string

func (*GetIdentityUpdatesRequest) GetStartTimeNs 

func (x *GetIdentityUpdatesRequest) GetStartTimeNs() uint64

func (*GetIdentityUpdatesRequest) ProtoMessage 

func (*GetIdentityUpdatesRequest) ProtoMessage()

func (*GetIdentityUpdatesRequest) ProtoReflect 

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

func (*GetIdentityUpdatesRequest) Reset 

func (x *GetIdentityUpdatesRequest) Reset()

func (*GetIdentityUpdatesRequest) String 

func (x *GetIdentityUpdatesRequest) String() string

type GetIdentityUpdatesResponse 

type GetIdentityUpdatesResponse struct {

	// A list of updates (or empty objects if no changes) in the original order
	// of the request
	Updates []*GetIdentityUpdatesResponse_WalletUpdates `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty"`
	// contains filtered or unexported fields
}

Used to get any new or revoked installations for a list of wallet addresses

func (*GetIdentityUpdatesResponse) Descriptor deprecated 

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

Deprecated: Use GetIdentityUpdatesResponse.ProtoReflect.Descriptor instead.

func (*GetIdentityUpdatesResponse) GetUpdates 

func (x *GetIdentityUpdatesResponse) GetUpdates() []*GetIdentityUpdatesResponse_WalletUpdates

func (*GetIdentityUpdatesResponse) ProtoMessage 

func (*GetIdentityUpdatesResponse) ProtoMessage()

func (*GetIdentityUpdatesResponse) ProtoReflect 

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

func (*GetIdentityUpdatesResponse) Reset 

func (x *GetIdentityUpdatesResponse) Reset()

func (*GetIdentityUpdatesResponse) String 

func (x *GetIdentityUpdatesResponse) String() string

type GetIdentityUpdatesResponse_NewInstallationUpdate 

type GetIdentityUpdatesResponse_NewInstallationUpdate struct {
	InstallationKey    []byte `protobuf:"bytes,1,opt,name=installation_key,json=installationKey,proto3" json:"installation_key,omitempty"`
	CredentialIdentity []byte `protobuf:"bytes,2,opt,name=credential_identity,json=credentialIdentity,proto3" json:"credential_identity,omitempty"`
	// contains filtered or unexported fields
}

A new installation key was seen for the first time by the nodes

func (*GetIdentityUpdatesResponse_NewInstallationUpdate) Descriptor deprecated 

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

Deprecated: Use GetIdentityUpdatesResponse_NewInstallationUpdate.ProtoReflect.Descriptor instead.

func (*GetIdentityUpdatesResponse_NewInstallationUpdate) GetCredentialIdentity 

func (x *GetIdentityUpdatesResponse_NewInstallationUpdate) GetCredentialIdentity() []byte

func (*GetIdentityUpdatesResponse_NewInstallationUpdate) GetInstallationKey 

func (x *GetIdentityUpdatesResponse_NewInstallationUpdate) GetInstallationKey() []byte

func (*GetIdentityUpdatesResponse_NewInstallationUpdate) ProtoMessage 

func (*GetIdentityUpdatesResponse_NewInstallationUpdate) ProtoMessage()

func (*GetIdentityUpdatesResponse_NewInstallationUpdate) ProtoReflect 

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

func (*GetIdentityUpdatesResponse_NewInstallationUpdate) Reset 

func (x *GetIdentityUpdatesResponse_NewInstallationUpdate) Reset()

func (*GetIdentityUpdatesResponse_NewInstallationUpdate) String 

func (x *GetIdentityUpdatesResponse_NewInstallationUpdate) String() string

type GetIdentityUpdatesResponse_RevokedInstallationUpdate 

type GetIdentityUpdatesResponse_RevokedInstallationUpdate struct {
	InstallationKey []byte `protobuf:"bytes,1,opt,name=installation_key,json=installationKey,proto3" json:"installation_key,omitempty"`
	// contains filtered or unexported fields
}

An installation was revoked

func (*GetIdentityUpdatesResponse_RevokedInstallationUpdate) Descriptor deprecated 

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

Deprecated: Use GetIdentityUpdatesResponse_RevokedInstallationUpdate.ProtoReflect.Descriptor instead.

func (*GetIdentityUpdatesResponse_RevokedInstallationUpdate) GetInstallationKey 

func (x *GetIdentityUpdatesResponse_RevokedInstallationUpdate) GetInstallationKey() []byte

func (*GetIdentityUpdatesResponse_RevokedInstallationUpdate) ProtoMessage 

func (*GetIdentityUpdatesResponse_RevokedInstallationUpdate) ProtoMessage()

func (*GetIdentityUpdatesResponse_RevokedInstallationUpdate) ProtoReflect 

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

func (*GetIdentityUpdatesResponse_RevokedInstallationUpdate) Reset 

func (x *GetIdentityUpdatesResponse_RevokedInstallationUpdate) Reset()

func (*GetIdentityUpdatesResponse_RevokedInstallationUpdate) String 

func (x *GetIdentityUpdatesResponse_RevokedInstallationUpdate) String() string

type GetIdentityUpdatesResponse_Update 

type GetIdentityUpdatesResponse_Update struct {
	TimestampNs uint64 `protobuf:"varint,1,opt,name=timestamp_ns,json=timestampNs,proto3" json:"timestamp_ns,omitempty"`
	// Types that are assignable to Kind:
	//
	//	*GetIdentityUpdatesResponse_Update_NewInstallation
	//	*GetIdentityUpdatesResponse_Update_RevokedInstallation
	Kind isGetIdentityUpdatesResponse_Update_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

A wrapper for any update to the wallet

func (*GetIdentityUpdatesResponse_Update) Descriptor deprecated 

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

Deprecated: Use GetIdentityUpdatesResponse_Update.ProtoReflect.Descriptor instead.

func (*GetIdentityUpdatesResponse_Update) GetKind 

func (m *GetIdentityUpdatesResponse_Update) GetKind() isGetIdentityUpdatesResponse_Update_Kind

func (*GetIdentityUpdatesResponse_Update) GetNewInstallation 

func (x *GetIdentityUpdatesResponse_Update) GetNewInstallation() *GetIdentityUpdatesResponse_NewInstallationUpdate

func (*GetIdentityUpdatesResponse_Update) GetRevokedInstallation 

func (x *GetIdentityUpdatesResponse_Update) GetRevokedInstallation() *GetIdentityUpdatesResponse_RevokedInstallationUpdate

func (*GetIdentityUpdatesResponse_Update) GetTimestampNs 

func (x *GetIdentityUpdatesResponse_Update) GetTimestampNs() uint64

func (*GetIdentityUpdatesResponse_Update) ProtoMessage 

func (*GetIdentityUpdatesResponse_Update) ProtoMessage()

func (*GetIdentityUpdatesResponse_Update) ProtoReflect 

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

func (*GetIdentityUpdatesResponse_Update) Reset 

func (x *GetIdentityUpdatesResponse_Update) Reset()

func (*GetIdentityUpdatesResponse_Update) String 

func (x *GetIdentityUpdatesResponse_Update) String() string

type GetIdentityUpdatesResponse_Update_NewInstallation 

type GetIdentityUpdatesResponse_Update_NewInstallation struct {
	NewInstallation *GetIdentityUpdatesResponse_NewInstallationUpdate `protobuf:"bytes,2,opt,name=new_installation,json=newInstallation,proto3,oneof"`
}

type GetIdentityUpdatesResponse_Update_RevokedInstallation 

type GetIdentityUpdatesResponse_Update_RevokedInstallation struct {
	RevokedInstallation *GetIdentityUpdatesResponse_RevokedInstallationUpdate `protobuf:"bytes,3,opt,name=revoked_installation,json=revokedInstallation,proto3,oneof"`
}

type GetIdentityUpdatesResponse_WalletUpdates 

type GetIdentityUpdatesResponse_WalletUpdates struct {
	Updates []*GetIdentityUpdatesResponse_Update `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty"`
	// contains filtered or unexported fields
}

A wrapper for the updates for a single wallet

func (*GetIdentityUpdatesResponse_WalletUpdates) Descriptor deprecated 

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

Deprecated: Use GetIdentityUpdatesResponse_WalletUpdates.ProtoReflect.Descriptor instead.

func (*GetIdentityUpdatesResponse_WalletUpdates) GetUpdates 

func (x *GetIdentityUpdatesResponse_WalletUpdates) GetUpdates() []*GetIdentityUpdatesResponse_Update

func (*GetIdentityUpdatesResponse_WalletUpdates) ProtoMessage 

func (*GetIdentityUpdatesResponse_WalletUpdates) ProtoMessage()

func (*GetIdentityUpdatesResponse_WalletUpdates) ProtoReflect 

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

func (*GetIdentityUpdatesResponse_WalletUpdates) Reset 

func (x *GetIdentityUpdatesResponse_WalletUpdates) Reset()

func (*GetIdentityUpdatesResponse_WalletUpdates) String 

func (x *GetIdentityUpdatesResponse_WalletUpdates) String() string

type GroupMessage 

type GroupMessage struct {

	// Types that are assignable to Version:
	//
	//	*GroupMessage_V1_
	Version isGroupMessage_Version `protobuf_oneof:"version"`
	// contains filtered or unexported fields
}

Full representation of a group message

func (*GroupMessage) Descriptor deprecated 

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

Deprecated: Use GroupMessage.ProtoReflect.Descriptor instead.

func (*GroupMessage) GetV1 

func (x *GroupMessage) GetV1() *GroupMessage_V1

func (*GroupMessage) GetVersion 

func (m *GroupMessage) GetVersion() isGroupMessage_Version

func (*GroupMessage) ProtoMessage 

func (*GroupMessage) ProtoMessage()

func (*GroupMessage) ProtoReflect 

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

func (*GroupMessage) Reset 

func (x *GroupMessage) Reset()

func (*GroupMessage) String 

func (x *GroupMessage) String() string

type GroupMessageInput 

type GroupMessageInput struct {

	// Types that are assignable to Version:
	//
	//	*GroupMessageInput_V1_
	Version isGroupMessageInput_Version `protobuf_oneof:"version"`
	// contains filtered or unexported fields
}

Input type for a group message

func (*GroupMessageInput) Descriptor deprecated 

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

Deprecated: Use GroupMessageInput.ProtoReflect.Descriptor instead.

func (*GroupMessageInput) GetV1 

func (x *GroupMessageInput) GetV1() *GroupMessageInput_V1

func (*GroupMessageInput) GetVersion 

func (m *GroupMessageInput) GetVersion() isGroupMessageInput_Version

func (*GroupMessageInput) ProtoMessage 

func (*GroupMessageInput) ProtoMessage()

func (*GroupMessageInput) ProtoReflect 

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

func (*GroupMessageInput) Reset 

func (x *GroupMessageInput) Reset()

func (*GroupMessageInput) String 

func (x *GroupMessageInput) String() string

type GroupMessageInput_V1 

type GroupMessageInput_V1 struct {
	Data       []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // Serialized MlsProtocolMessage
	SenderHmac []byte `protobuf:"bytes,2,opt,name=sender_hmac,json=senderHmac,proto3" json:"sender_hmac,omitempty"`
	// contains filtered or unexported fields
}

Version 1 of the GroupMessageInput payload format

func (*GroupMessageInput_V1) Descriptor deprecated 

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

Deprecated: Use GroupMessageInput_V1.ProtoReflect.Descriptor instead.

func (*GroupMessageInput_V1) GetData 

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

func (*GroupMessageInput_V1) GetSenderHmac 

func (x *GroupMessageInput_V1) GetSenderHmac() []byte

func (*GroupMessageInput_V1) ProtoMessage 

func (*GroupMessageInput_V1) ProtoMessage()

func (*GroupMessageInput_V1) ProtoReflect 

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

func (*GroupMessageInput_V1) Reset 

func (x *GroupMessageInput_V1) Reset()

func (*GroupMessageInput_V1) String 

func (x *GroupMessageInput_V1) String() string

type GroupMessageInput_V1_ 

type GroupMessageInput_V1_ struct {
	V1 *GroupMessageInput_V1 `protobuf:"bytes,1,opt,name=v1,proto3,oneof"`
}

type GroupMessage_V1 

type GroupMessage_V1 struct {
	Id         uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedNs  uint64 `protobuf:"varint,2,opt,name=created_ns,json=createdNs,proto3" json:"created_ns,omitempty"`
	GroupId    []byte `protobuf:"bytes,3,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Data       []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	SenderHmac []byte `protobuf:"bytes,5,opt,name=sender_hmac,json=senderHmac,proto3" json:"sender_hmac,omitempty"`
	// contains filtered or unexported fields
}

Version 1 of the GroupMessage format

func (*GroupMessage_V1) Descriptor deprecated 

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

Deprecated: Use GroupMessage_V1.ProtoReflect.Descriptor instead.

func (*GroupMessage_V1) GetCreatedNs 

func (x *GroupMessage_V1) GetCreatedNs() uint64

func (*GroupMessage_V1) GetData 

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

func (*GroupMessage_V1) GetGroupId 

func (x *GroupMessage_V1) GetGroupId() []byte

func (*GroupMessage_V1) GetId 

func (x *GroupMessage_V1) GetId() uint64

func (*GroupMessage_V1) GetSenderHmac 

func (x *GroupMessage_V1) GetSenderHmac() []byte

func (*GroupMessage_V1) ProtoMessage 

func (*GroupMessage_V1) ProtoMessage()

func (*GroupMessage_V1) ProtoReflect 

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

func (*GroupMessage_V1) Reset 

func (x *GroupMessage_V1) Reset()

func (*GroupMessage_V1) String 

func (x *GroupMessage_V1) String() string

type GroupMessage_V1_ 

type GroupMessage_V1_ struct {
	V1 *GroupMessage_V1 `protobuf:"bytes,1,opt,name=v1,proto3,oneof"`
}

type KeyPackageUpload 

type KeyPackageUpload struct {

	// The owner's wallet address would be extracted from the identity
	// credential in the key package, and all signatures would be validated.
	KeyPackageTlsSerialized []byte `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

A wrapper around the Key Package bytes

func (*KeyPackageUpload) Descriptor deprecated 

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

Deprecated: Use KeyPackageUpload.ProtoReflect.Descriptor instead.

func (*KeyPackageUpload) GetKeyPackageTlsSerialized 

func (x *KeyPackageUpload) GetKeyPackageTlsSerialized() []byte

func (*KeyPackageUpload) ProtoMessage 

func (*KeyPackageUpload) ProtoMessage()

func (*KeyPackageUpload) ProtoReflect 

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

func (*KeyPackageUpload) Reset 

func (x *KeyPackageUpload) Reset()

func (*KeyPackageUpload) String 

func (x *KeyPackageUpload) String() string

type MlsApiClient 

type MlsApiClient interface {
	// Send a MLS payload, that would be validated before being stored to the
	// network
	SendGroupMessages(ctx context.Context, in *SendGroupMessagesRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Send a batch of welcome messages
	SendWelcomeMessages(ctx context.Context, in *SendWelcomeMessagesRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Register a new installation, which would be validated before storage
	RegisterInstallation(ctx context.Context, in *RegisterInstallationRequest, opts ...grpc.CallOption) (*RegisterInstallationResponse, error)
	// Upload a new KeyPackage, which would be validated before storage
	UploadKeyPackage(ctx context.Context, in *UploadKeyPackageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Get one or more Key Packages by installation_id
	FetchKeyPackages(ctx context.Context, in *FetchKeyPackagesRequest, opts ...grpc.CallOption) (*FetchKeyPackagesResponse, error)
	// Would delete all key packages associated with the installation and mark
	// the installation as having been revoked
	RevokeInstallation(ctx context.Context, in *RevokeInstallationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Used to check for changes related to members of a group.
	// Would return an array of any new installations associated with the wallet
	// address, and any revocations that have happened.
	GetIdentityUpdates(ctx context.Context, in *GetIdentityUpdatesRequest, opts ...grpc.CallOption) (*GetIdentityUpdatesResponse, error)
	// Query stored group messages
	QueryGroupMessages(ctx context.Context, in *QueryGroupMessagesRequest, opts ...grpc.CallOption) (*QueryGroupMessagesResponse, error)
	// Query stored group messages
	QueryWelcomeMessages(ctx context.Context, in *QueryWelcomeMessagesRequest, opts ...grpc.CallOption) (*QueryWelcomeMessagesResponse, error)
	// Subscribe stream of new group messages
	SubscribeGroupMessages(ctx context.Context, in *SubscribeGroupMessagesRequest, opts ...grpc.CallOption) (MlsApi_SubscribeGroupMessagesClient, error)
	// Subscribe stream of new welcome messages
	SubscribeWelcomeMessages(ctx context.Context, in *SubscribeWelcomeMessagesRequest, opts ...grpc.CallOption) (MlsApi_SubscribeWelcomeMessagesClient, error)
}

MlsApiClient is the client API for MlsApi service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMlsApiClient 

func NewMlsApiClient(cc grpc.ClientConnInterface) MlsApiClient

type MlsApiServer 

type MlsApiServer interface {
	// Send a MLS payload, that would be validated before being stored to the
	// network
	SendGroupMessages(context.Context, *SendGroupMessagesRequest) (*emptypb.Empty, error)
	// Send a batch of welcome messages
	SendWelcomeMessages(context.Context, *SendWelcomeMessagesRequest) (*emptypb.Empty, error)
	// Register a new installation, which would be validated before storage
	RegisterInstallation(context.Context, *RegisterInstallationRequest) (*RegisterInstallationResponse, error)
	// Upload a new KeyPackage, which would be validated before storage
	UploadKeyPackage(context.Context, *UploadKeyPackageRequest) (*emptypb.Empty, error)
	// Get one or more Key Packages by installation_id
	FetchKeyPackages(context.Context, *FetchKeyPackagesRequest) (*FetchKeyPackagesResponse, error)
	// Would delete all key packages associated with the installation and mark
	// the installation as having been revoked
	RevokeInstallation(context.Context, *RevokeInstallationRequest) (*emptypb.Empty, error)
	// Used to check for changes related to members of a group.
	// Would return an array of any new installations associated with the wallet
	// address, and any revocations that have happened.
	GetIdentityUpdates(context.Context, *GetIdentityUpdatesRequest) (*GetIdentityUpdatesResponse, error)
	// Query stored group messages
	QueryGroupMessages(context.Context, *QueryGroupMessagesRequest) (*QueryGroupMessagesResponse, error)
	// Query stored group messages
	QueryWelcomeMessages(context.Context, *QueryWelcomeMessagesRequest) (*QueryWelcomeMessagesResponse, error)
	// Subscribe stream of new group messages
	SubscribeGroupMessages(*SubscribeGroupMessagesRequest, MlsApi_SubscribeGroupMessagesServer) error
	// Subscribe stream of new welcome messages
	SubscribeWelcomeMessages(*SubscribeWelcomeMessagesRequest, MlsApi_SubscribeWelcomeMessagesServer) error
	// contains filtered or unexported methods
}

MlsApiServer is the server API for MlsApi service. All implementations must embed UnimplementedMlsApiServer for forward compatibility

type MlsApi_SubscribeGroupMessagesClient 

type MlsApi_SubscribeGroupMessagesClient interface {
	Recv() (*GroupMessage, error)
	grpc.ClientStream
}

type MlsApi_SubscribeGroupMessagesServer 

type MlsApi_SubscribeGroupMessagesServer interface {
	Send(*GroupMessage) error
	grpc.ServerStream
}

type MlsApi_SubscribeWelcomeMessagesClient 

type MlsApi_SubscribeWelcomeMessagesClient interface {
	Recv() (*WelcomeMessage, error)
	grpc.ClientStream
}

type MlsApi_SubscribeWelcomeMessagesServer 

type MlsApi_SubscribeWelcomeMessagesServer interface {
	Send(*WelcomeMessage) error
	grpc.ServerStream
}

type PagingInfo 

type PagingInfo struct {
	Direction SortDirection `protobuf:"varint,1,opt,name=direction,proto3,enum=xmtp.mls.api.v1.SortDirection" json:"direction,omitempty"`
	Limit     uint32        `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	IdCursor  uint64        `protobuf:"varint,3,opt,name=id_cursor,json=idCursor,proto3" json:"id_cursor,omitempty"`
	// contains filtered or unexported fields
}

Pagination config for queries

func (*PagingInfo) Descriptor deprecated 

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

Deprecated: Use PagingInfo.ProtoReflect.Descriptor instead.

func (*PagingInfo) GetDirection 

func (x *PagingInfo) GetDirection() SortDirection

func (*PagingInfo) GetIdCursor 

func (x *PagingInfo) GetIdCursor() uint64

func (*PagingInfo) GetLimit 

func (x *PagingInfo) GetLimit() uint32

func (*PagingInfo) ProtoMessage 

func (*PagingInfo) ProtoMessage()

func (*PagingInfo) ProtoReflect 

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

func (*PagingInfo) Reset 

func (x *PagingInfo) Reset()

func (*PagingInfo) String 

func (x *PagingInfo) String() string

type QueryGroupMessagesRequest 

type QueryGroupMessagesRequest struct {
	GroupId    []byte      `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	PagingInfo *PagingInfo `protobuf:"bytes,2,opt,name=paging_info,json=pagingInfo,proto3" json:"paging_info,omitempty"`
	// contains filtered or unexported fields
}

Request for group message queries

func (*QueryGroupMessagesRequest) Descriptor deprecated 

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

Deprecated: Use QueryGroupMessagesRequest.ProtoReflect.Descriptor instead.

func (*QueryGroupMessagesRequest) GetGroupId 

func (x *QueryGroupMessagesRequest) GetGroupId() []byte

func (*QueryGroupMessagesRequest) GetPagingInfo 

func (x *QueryGroupMessagesRequest) GetPagingInfo() *PagingInfo

func (*QueryGroupMessagesRequest) ProtoMessage 

func (*QueryGroupMessagesRequest) ProtoMessage()

func (*QueryGroupMessagesRequest) ProtoReflect 

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

func (*QueryGroupMessagesRequest) Reset 

func (x *QueryGroupMessagesRequest) Reset()

func (*QueryGroupMessagesRequest) String 

func (x *QueryGroupMessagesRequest) String() string

type QueryGroupMessagesResponse 

type QueryGroupMessagesResponse struct {
	Messages   []*GroupMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	PagingInfo *PagingInfo     `protobuf:"bytes,2,opt,name=paging_info,json=pagingInfo,proto3" json:"paging_info,omitempty"`
	// contains filtered or unexported fields
}

Response for group message queries

func (*QueryGroupMessagesResponse) Descriptor deprecated 

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

Deprecated: Use QueryGroupMessagesResponse.ProtoReflect.Descriptor instead.

func (*QueryGroupMessagesResponse) GetMessages 

func (x *QueryGroupMessagesResponse) GetMessages() []*GroupMessage

func (*QueryGroupMessagesResponse) GetPagingInfo 

func (x *QueryGroupMessagesResponse) GetPagingInfo() *PagingInfo

func (*QueryGroupMessagesResponse) ProtoMessage 

func (*QueryGroupMessagesResponse) ProtoMessage()

func (*QueryGroupMessagesResponse) ProtoReflect 

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

func (*QueryGroupMessagesResponse) Reset 

func (x *QueryGroupMessagesResponse) Reset()

func (*QueryGroupMessagesResponse) String 

func (x *QueryGroupMessagesResponse) String() string

type QueryWelcomeMessagesRequest 

type QueryWelcomeMessagesRequest struct {
	InstallationKey []byte      `protobuf:"bytes,1,opt,name=installation_key,json=installationKey,proto3" json:"installation_key,omitempty"`
	PagingInfo      *PagingInfo `protobuf:"bytes,2,opt,name=paging_info,json=pagingInfo,proto3" json:"paging_info,omitempty"`
	// contains filtered or unexported fields
}

Request for welcome message queries

func (*QueryWelcomeMessagesRequest) Descriptor deprecated 

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

Deprecated: Use QueryWelcomeMessagesRequest.ProtoReflect.Descriptor instead.

func (*QueryWelcomeMessagesRequest) GetInstallationKey 

func (x *QueryWelcomeMessagesRequest) GetInstallationKey() []byte

func (*QueryWelcomeMessagesRequest) GetPagingInfo 

func (x *QueryWelcomeMessagesRequest) GetPagingInfo() *PagingInfo

func (*QueryWelcomeMessagesRequest) ProtoMessage 

func (*QueryWelcomeMessagesRequest) ProtoMessage()

func (*QueryWelcomeMessagesRequest) ProtoReflect 

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

func (*QueryWelcomeMessagesRequest) Reset 

func (x *QueryWelcomeMessagesRequest) Reset()

func (*QueryWelcomeMessagesRequest) String 

func (x *QueryWelcomeMessagesRequest) String() string

type QueryWelcomeMessagesResponse 

type QueryWelcomeMessagesResponse struct {
	Messages   []*WelcomeMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	PagingInfo *PagingInfo       `protobuf:"bytes,2,opt,name=paging_info,json=pagingInfo,proto3" json:"paging_info,omitempty"`
	// contains filtered or unexported fields
}

Response for welcome message queries

func (*QueryWelcomeMessagesResponse) Descriptor deprecated 

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

Deprecated: Use QueryWelcomeMessagesResponse.ProtoReflect.Descriptor instead.

func (*QueryWelcomeMessagesResponse) GetMessages 

func (x *QueryWelcomeMessagesResponse) GetMessages() []*WelcomeMessage

func (*QueryWelcomeMessagesResponse) GetPagingInfo 

func (x *QueryWelcomeMessagesResponse) GetPagingInfo() *PagingInfo

func (*QueryWelcomeMessagesResponse) ProtoMessage 

func (*QueryWelcomeMessagesResponse) ProtoMessage()

func (*QueryWelcomeMessagesResponse) ProtoReflect 

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

func (*QueryWelcomeMessagesResponse) Reset 

func (x *QueryWelcomeMessagesResponse) Reset()

func (*QueryWelcomeMessagesResponse) String 

func (x *QueryWelcomeMessagesResponse) String() string

type RegisterInstallationRequest 

type RegisterInstallationRequest struct {

	// The Key Package contains all information needed to register an installation
	KeyPackage          *KeyPackageUpload `protobuf:"bytes,1,opt,name=key_package,json=keyPackage,proto3" json:"key_package,omitempty"`
	IsInboxIdCredential bool              `protobuf:"varint,2,opt,name=is_inbox_id_credential,json=isInboxIdCredential,proto3" json:"is_inbox_id_credential,omitempty"`
	// contains filtered or unexported fields
}

Register a new installation

func (*RegisterInstallationRequest) Descriptor deprecated 

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

Deprecated: Use RegisterInstallationRequest.ProtoReflect.Descriptor instead.

func (*RegisterInstallationRequest) GetIsInboxIdCredential 

func (x *RegisterInstallationRequest) GetIsInboxIdCredential() bool

func (*RegisterInstallationRequest) GetKeyPackage 

func (x *RegisterInstallationRequest) GetKeyPackage() *KeyPackageUpload

func (*RegisterInstallationRequest) ProtoMessage 

func (*RegisterInstallationRequest) ProtoMessage()

func (*RegisterInstallationRequest) ProtoReflect 

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

func (*RegisterInstallationRequest) Reset 

func (x *RegisterInstallationRequest) Reset()

func (*RegisterInstallationRequest) String 

func (x *RegisterInstallationRequest) String() string

type RegisterInstallationResponse 

type RegisterInstallationResponse struct {
	InstallationKey []byte `protobuf:"bytes,1,opt,name=installation_key,json=installationKey,proto3" json:"installation_key,omitempty"`
	// contains filtered or unexported fields
}

The response to a RegisterInstallationRequest

func (*RegisterInstallationResponse) Descriptor deprecated 

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

Deprecated: Use RegisterInstallationResponse.ProtoReflect.Descriptor instead.

func (*RegisterInstallationResponse) GetInstallationKey 

func (x *RegisterInstallationResponse) GetInstallationKey() []byte

func (*RegisterInstallationResponse) ProtoMessage 

func (*RegisterInstallationResponse) ProtoMessage()

func (*RegisterInstallationResponse) ProtoReflect 

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

func (*RegisterInstallationResponse) Reset 

func (x *RegisterInstallationResponse) Reset()

func (*RegisterInstallationResponse) String 

func (x *RegisterInstallationResponse) String() string

type RevokeInstallationRequest 

type RevokeInstallationRequest struct {
	InstallationKey []byte `protobuf:"bytes,1,opt,name=installation_key,json=installationKey,proto3" json:"installation_key,omitempty"`
	// All revocations must be validated with a wallet signature over the
	// installation_id being revoked (and some sort of standard prologue)
	WalletSignature *message_contents.Signature `protobuf:"bytes,2,opt,name=wallet_signature,json=walletSignature,proto3" json:"wallet_signature,omitempty"`
	// contains filtered or unexported fields
}

Revoke an installation

func (*RevokeInstallationRequest) Descriptor deprecated 

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

Deprecated: Use RevokeInstallationRequest.ProtoReflect.Descriptor instead.

func (*RevokeInstallationRequest) GetInstallationKey 

func (x *RevokeInstallationRequest) GetInstallationKey() []byte

func (*RevokeInstallationRequest) GetWalletSignature 

func (x *RevokeInstallationRequest) GetWalletSignature() *message_contents.Signature

func (*RevokeInstallationRequest) ProtoMessage 

func (*RevokeInstallationRequest) ProtoMessage()

func (*RevokeInstallationRequest) ProtoReflect 

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

func (*RevokeInstallationRequest) Reset 

func (x *RevokeInstallationRequest) Reset()

func (*RevokeInstallationRequest) String 

func (x *RevokeInstallationRequest) String() string

type SendGroupMessagesRequest 

type SendGroupMessagesRequest struct {
	Messages []*GroupMessageInput `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

Send a batch of MLS messages

func (*SendGroupMessagesRequest) Descriptor deprecated 

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

Deprecated: Use SendGroupMessagesRequest.ProtoReflect.Descriptor instead.

func (*SendGroupMessagesRequest) GetMessages 

func (x *SendGroupMessagesRequest) GetMessages() []*GroupMessageInput

func (*SendGroupMessagesRequest) ProtoMessage 

func (*SendGroupMessagesRequest) ProtoMessage()

func (*SendGroupMessagesRequest) ProtoReflect 

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

func (*SendGroupMessagesRequest) Reset 

func (x *SendGroupMessagesRequest) Reset()

func (*SendGroupMessagesRequest) String 

func (x *SendGroupMessagesRequest) String() string

type SendWelcomeMessagesRequest 

type SendWelcomeMessagesRequest struct {
	Messages []*WelcomeMessageInput `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

Send a batch of welcome messages

func (*SendWelcomeMessagesRequest) Descriptor deprecated 

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

Deprecated: Use SendWelcomeMessagesRequest.ProtoReflect.Descriptor instead.

func (*SendWelcomeMessagesRequest) GetMessages 

func (x *SendWelcomeMessagesRequest) GetMessages() []*WelcomeMessageInput

func (*SendWelcomeMessagesRequest) ProtoMessage 

func (*SendWelcomeMessagesRequest) ProtoMessage()

func (*SendWelcomeMessagesRequest) ProtoReflect 

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

func (*SendWelcomeMessagesRequest) Reset 

func (x *SendWelcomeMessagesRequest) Reset()

func (*SendWelcomeMessagesRequest) String 

func (x *SendWelcomeMessagesRequest) String() string

type SortDirection 

type SortDirection int32

Sort direction for queries 

const (
	SortDirection_SORT_DIRECTION_UNSPECIFIED SortDirection = 0
	SortDirection_SORT_DIRECTION_ASCENDING   SortDirection = 1
	SortDirection_SORT_DIRECTION_DESCENDING  SortDirection = 2
)

func (SortDirection) Descriptor 

func (SortDirection) Descriptor() protoreflect.EnumDescriptor

func (SortDirection) Enum 

func (x SortDirection) Enum() *SortDirection

func (SortDirection) EnumDescriptor deprecated 

func (SortDirection) EnumDescriptor() ([]byte, []int)

Deprecated: Use SortDirection.Descriptor instead.

func (SortDirection) Number 

func (x SortDirection) Number() protoreflect.EnumNumber

func (SortDirection) String 

func (x SortDirection) String() string

func (SortDirection) Type 

func (SortDirection) Type() protoreflect.EnumType

type SubscribeGroupMessagesRequest 

type SubscribeGroupMessagesRequest struct {
	Filters []*SubscribeGroupMessagesRequest_Filter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

Request for subscribing to group messages

func (*SubscribeGroupMessagesRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeGroupMessagesRequest.ProtoReflect.Descriptor instead.

func (*SubscribeGroupMessagesRequest) GetFilters 

func (x *SubscribeGroupMessagesRequest) GetFilters() []*SubscribeGroupMessagesRequest_Filter

func (*SubscribeGroupMessagesRequest) ProtoMessage 

func (*SubscribeGroupMessagesRequest) ProtoMessage()

func (*SubscribeGroupMessagesRequest) ProtoReflect 

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

func (*SubscribeGroupMessagesRequest) Reset 

func (x *SubscribeGroupMessagesRequest) Reset()

func (*SubscribeGroupMessagesRequest) String 

func (x *SubscribeGroupMessagesRequest) String() string

type SubscribeGroupMessagesRequest_Filter 

type SubscribeGroupMessagesRequest_Filter struct {
	GroupId  []byte `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	IdCursor uint64 `protobuf:"varint,2,opt,name=id_cursor,json=idCursor,proto3" json:"id_cursor,omitempty"`
	// contains filtered or unexported fields
}

Subscription filter

func (*SubscribeGroupMessagesRequest_Filter) Descriptor deprecated 

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

Deprecated: Use SubscribeGroupMessagesRequest_Filter.ProtoReflect.Descriptor instead.

func (*SubscribeGroupMessagesRequest_Filter) GetGroupId 

func (x *SubscribeGroupMessagesRequest_Filter) GetGroupId() []byte

func (*SubscribeGroupMessagesRequest_Filter) GetIdCursor 

func (x *SubscribeGroupMessagesRequest_Filter) GetIdCursor() uint64

func (*SubscribeGroupMessagesRequest_Filter) ProtoMessage 

func (*SubscribeGroupMessagesRequest_Filter) ProtoMessage()

func (*SubscribeGroupMessagesRequest_Filter) ProtoReflect 

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

func (*SubscribeGroupMessagesRequest_Filter) Reset 

func (x *SubscribeGroupMessagesRequest_Filter) Reset()

func (*SubscribeGroupMessagesRequest_Filter) String 

func (x *SubscribeGroupMessagesRequest_Filter) String() string

type SubscribeWelcomeMessagesRequest 

type SubscribeWelcomeMessagesRequest struct {
	Filters []*SubscribeWelcomeMessagesRequest_Filter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

Request for subscribing to welcome messages

func (*SubscribeWelcomeMessagesRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeWelcomeMessagesRequest.ProtoReflect.Descriptor instead.

func (*SubscribeWelcomeMessagesRequest) GetFilters 

func (x *SubscribeWelcomeMessagesRequest) GetFilters() []*SubscribeWelcomeMessagesRequest_Filter

func (*SubscribeWelcomeMessagesRequest) ProtoMessage 

func (*SubscribeWelcomeMessagesRequest) ProtoMessage()

func (*SubscribeWelcomeMessagesRequest) ProtoReflect 

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

func (*SubscribeWelcomeMessagesRequest) Reset 

func (x *SubscribeWelcomeMessagesRequest) Reset()

func (*SubscribeWelcomeMessagesRequest) String 

func (x *SubscribeWelcomeMessagesRequest) String() string

type SubscribeWelcomeMessagesRequest_Filter 

type SubscribeWelcomeMessagesRequest_Filter struct {
	InstallationKey []byte `protobuf:"bytes,1,opt,name=installation_key,json=installationKey,proto3" json:"installation_key,omitempty"`
	IdCursor        uint64 `protobuf:"varint,2,opt,name=id_cursor,json=idCursor,proto3" json:"id_cursor,omitempty"`
	// contains filtered or unexported fields
}

Subscription filter

func (*SubscribeWelcomeMessagesRequest_Filter) Descriptor deprecated 

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

Deprecated: Use SubscribeWelcomeMessagesRequest_Filter.ProtoReflect.Descriptor instead.

func (*SubscribeWelcomeMessagesRequest_Filter) GetIdCursor 

func (x *SubscribeWelcomeMessagesRequest_Filter) GetIdCursor() uint64

func (*SubscribeWelcomeMessagesRequest_Filter) GetInstallationKey 

func (x *SubscribeWelcomeMessagesRequest_Filter) GetInstallationKey() []byte

func (*SubscribeWelcomeMessagesRequest_Filter) ProtoMessage 

func (*SubscribeWelcomeMessagesRequest_Filter) ProtoMessage()

func (*SubscribeWelcomeMessagesRequest_Filter) ProtoReflect 

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

func (*SubscribeWelcomeMessagesRequest_Filter) Reset 

func (x *SubscribeWelcomeMessagesRequest_Filter) Reset()

func (*SubscribeWelcomeMessagesRequest_Filter) String 

func (x *SubscribeWelcomeMessagesRequest_Filter) String() string

type UnimplementedMlsApiServer 

type UnimplementedMlsApiServer struct {
}

UnimplementedMlsApiServer must be embedded to have forward compatible implementations.

func (UnimplementedMlsApiServer) FetchKeyPackages 

func (UnimplementedMlsApiServer) FetchKeyPackages(context.Context, *FetchKeyPackagesRequest) (*FetchKeyPackagesResponse, error)

func (UnimplementedMlsApiServer) GetIdentityUpdates 

func (UnimplementedMlsApiServer) GetIdentityUpdates(context.Context, *GetIdentityUpdatesRequest) (*GetIdentityUpdatesResponse, error)

func (UnimplementedMlsApiServer) QueryGroupMessages 

func (UnimplementedMlsApiServer) QueryGroupMessages(context.Context, *QueryGroupMessagesRequest) (*QueryGroupMessagesResponse, error)

func (UnimplementedMlsApiServer) QueryWelcomeMessages 

func (UnimplementedMlsApiServer) QueryWelcomeMessages(context.Context, *QueryWelcomeMessagesRequest) (*QueryWelcomeMessagesResponse, error)

func (UnimplementedMlsApiServer) RegisterInstallation 

func (UnimplementedMlsApiServer) RegisterInstallation(context.Context, *RegisterInstallationRequest) (*RegisterInstallationResponse, error)

func (UnimplementedMlsApiServer) RevokeInstallation 

func (UnimplementedMlsApiServer) RevokeInstallation(context.Context, *RevokeInstallationRequest) (*emptypb.Empty, error)

func (UnimplementedMlsApiServer) SendGroupMessages 

func (UnimplementedMlsApiServer) SendGroupMessages(context.Context, *SendGroupMessagesRequest) (*emptypb.Empty, error)

func (UnimplementedMlsApiServer) SendWelcomeMessages 

func (UnimplementedMlsApiServer) SendWelcomeMessages(context.Context, *SendWelcomeMessagesRequest) (*emptypb.Empty, error)

func (UnimplementedMlsApiServer) SubscribeGroupMessages 

func (UnimplementedMlsApiServer) SubscribeGroupMessages(*SubscribeGroupMessagesRequest, MlsApi_SubscribeGroupMessagesServer) error

func (UnimplementedMlsApiServer) SubscribeWelcomeMessages 

func (UnimplementedMlsApiServer) SubscribeWelcomeMessages(*SubscribeWelcomeMessagesRequest, MlsApi_SubscribeWelcomeMessagesServer) error

func (UnimplementedMlsApiServer) UploadKeyPackage 

func (UnimplementedMlsApiServer) UploadKeyPackage(context.Context, *UploadKeyPackageRequest) (*emptypb.Empty, error)

type UnsafeMlsApiServer 

type UnsafeMlsApiServer interface {
	// contains filtered or unexported methods
}

UnsafeMlsApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MlsApiServer will result in compilation errors.

type UploadKeyPackageRequest 

type UploadKeyPackageRequest struct {

	// An individual key package upload request
	KeyPackage          *KeyPackageUpload `protobuf:"bytes,1,opt,name=key_package,json=keyPackage,proto3" json:"key_package,omitempty"`
	IsInboxIdCredential bool              `protobuf:"varint,2,opt,name=is_inbox_id_credential,json=isInboxIdCredential,proto3" json:"is_inbox_id_credential,omitempty"`
	// contains filtered or unexported fields
}

Upload a new key packages

func (*UploadKeyPackageRequest) Descriptor deprecated 

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

Deprecated: Use UploadKeyPackageRequest.ProtoReflect.Descriptor instead.

func (*UploadKeyPackageRequest) GetIsInboxIdCredential 

func (x *UploadKeyPackageRequest) GetIsInboxIdCredential() bool

func (*UploadKeyPackageRequest) GetKeyPackage 

func (x *UploadKeyPackageRequest) GetKeyPackage() *KeyPackageUpload

func (*UploadKeyPackageRequest) ProtoMessage 

func (*UploadKeyPackageRequest) ProtoMessage()

func (*UploadKeyPackageRequest) ProtoReflect 

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

func (*UploadKeyPackageRequest) Reset 

func (x *UploadKeyPackageRequest) Reset()

func (*UploadKeyPackageRequest) String 

func (x *UploadKeyPackageRequest) String() string

type WelcomeMessage 

type WelcomeMessage struct {

	// Types that are assignable to Version:
	//
	//	*WelcomeMessage_V1_
	Version isWelcomeMessage_Version `protobuf_oneof:"version"`
	// contains filtered or unexported fields
}

Full representation of a welcome message

func (*WelcomeMessage) Descriptor deprecated 

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

Deprecated: Use WelcomeMessage.ProtoReflect.Descriptor instead.

func (*WelcomeMessage) GetV1 

func (x *WelcomeMessage) GetV1() *WelcomeMessage_V1

func (*WelcomeMessage) GetVersion 

func (m *WelcomeMessage) GetVersion() isWelcomeMessage_Version

func (*WelcomeMessage) ProtoMessage 

func (*WelcomeMessage) ProtoMessage()

func (*WelcomeMessage) ProtoReflect 

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

func (*WelcomeMessage) Reset 

func (x *WelcomeMessage) Reset()

func (*WelcomeMessage) String 

func (x *WelcomeMessage) String() string

type WelcomeMessageInput 

type WelcomeMessageInput struct {

	// Types that are assignable to Version:
	//
	//	*WelcomeMessageInput_V1_
	Version isWelcomeMessageInput_Version `protobuf_oneof:"version"`
	// contains filtered or unexported fields
}

Input type for a welcome message

func (*WelcomeMessageInput) Descriptor deprecated 

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

Deprecated: Use WelcomeMessageInput.ProtoReflect.Descriptor instead.

func (*WelcomeMessageInput) GetV1 

func (x *WelcomeMessageInput) GetV1() *WelcomeMessageInput_V1

func (*WelcomeMessageInput) GetVersion 

func (m *WelcomeMessageInput) GetVersion() isWelcomeMessageInput_Version

func (*WelcomeMessageInput) ProtoMessage 

func (*WelcomeMessageInput) ProtoMessage()

func (*WelcomeMessageInput) ProtoReflect 

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

func (*WelcomeMessageInput) Reset 

func (x *WelcomeMessageInput) Reset()

func (*WelcomeMessageInput) String 

func (x *WelcomeMessageInput) String() string

type WelcomeMessageInput_V1 

type WelcomeMessageInput_V1 struct {
	InstallationKey []byte `protobuf:"bytes,1,opt,name=installation_key,json=installationKey,proto3" json:"installation_key,omitempty"`
	Data            []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	HpkePublicKey   []byte `protobuf:"bytes,3,opt,name=hpke_public_key,json=hpkePublicKey,proto3" json:"hpke_public_key,omitempty"`
	// contains filtered or unexported fields
}

Version 1 of the WelcomeMessageInput format

func (*WelcomeMessageInput_V1) Descriptor deprecated 

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

Deprecated: Use WelcomeMessageInput_V1.ProtoReflect.Descriptor instead.

func (*WelcomeMessageInput_V1) GetData 

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

func (*WelcomeMessageInput_V1) GetHpkePublicKey 

func (x *WelcomeMessageInput_V1) GetHpkePublicKey() []byte

func (*WelcomeMessageInput_V1) GetInstallationKey 

func (x *WelcomeMessageInput_V1) GetInstallationKey() []byte

func (*WelcomeMessageInput_V1) ProtoMessage 

func (*WelcomeMessageInput_V1) ProtoMessage()

func (*WelcomeMessageInput_V1) ProtoReflect 

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

func (*WelcomeMessageInput_V1) Reset 

func (x *WelcomeMessageInput_V1) Reset()

func (*WelcomeMessageInput_V1) String 

func (x *WelcomeMessageInput_V1) String() string

type WelcomeMessageInput_V1_ 

type WelcomeMessageInput_V1_ struct {
	V1 *WelcomeMessageInput_V1 `protobuf:"bytes,1,opt,name=v1,proto3,oneof"`
}

type WelcomeMessage_V1 

type WelcomeMessage_V1 struct {
	Id              uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedNs       uint64 `protobuf:"varint,2,opt,name=created_ns,json=createdNs,proto3" json:"created_ns,omitempty"`
	InstallationKey []byte `protobuf:"bytes,3,opt,name=installation_key,json=installationKey,proto3" json:"installation_key,omitempty"`
	Data            []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	HpkePublicKey   []byte `protobuf:"bytes,5,opt,name=hpke_public_key,json=hpkePublicKey,proto3" json:"hpke_public_key,omitempty"`
	// contains filtered or unexported fields
}

Version 1 of the WelcomeMessage format

func (*WelcomeMessage_V1) Descriptor deprecated 

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

Deprecated: Use WelcomeMessage_V1.ProtoReflect.Descriptor instead.

func (*WelcomeMessage_V1) GetCreatedNs 

func (x *WelcomeMessage_V1) GetCreatedNs() uint64

func (*WelcomeMessage_V1) GetData 

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

func (*WelcomeMessage_V1) GetHpkePublicKey 

func (x *WelcomeMessage_V1) GetHpkePublicKey() []byte

func (*WelcomeMessage_V1) GetId 

func (x *WelcomeMessage_V1) GetId() uint64

func (*WelcomeMessage_V1) GetInstallationKey 

func (x *WelcomeMessage_V1) GetInstallationKey() []byte

func (*WelcomeMessage_V1) ProtoMessage 

func (*WelcomeMessage_V1) ProtoMessage()

func (*WelcomeMessage_V1) ProtoReflect 

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

func (*WelcomeMessage_V1) Reset 

func (x *WelcomeMessage_V1) Reset()

func (*WelcomeMessage_V1) String 

func (x *WelcomeMessage_V1) String() string

type WelcomeMessage_V1_ 

type WelcomeMessage_V1_ struct {
	V1 *WelcomeMessage_V1 `protobuf:"bytes,1,opt,name=v1,proto3,oneof"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.