writer

Documentation

Index

• Variables
• func RegisterServiceServer(s *grpc.Server, srv ServiceServer)
• type Service
  • func NewService(client ServiceClient) Service
  • func NewServiceMock() Service
• type ServiceClient
  • func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient
• type ServiceServer
• type Service_SubmitMessagesClient
• type Service_SubmitMessagesServer
• type SubmitMessagesRequest
  • func (*SubmitMessagesRequest) Descriptor() ([]byte, []int)
  • func (x *SubmitMessagesRequest) GetMsgs() []*pb.CloudEvent
  • func (*SubmitMessagesRequest) ProtoMessage()
  • func (x *SubmitMessagesRequest) ProtoReflect() protoreflect.Message
  • func (x *SubmitMessagesRequest) Reset()
  • func (x *SubmitMessagesRequest) String() string
• type SubmitMessagesResponse
  • func (*SubmitMessagesResponse) Descriptor() ([]byte, []int)
  • func (x *SubmitMessagesResponse) GetAckCount() uint32
  • func (*SubmitMessagesResponse) ProtoMessage()
  • func (x *SubmitMessagesResponse) ProtoReflect() protoreflect.Message
  • func (x *SubmitMessagesResponse) Reset()
  • func (x *SubmitMessagesResponse) String() string
• type UnimplementedServiceServer
  • func (*UnimplementedServiceServer) SubmitMessages(Service_SubmitMessagesServer) error

Variables

var ErrInternal = errors.New("internal failure")

var File_api_grpc_writer_service_proto protoreflect.FileDescriptor

Functions

func RegisterServiceServer

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

Types

type Service

type Service interface {
	OpenWriter(ctx context.Context, userId string) (w model.Writer[*pb.CloudEvent], err error)
}

func NewService

func NewService(client ServiceClient) Service

func NewServiceMock

func NewServiceMock() Service

type ServiceClient

type ServiceClient interface {
	SubmitMessages(ctx context.Context, opts ...grpc.CallOption) (Service_SubmitMessagesClient, error)
}

ServiceClient is the client API for Service service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewServiceClient

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer

type ServiceServer interface {
	SubmitMessages(Service_SubmitMessagesServer) error
}

ServiceServer is the server API for Service service.

type Service_SubmitMessagesClient

type Service_SubmitMessagesClient interface {
	Send(*SubmitMessagesRequest) error
	Recv() (*SubmitMessagesResponse, error)
	grpc.ClientStream
}

type Service_SubmitMessagesServer

type Service_SubmitMessagesServer interface {
	Send(*SubmitMessagesResponse) error
	Recv() (*SubmitMessagesRequest, error)
	grpc.ServerStream
}

type SubmitMessagesRequest

type SubmitMessagesRequest struct {
	Msgs []*pb.CloudEvent `protobuf:"bytes,1,rep,name=msgs,proto3" json:"msgs,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitMessagesRequest) Descriptor

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

Deprecated: Use SubmitMessagesRequest.ProtoReflect.Descriptor instead.

func (*SubmitMessagesRequest) GetMsgs

func (x *SubmitMessagesRequest) GetMsgs() []*pb.CloudEvent

func (*SubmitMessagesRequest) ProtoMessage

func (*SubmitMessagesRequest) ProtoMessage()

func (*SubmitMessagesRequest) ProtoReflect

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

func (*SubmitMessagesRequest) Reset

func (x *SubmitMessagesRequest) Reset()

func (*SubmitMessagesRequest) String

func (x *SubmitMessagesRequest) String() string

type SubmitMessagesResponse

type SubmitMessagesResponse struct {
	AckCount uint32 `protobuf:"varint,1,opt,name=ackCount,proto3" json:"ackCount,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitMessagesResponse) Descriptor

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

Deprecated: Use SubmitMessagesResponse.ProtoReflect.Descriptor instead.

func (*SubmitMessagesResponse) GetAckCount

func (x *SubmitMessagesResponse) GetAckCount() uint32

func (*SubmitMessagesResponse) ProtoMessage

func (*SubmitMessagesResponse) ProtoMessage()

func (*SubmitMessagesResponse) ProtoReflect

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

func (*SubmitMessagesResponse) Reset

func (x *SubmitMessagesResponse) Reset()

func (*SubmitMessagesResponse) String

func (x *SubmitMessagesResponse) String() string

type UnimplementedServiceServer

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceServer) SubmitMessages

func (*UnimplementedServiceServer) SubmitMessages(Service_SubmitMessagesServer) error