rpc

type Ack struct {
	MessageIds []string `protobuf:"bytes,1,rep,name=message_ids" json:"message_ids,omitempty"`
	// contains filtered or unexported fields
}

type EventsPlatformClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscribeRequest, SubscribeResponse], error)
}

type EventsPlatformServer interface {
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	Subscribe(grpc.BidiStreamingServer[SubscribeRequest, SubscribeResponse]) error
	// contains filtered or unexported methods
}

type EventsPlatform_SubscribeClient = grpc.BidiStreamingClient[SubscribeRequest, SubscribeResponse]

type EventsPlatform_SubscribeServer = grpc.BidiStreamingServer[SubscribeRequest, SubscribeResponse]

type PublishRequest struct {
	Topic  string              `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
	Events []*event.CloudEvent `protobuf:"bytes,2,rep,name=events" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type PublishResponse struct {
	MessageIds []string `protobuf:"bytes,1,rep,name=message_ids" json:"message_ids,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeConfig struct {
	Topic         string   `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
	ConsumerGroup string   `protobuf:"bytes,2,opt,name=consumer_group" json:"consumer_group,omitempty"`
	EventTypes    []string `protobuf:"bytes,3,rep,name=event_types" json:"event_types,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*SubscribeRequest_Config
	//	*SubscribeRequest_Ack
	Request isSubscribeRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type SubscribeRequest_Ack struct {
	Ack *Ack `protobuf:"bytes,2,opt,name=ack,oneof"`
}

type SubscribeRequest_Config struct {
	Config *SubscribeConfig `protobuf:"bytes,1,opt,name=config,oneof"`
}

type SubscribeResponse struct {
	Event     *event.CloudEvent `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
	MessageId string            `protobuf:"bytes,2,opt,name=message_id" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventsPlatformServer struct{}

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