pb

type ChipIngressClient ¶

type ChipIngressClient interface {
	Publish(ctx context.Context, in *pb.CloudEvent, opts ...grpc.CallOption) (*PublishResponse, error)
	PublishBatch(ctx context.Context, in *CloudEventBatch, opts ...grpc.CallOption) (*PublishResponse, error)
	Ping(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

ChipIngressClient is the client API for ChipIngress service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

ChipIngress service provides a way for senders to produce CloudEvents messages to Kafka

func NewChipIngressClient(cc grpc.ClientConnInterface) ChipIngressClient

type ChipIngressServer ¶

type ChipIngressServer interface {
	Publish(context.Context, *pb.CloudEvent) (*PublishResponse, error)
	PublishBatch(context.Context, *CloudEventBatch) (*PublishResponse, error)
	Ping(context.Context, *EmptyRequest) (*PingResponse, error)
	// contains filtered or unexported methods
}

ChipIngressServer is the server API for ChipIngress service. All implementations must embed UnimplementedChipIngressServer for forward compatibility.

ChipIngress service provides a way for senders to produce CloudEvents messages to Kafka

type CloudEventBatch ¶

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

CloudEventBatch is used to send many ChipIngress

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

func (x *CloudEventBatch) GetEvents() []*pb.CloudEvent

func (*CloudEventBatch) ProtoMessage()

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

func (x *CloudEventBatch) Reset()

func (x *CloudEventBatch) String() string

type EmptyRequest ¶

type EmptyRequest struct {
	// contains filtered or unexported fields
}

EmptyRequest is just an empty request

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

func (*EmptyRequest) ProtoMessage()

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

func (x *EmptyRequest) Reset()

func (x *EmptyRequest) String() string

type PingResponse ¶

type PingResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

PingResponse responds to pings

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

func (x *PingResponse) GetMessage() string

func (*PingResponse) ProtoMessage()

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

func (x *PingResponse) Reset()

func (x *PingResponse) String() string

type PublishResponse ¶

type PublishResponse struct {
	Results []*PublishResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *PublishResponse) GetResults() []*PublishResult

func (*PublishResponse) ProtoMessage()

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

func (x *PublishResponse) Reset()

func (x *PublishResponse) String() string

type PublishResult ¶

type PublishResult struct {
	EventId string `protobuf:"bytes,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *PublishResult) GetEventId() string

func (*PublishResult) ProtoMessage()

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

func (x *PublishResult) Reset()

func (x *PublishResult) String() string

type UnimplementedChipIngressServer ¶

type UnimplementedChipIngressServer struct{}

UnimplementedChipIngressServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedChipIngressServer) Ping(context.Context, *EmptyRequest) (*PingResponse, error)

func (UnimplementedChipIngressServer) Publish(context.Context, *pb.CloudEvent) (*PublishResponse, error)

func (UnimplementedChipIngressServer) PublishBatch(context.Context, *CloudEventBatch) (*PublishResponse, error)

type UnsafeChipIngressServer ¶

type UnsafeChipIngressServer interface {
	// contains filtered or unexported methods
}

UnsafeChipIngressServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChipIngressServer will result in compilation errors.