resolver

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Sep 23, 2024 License: MIT Imports: 17 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrInternal = errors.New("internal failure")
View Source
var ErrUnavailable = errors.New("unavailable")
View Source
var File_api_grpc_resolver_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 NewClientConnPool added in v1.2.0

func NewClientConnPool(connPool *grpcpool.Pool) ServiceClient

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 deprecated

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 deprecated

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

Jump to

Keyboard shortcuts

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