eventsv1

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

type AcknowledgementRequest_Acknowledgement int32

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

type DomainEventsServiceClient interface {
	Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (*StreamResponse, error)
	Publish(ctx context.Context, opts ...grpc.CallOption) (DomainEventsService_PublishClient, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (DomainEventsService_SubscribeClient, error)
	Acknowledgement(ctx context.Context, opts ...grpc.CallOption) (DomainEventsService_AcknowledgementClient, error)
}

type DomainEventsServiceServer interface {
	Stream(context.Context, *StreamRequest) (*StreamResponse, error)
	Publish(DomainEventsService_PublishServer) error
	Subscribe(*SubscribeRequest, DomainEventsService_SubscribeServer) error
	Acknowledgement(DomainEventsService_AcknowledgementServer) error
	// contains filtered or unexported methods
}

type DomainEventsService_AcknowledgementClient interface {
	Send(*AcknowledgementRequest) error
	Recv() (*AcknowledgementResponse, error)
	grpc.ClientStream
}

type DomainEventsService_AcknowledgementServer interface {
	Send(*AcknowledgementResponse) error
	Recv() (*AcknowledgementRequest, error)
	grpc.ServerStream
}

type DomainEventsService_PublishClient interface {
	Send(*PublishRequest) error
	CloseAndRecv() (*PublishResponse, error)
	grpc.ClientStream
}

type DomainEventsService_PublishServer interface {
	SendAndClose(*PublishResponse) error
	Recv() (*PublishRequest, error)
	grpc.ServerStream
}

type DomainEventsService_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type DomainEventsService_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type PublishRequest struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Subject   string                 `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	EventTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	Header    map[string]string      `` /* 153-byte string literal not displayed */
	Message   *anypb.Any             `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// Types that are assignable to Action:
	//
	//	*PublishRequest_Event
	//	*PublishRequest_Cron
	Action isPublishRequest_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

type PublishRequest_Cron struct {
	Cron *v1.Cron `protobuf:"bytes,7,opt,name=cron,proto3,oneof"`
}

type PublishRequest_Event struct {
	Event *v1.Event `protobuf:"bytes,6,opt,name=event,proto3,oneof"`
}

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

type StreamRequest struct {
	Name       string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Subject    string                 `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	Policy     v1.AckPolicy           `protobuf:"varint,3,opt,name=policy,proto3,enum=common.v1.AckPolicy" json:"policy,omitempty"`
	Replicas   string                 `protobuf:"bytes,4,opt,name=replicas,proto3" json:"replicas,omitempty"`
	MaxDeliver int32                  `protobuf:"varint,5,opt,name=max_deliver,json=maxDeliver,proto3" json:"max_deliver,omitempty"`
	AckWait    *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=ack_wait,json=ackWait,proto3" json:"ack_wait,omitempty"`
	// contains filtered or unexported fields
}

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

type SubscribeRequest struct {
	Subject    string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	StreamName string `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	RateLimit  int32  `protobuf:"varint,3,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeResponse struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	EventTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	Header    map[string]string      `` /* 153-byte string literal not displayed */
	Message   *anypb.Any             `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedDomainEventsServiceServer struct {
}

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