v1

package
v3.37.0-beta.2 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2024 License: MIT Imports: 20 Imported by: 0

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	MlsApi_PublishToGroup_FullMethodName       = "/xmtp.mls.api.v1.MlsApi/PublishToGroup"
	MlsApi_PublishWelcomes_FullMethodName      = "/xmtp.mls.api.v1.MlsApi/PublishWelcomes"
	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"
)

Variables

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: "PublishToGroup",
			Handler:    _MlsApi_PublishToGroup_Handler,
		},
		{
			MethodName: "PublishWelcomes",
			Handler:    _MlsApi_PublishWelcomes_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,
		},
	},
	Streams:  []grpc.StreamDesc{},
	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 wallet addresses, and the API
	// will return one key package for each installation associated with each
	// wallet address
	InstallationIds [][]byte `protobuf:"bytes,1,rep,name=installation_ids,json=installationIds,proto3" json:"installation_ids,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) GetInstallationIds 

func (x *FetchKeyPackagesRequest) GetInstallationIds() [][]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 {
	InstallationId     []byte `protobuf:"bytes,1,opt,name=installation_id,json=installationId,proto3" json:"installation_id,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 ID 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) GetInstallationId 

func (x *GetIdentityUpdatesResponse_NewInstallationUpdate) GetInstallationId() []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 {
	InstallationId []byte `protobuf:"bytes,1,opt,name=installation_id,json=installationId,proto3" json:"installation_id,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) GetInstallationId 

func (x *GetIdentityUpdatesResponse_RevokedInstallationUpdate) GetInstallationId() []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 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 {
	// Publish a MLS payload, that would be validated before being stored to the
	// network
	PublishToGroup(ctx context.Context, in *PublishToGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Publish a batch of welcome messages
	PublishWelcomes(ctx context.Context, in *PublishWelcomesRequest, 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)
}

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 {
	// Publish a MLS payload, that would be validated before being stored to the
	// network
	PublishToGroup(context.Context, *PublishToGroupRequest) (*emptypb.Empty, error)
	// Publish a batch of welcome messages
	PublishWelcomes(context.Context, *PublishWelcomesRequest) (*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)
	// contains filtered or unexported methods
}

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

type PublishToGroupRequest 

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

Publish a batch of MLS messages

func (*PublishToGroupRequest) Descriptor deprecated 

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

Deprecated: Use PublishToGroupRequest.ProtoReflect.Descriptor instead.

func (*PublishToGroupRequest) GetMessages 

func (x *PublishToGroupRequest) GetMessages() []*message_contents.GroupMessage

func (*PublishToGroupRequest) ProtoMessage 

func (*PublishToGroupRequest) ProtoMessage()

func (*PublishToGroupRequest) ProtoReflect 

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

func (*PublishToGroupRequest) Reset 

func (x *PublishToGroupRequest) Reset()

func (*PublishToGroupRequest) String 

func (x *PublishToGroupRequest) String() string

type PublishWelcomesRequest 

type PublishWelcomesRequest struct {
	WelcomeMessages []*PublishWelcomesRequest_WelcomeMessageRequest `protobuf:"bytes,1,rep,name=welcome_messages,json=welcomeMessages,proto3" json:"welcome_messages,omitempty"`
	// contains filtered or unexported fields
}

Publish a batch of welcome messages

func (*PublishWelcomesRequest) Descriptor deprecated 

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

Deprecated: Use PublishWelcomesRequest.ProtoReflect.Descriptor instead.

func (*PublishWelcomesRequest) GetWelcomeMessages 

func (x *PublishWelcomesRequest) GetWelcomeMessages() []*PublishWelcomesRequest_WelcomeMessageRequest

func (*PublishWelcomesRequest) ProtoMessage 

func (*PublishWelcomesRequest) ProtoMessage()

func (*PublishWelcomesRequest) ProtoReflect 

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

func (*PublishWelcomesRequest) Reset 

func (x *PublishWelcomesRequest) Reset()

func (*PublishWelcomesRequest) String 

func (x *PublishWelcomesRequest) String() string

type PublishWelcomesRequest_WelcomeMessageRequest 

type PublishWelcomesRequest_WelcomeMessageRequest struct {

	// The topic will be derived from this
	InstallationId []byte                           `protobuf:"bytes,1,opt,name=installation_id,json=installationId,proto3" json:"installation_id,omitempty"`
	WelcomeMessage *message_contents.WelcomeMessage `protobuf:"bytes,2,opt,name=welcome_message,json=welcomeMessage,proto3" json:"welcome_message,omitempty"`
	// contains filtered or unexported fields
}

An individual welcome message

func (*PublishWelcomesRequest_WelcomeMessageRequest) Descriptor deprecated 

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

Deprecated: Use PublishWelcomesRequest_WelcomeMessageRequest.ProtoReflect.Descriptor instead.

func (*PublishWelcomesRequest_WelcomeMessageRequest) GetInstallationId 

func (x *PublishWelcomesRequest_WelcomeMessageRequest) GetInstallationId() []byte

func (*PublishWelcomesRequest_WelcomeMessageRequest) GetWelcomeMessage 

func (x *PublishWelcomesRequest_WelcomeMessageRequest) GetWelcomeMessage() *message_contents.WelcomeMessage

func (*PublishWelcomesRequest_WelcomeMessageRequest) ProtoMessage 

func (*PublishWelcomesRequest_WelcomeMessageRequest) ProtoMessage()

func (*PublishWelcomesRequest_WelcomeMessageRequest) ProtoReflect 

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

func (*PublishWelcomesRequest_WelcomeMessageRequest) Reset 

func (x *PublishWelcomesRequest_WelcomeMessageRequest) Reset()

func (*PublishWelcomesRequest_WelcomeMessageRequest) String 

func (x *PublishWelcomesRequest_WelcomeMessageRequest) 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"`
	// 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) 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 {
	InstallationId []byte `protobuf:"bytes,1,opt,name=installation_id,json=installationId,proto3" json:"installation_id,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) GetInstallationId 

func (x *RegisterInstallationResponse) GetInstallationId() []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 {
	InstallationId []byte `protobuf:"bytes,1,opt,name=installation_id,json=installationId,proto3" json:"installation_id,omitempty"`
	// All revocations must be validated with a wallet signature over the
	// installation_id being revoked (and some sort of standard prologue)
	WalletSignature *message_contents1.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) GetInstallationId 

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

func (*RevokeInstallationRequest) GetWalletSignature 

func (x *RevokeInstallationRequest) GetWalletSignature() *message_contents1.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 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) PublishToGroup 

func (UnimplementedMlsApiServer) PublishToGroup(context.Context, *PublishToGroupRequest) (*emptypb.Empty, error)

func (UnimplementedMlsApiServer) PublishWelcomes 

func (UnimplementedMlsApiServer) PublishWelcomes(context.Context, *PublishWelcomesRequest) (*emptypb.Empty, 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) 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"`
	// 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) 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

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.