api

package
v1.3.1 Latest Latest
Warning

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

Go to latest
Published: Nov 3, 2025 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
const DEFAULT_POLL_INTERVAL = 25 * time.Millisecond

Variables

This section is empty.

Functions

This section is empty.

Types

type Service

type Service struct {
	mlsv1.UnimplementedMlsApiServer
	// contains filtered or unexported fields
}

func NewService

func NewService(
	log *zap.Logger,
	writerStore mlsstore.ReadWriteMlsStore,
	readOnlyStore mlsstore.ReadMlsStore,
	subDispatcher *subscriptions.SubscriptionDispatcher,
	validationService mlsvalidate.MLSValidationService,
	disablePublish bool,
) (s *Service, err error)

func (*Service) BatchPublishCommitLog added in v1.0.1

func (s *Service) BatchPublishCommitLog(
	ctx context.Context,
	req *mlsv1.BatchPublishCommitLogRequest,
) (*emptypb.Empty, error)

func (*Service) BatchQueryCommitLog added in v1.0.1

func (*Service) Close

func (s *Service) Close()

func (*Service) FetchKeyPackages

func (*Service) GetIdentityUpdates

func (s *Service) GetIdentityUpdates(
	ctx context.Context,
	req *mlsv1.GetIdentityUpdatesRequest,
) (res *mlsv1.GetIdentityUpdatesResponse, err error)

func (*Service) GetNewestGroupMessage added in v1.3.0

func (*Service) QueryGroupMessages

func (*Service) QueryWelcomeMessages

func (*Service) RegisterInstallation

* DEPRECATED: Use UploadKeyPackage instead *

func (*Service) RevokeInstallation

func (s *Service) RevokeInstallation(
	ctx context.Context,
	req *mlsv1.RevokeInstallationRequest,
) (*emptypb.Empty, error)

func (*Service) SendGroupMessages

func (s *Service) SendGroupMessages(
	ctx context.Context,
	req *mlsv1.SendGroupMessagesRequest,
) (res *emptypb.Empty, err error)

func (*Service) SendWelcomeMessages

func (s *Service) SendWelcomeMessages(
	ctx context.Context,
	req *mlsv1.SendWelcomeMessagesRequest,
) (res *emptypb.Empty, err error)

func (*Service) SubscribeGroupMessages

func (*Service) UploadKeyPackage

func (s *Service) UploadKeyPackage(
	ctx context.Context,
	req *mlsv1.UploadKeyPackageRequest,
) (res *emptypb.Empty, err error)

Jump to

Keyboard shortcuts

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