Documentation
¶
Index ¶
- Constants
- type Service
- func (s *Service) BatchPublishCommitLog(ctx context.Context, req *mlsv1.BatchPublishCommitLogRequest) (*emptypb.Empty, error)
- func (s *Service) BatchQueryCommitLog(ctx context.Context, req *mlsv1.BatchQueryCommitLogRequest) (*mlsv1.BatchQueryCommitLogResponse, error)
- func (s *Service) Close()
- func (s *Service) FetchKeyPackages(ctx context.Context, req *mlsv1.FetchKeyPackagesRequest) (*mlsv1.FetchKeyPackagesResponse, error)
- func (s *Service) GetIdentityUpdates(ctx context.Context, req *mlsv1.GetIdentityUpdatesRequest) (res *mlsv1.GetIdentityUpdatesResponse, err error)
- func (s *Service) GetNewestGroupMessage(ctx context.Context, req *mlsv1.GetNewestGroupMessageRequest) (*mlsv1.GetNewestGroupMessageResponse, error)
- func (s *Service) QueryGroupMessages(ctx context.Context, req *mlsv1.QueryGroupMessagesRequest) (*mlsv1.QueryGroupMessagesResponse, error)
- func (s *Service) QueryWelcomeMessages(ctx context.Context, req *mlsv1.QueryWelcomeMessagesRequest) (*mlsv1.QueryWelcomeMessagesResponse, error)
- func (s *Service) RegisterInstallation(ctx context.Context, req *mlsv1.RegisterInstallationRequest) (*mlsv1.RegisterInstallationResponse, error)
- func (s *Service) RevokeInstallation(ctx context.Context, req *mlsv1.RevokeInstallationRequest) (*emptypb.Empty, error)
- func (s *Service) SendGroupMessages(ctx context.Context, req *mlsv1.SendGroupMessagesRequest) (res *emptypb.Empty, err error)
- func (s *Service) SendWelcomeMessages(ctx context.Context, req *mlsv1.SendWelcomeMessagesRequest) (res *emptypb.Empty, err error)
- func (s *Service) SubscribeGroupMessages(req *mlsv1.SubscribeGroupMessagesRequest, ...) error
- func (s *Service) SubscribeWelcomeMessages(req *mlsv1.SubscribeWelcomeMessagesRequest, ...) error
- func (s *Service) UploadKeyPackage(ctx context.Context, req *mlsv1.UploadKeyPackageRequest) (res *emptypb.Empty, err error)
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 (*Service) BatchQueryCommitLog ¶ added in v1.0.1
func (s *Service) BatchQueryCommitLog( ctx context.Context, req *mlsv1.BatchQueryCommitLogRequest, ) (*mlsv1.BatchQueryCommitLogResponse, error)
func (*Service) FetchKeyPackages ¶
func (s *Service) FetchKeyPackages( ctx context.Context, req *mlsv1.FetchKeyPackagesRequest, ) (*mlsv1.FetchKeyPackagesResponse, error)
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 (s *Service) GetNewestGroupMessage( ctx context.Context, req *mlsv1.GetNewestGroupMessageRequest, ) (*mlsv1.GetNewestGroupMessageResponse, error)
func (*Service) QueryGroupMessages ¶
func (s *Service) QueryGroupMessages( ctx context.Context, req *mlsv1.QueryGroupMessagesRequest, ) (*mlsv1.QueryGroupMessagesResponse, error)
func (*Service) QueryWelcomeMessages ¶
func (s *Service) QueryWelcomeMessages( ctx context.Context, req *mlsv1.QueryWelcomeMessagesRequest, ) (*mlsv1.QueryWelcomeMessagesResponse, error)
func (*Service) RegisterInstallation ¶
func (s *Service) RegisterInstallation( ctx context.Context, req *mlsv1.RegisterInstallationRequest, ) (*mlsv1.RegisterInstallationResponse, error)
* DEPRECATED: Use UploadKeyPackage instead *
func (*Service) RevokeInstallation ¶
func (*Service) SendGroupMessages ¶
func (*Service) SendWelcomeMessages ¶
func (*Service) SubscribeGroupMessages ¶
func (s *Service) SubscribeGroupMessages( req *mlsv1.SubscribeGroupMessagesRequest, stream mlsv1.MlsApi_SubscribeGroupMessagesServer, ) error
func (*Service) SubscribeWelcomeMessages ¶
func (s *Service) SubscribeWelcomeMessages( req *mlsv1.SubscribeWelcomeMessagesRequest, stream mlsv1.MlsApi_SubscribeWelcomeMessagesServer, ) error
func (*Service) UploadKeyPackage ¶
Click to show internal directories.
Click to hide internal directories.