pb

type ChipIngressClient interface {
	// Publish sends a single CloudEvent to the ChipIngress service.
	Publish(ctx context.Context, in *pb.CloudEvent, opts ...grpc.CallOption) (*PublishResponse, error)
	// PublishBatch sends a batch of CloudEvents to the ChipIngress service.
	// This method is atomic, meaning it will either succeed or fail for the entire batch.
	// When the server receives a batch of events, it will open a kafka transaction, and begin producing each event sequentially in order received.
	// If any 1 message fails, all previous messages in the same batch that were already produced won't be marked as committed,
	// and the server will respond with an error.
	// Consumers can set isolation.level=read_committed to only read committed records
	PublishBatch(ctx context.Context, in *CloudEventBatch, opts ...grpc.CallOption) (*PublishResponse, error)
	// Ping sends a request to the ChipIngress service to check if it is alive.
	Ping(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// StreamEvents; EXPERIMENTAL ~ allows clients to stream CloudEvents to the server.
	// This API is experimental and may change in the future.
	StreamEvents(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse], error)
}

type ChipIngressServer interface {
	// Publish sends a single CloudEvent to the ChipIngress service.
	Publish(context.Context, *pb.CloudEvent) (*PublishResponse, error)
	// PublishBatch sends a batch of CloudEvents to the ChipIngress service.
	// This method is atomic, meaning it will either succeed or fail for the entire batch.
	// When the server receives a batch of events, it will open a kafka transaction, and begin producing each event sequentially in order received.
	// If any 1 message fails, all previous messages in the same batch that were already produced won't be marked as committed,
	// and the server will respond with an error.
	// Consumers can set isolation.level=read_committed to only read committed records
	PublishBatch(context.Context, *CloudEventBatch) (*PublishResponse, error)
	// Ping sends a request to the ChipIngress service to check if it is alive.
	Ping(context.Context, *EmptyRequest) (*PingResponse, error)
	// StreamEvents; EXPERIMENTAL ~ allows clients to stream CloudEvents to the server.
	// This API is experimental and may change in the future.
	StreamEvents(grpc.BidiStreamingServer[StreamEventsRequest, StreamEventsResponse]) error
	// contains filtered or unexported methods
}

type ChipIngress_StreamEventsClient = grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse]

type ChipIngress_StreamEventsServer = grpc.BidiStreamingServer[StreamEventsRequest, StreamEventsResponse]

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

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

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

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

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

type StreamEventsRequest struct {
	Event *pb.CloudEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type StreamEventsResponse struct {
	EventId string `protobuf:"bytes,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
	Status  string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // e.g., "success", "error"
	// contains filtered or unexported fields
}

type UnimplementedChipIngressServer struct{}

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