Documentation ¶
Overview ¶
Package api is a generated GoMock package.
Index ¶
- type MockMlsApi_SubscribeGroupMessagesServer
- func (m *MockMlsApi_SubscribeGroupMessagesServer) Context() context.Context
- func (m *MockMlsApi_SubscribeGroupMessagesServer) EXPECT() *MockMlsApi_SubscribeGroupMessagesServerMockRecorder
- func (m *MockMlsApi_SubscribeGroupMessagesServer) RecvMsg(arg0 any) error
- func (m *MockMlsApi_SubscribeGroupMessagesServer) Send(arg0 *apiv1.GroupMessage) error
- func (m *MockMlsApi_SubscribeGroupMessagesServer) SendHeader(arg0 metadata.MD) error
- func (m *MockMlsApi_SubscribeGroupMessagesServer) SendMsg(arg0 any) error
- func (m *MockMlsApi_SubscribeGroupMessagesServer) SetHeader(arg0 metadata.MD) error
- func (m *MockMlsApi_SubscribeGroupMessagesServer) SetTrailer(arg0 metadata.MD)
- type MockMlsApi_SubscribeGroupMessagesServerMockRecorder
- func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) Context() *gomock.Call
- func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) RecvMsg(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SendMsg(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockMlsApi_SubscribeWelcomeMessagesServer
- func (m *MockMlsApi_SubscribeWelcomeMessagesServer) Context() context.Context
- func (m *MockMlsApi_SubscribeWelcomeMessagesServer) EXPECT() *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder
- func (m *MockMlsApi_SubscribeWelcomeMessagesServer) RecvMsg(arg0 any) error
- func (m *MockMlsApi_SubscribeWelcomeMessagesServer) Send(arg0 *apiv1.WelcomeMessage) error
- func (m *MockMlsApi_SubscribeWelcomeMessagesServer) SendHeader(arg0 metadata.MD) error
- func (m *MockMlsApi_SubscribeWelcomeMessagesServer) SendMsg(arg0 any) error
- func (m *MockMlsApi_SubscribeWelcomeMessagesServer) SetHeader(arg0 metadata.MD) error
- func (m *MockMlsApi_SubscribeWelcomeMessagesServer) SetTrailer(arg0 metadata.MD)
- type MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder
- func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) Context() *gomock.Call
- func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) RecvMsg(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SendMsg(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type Service
- 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) HandleIncomingWakuRelayMessage(wakuMsg *wakupb.WakuMessage) 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 ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockMlsApi_SubscribeGroupMessagesServer ¶
type MockMlsApi_SubscribeGroupMessagesServer struct {
// contains filtered or unexported fields
}
MockMlsApi_SubscribeGroupMessagesServer is a mock of MlsApi_SubscribeGroupMessagesServer interface.
func NewMockMlsApi_SubscribeGroupMessagesServer ¶
func NewMockMlsApi_SubscribeGroupMessagesServer(ctrl *gomock.Controller) *MockMlsApi_SubscribeGroupMessagesServer
NewMockMlsApi_SubscribeGroupMessagesServer creates a new mock instance.
func (*MockMlsApi_SubscribeGroupMessagesServer) Context ¶
func (m *MockMlsApi_SubscribeGroupMessagesServer) Context() context.Context
Context mocks base method.
func (*MockMlsApi_SubscribeGroupMessagesServer) EXPECT ¶
func (m *MockMlsApi_SubscribeGroupMessagesServer) EXPECT() *MockMlsApi_SubscribeGroupMessagesServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMlsApi_SubscribeGroupMessagesServer) RecvMsg ¶
func (m *MockMlsApi_SubscribeGroupMessagesServer) RecvMsg(arg0 any) error
RecvMsg mocks base method.
func (*MockMlsApi_SubscribeGroupMessagesServer) Send ¶
func (m *MockMlsApi_SubscribeGroupMessagesServer) Send(arg0 *apiv1.GroupMessage) error
Send mocks base method.
func (*MockMlsApi_SubscribeGroupMessagesServer) SendHeader ¶
func (m *MockMlsApi_SubscribeGroupMessagesServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockMlsApi_SubscribeGroupMessagesServer) SendMsg ¶
func (m *MockMlsApi_SubscribeGroupMessagesServer) SendMsg(arg0 any) error
SendMsg mocks base method.
func (*MockMlsApi_SubscribeGroupMessagesServer) SetHeader ¶
func (m *MockMlsApi_SubscribeGroupMessagesServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockMlsApi_SubscribeGroupMessagesServer) SetTrailer ¶
func (m *MockMlsApi_SubscribeGroupMessagesServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockMlsApi_SubscribeGroupMessagesServerMockRecorder ¶
type MockMlsApi_SubscribeGroupMessagesServerMockRecorder struct {
// contains filtered or unexported fields
}
MockMlsApi_SubscribeGroupMessagesServerMockRecorder is the mock recorder for MockMlsApi_SubscribeGroupMessagesServer.
func (*MockMlsApi_SubscribeGroupMessagesServerMockRecorder) Context ¶
func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockMlsApi_SubscribeGroupMessagesServerMockRecorder) RecvMsg ¶
func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) RecvMsg(arg0 any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockMlsApi_SubscribeGroupMessagesServerMockRecorder) Send ¶
func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SendHeader ¶
func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SendMsg ¶
func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SendMsg(arg0 any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SetHeader ¶
func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SetTrailer ¶
func (mr *MockMlsApi_SubscribeGroupMessagesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockMlsApi_SubscribeWelcomeMessagesServer ¶
type MockMlsApi_SubscribeWelcomeMessagesServer struct {
// contains filtered or unexported fields
}
MockMlsApi_SubscribeWelcomeMessagesServer is a mock of MlsApi_SubscribeWelcomeMessagesServer interface.
func NewMockMlsApi_SubscribeWelcomeMessagesServer ¶
func NewMockMlsApi_SubscribeWelcomeMessagesServer(ctrl *gomock.Controller) *MockMlsApi_SubscribeWelcomeMessagesServer
NewMockMlsApi_SubscribeWelcomeMessagesServer creates a new mock instance.
func (*MockMlsApi_SubscribeWelcomeMessagesServer) Context ¶
func (m *MockMlsApi_SubscribeWelcomeMessagesServer) Context() context.Context
Context mocks base method.
func (*MockMlsApi_SubscribeWelcomeMessagesServer) EXPECT ¶
func (m *MockMlsApi_SubscribeWelcomeMessagesServer) EXPECT() *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMlsApi_SubscribeWelcomeMessagesServer) RecvMsg ¶
func (m *MockMlsApi_SubscribeWelcomeMessagesServer) RecvMsg(arg0 any) error
RecvMsg mocks base method.
func (*MockMlsApi_SubscribeWelcomeMessagesServer) Send ¶
func (m *MockMlsApi_SubscribeWelcomeMessagesServer) Send(arg0 *apiv1.WelcomeMessage) error
Send mocks base method.
func (*MockMlsApi_SubscribeWelcomeMessagesServer) SendHeader ¶
func (m *MockMlsApi_SubscribeWelcomeMessagesServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockMlsApi_SubscribeWelcomeMessagesServer) SendMsg ¶
func (m *MockMlsApi_SubscribeWelcomeMessagesServer) SendMsg(arg0 any) error
SendMsg mocks base method.
func (*MockMlsApi_SubscribeWelcomeMessagesServer) SetHeader ¶
func (m *MockMlsApi_SubscribeWelcomeMessagesServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockMlsApi_SubscribeWelcomeMessagesServer) SetTrailer ¶
func (m *MockMlsApi_SubscribeWelcomeMessagesServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder ¶
type MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder struct {
// contains filtered or unexported fields
}
MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder is the mock recorder for MockMlsApi_SubscribeWelcomeMessagesServer.
func (*MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) Context ¶
func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) RecvMsg ¶
func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) RecvMsg(arg0 any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) Send ¶
func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SendHeader ¶
func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SendMsg ¶
func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SendMsg(arg0 any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SetHeader ¶
func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SetTrailer ¶
func (mr *MockMlsApi_SubscribeWelcomeMessagesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type Service ¶
type Service struct { mlsv1.UnimplementedMlsApiServer // contains filtered or unexported fields }
func NewService ¶
func NewService(log *zap.Logger, store mlsstore.MlsStore, validationService mlsvalidate.MLSValidationService, natsServer *server.Server, publishToWakuRelay func(context.Context, *wakupb.WakuMessage) error) (s *Service, err 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) HandleIncomingWakuRelayMessage ¶
func (s *Service) HandleIncomingWakuRelayMessage(wakuMsg *wakupb.WakuMessage) 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)
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