Versions in this module Expand all Collapse all v0 v0.0.2 May 23, 2023 Changes in this version + var File_api_grpc_messages_service_proto protoreflect.FileDescriptor + func RegisterServiceServer(s *grpc.Server, srv ServiceServer) + type ReceiveCommandAck struct + Ack bool + func (*ReceiveCommandAck) Descriptor() ([]byte, []int) + func (*ReceiveCommandAck) ProtoMessage() + func (x *ReceiveCommandAck) GetAck() bool + func (x *ReceiveCommandAck) ProtoReflect() protoreflect.Message + func (x *ReceiveCommandAck) Reset() + func (x *ReceiveCommandAck) String() string + type ReceiveCommandStart struct + SubId string + func (*ReceiveCommandStart) Descriptor() ([]byte, []int) + func (*ReceiveCommandStart) ProtoMessage() + func (x *ReceiveCommandStart) GetSubId() string + func (x *ReceiveCommandStart) ProtoReflect() protoreflect.Message + func (x *ReceiveCommandStart) Reset() + func (x *ReceiveCommandStart) String() string + type ReceiveRequest struct + Command isReceiveRequest_Command + func (*ReceiveRequest) Descriptor() ([]byte, []int) + func (*ReceiveRequest) ProtoMessage() + func (m *ReceiveRequest) GetCommand() isReceiveRequest_Command + func (x *ReceiveRequest) GetAck() *ReceiveCommandAck + func (x *ReceiveRequest) GetStart() *ReceiveCommandStart + func (x *ReceiveRequest) ProtoReflect() protoreflect.Message + func (x *ReceiveRequest) Reset() + func (x *ReceiveRequest) String() string + type ReceiveRequest_Ack struct + Ack *ReceiveCommandAck + type ReceiveRequest_Start struct + Start *ReceiveCommandStart + type ServiceClient interface + Receive func(ctx context.Context, opts ...grpc.CallOption) (Service_ReceiveClient, error) + func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient + type ServiceServer interface + Receive func(Service_ReceiveServer) error + type Service_ReceiveClient interface + Recv func() (*pb.CloudEvent, error) + Send func(*ReceiveRequest) error + type Service_ReceiveServer interface + Recv func() (*ReceiveRequest, error) + Send func(*pb.CloudEvent) error + type UnimplementedServiceServer struct + func (*UnimplementedServiceServer) Receive(Service_ReceiveServer) error v0.0.1 May 21, 2023 Changes in this version + var ErrInternal = errors.New("internal failure") + var ErrNotFound = errors.New("not found") + type Service interface + Read func(ctx context.Context, userId, subId string) (rs model.ReadStream[*pb.CloudEvent], err error) + func NewService(client ServiceClient) Service + func NewServiceMock() Service
Go to main page