eventsv1

package
v0.0.0-...-5bc7920 Latest Latest
Warning

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

 Go to latest Published: Jun 30, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DomainEventsService_Stream_FullMethodName          = "/events.v1.DomainEventsService/Stream"
	DomainEventsService_Publish_FullMethodName         = "/events.v1.DomainEventsService/Publish"
	DomainEventsService_Subscribe_FullMethodName       = "/events.v1.DomainEventsService/Subscribe"
	DomainEventsService_Acknowledgement_FullMethodName = "/events.v1.DomainEventsService/Acknowledgement"
)

Variables

View Source 
var (
	AcknowledgementRequest_Acknowledgement_name = map[int32]string{
		0: "ACKNOWLEDGEMENT_UNSPECIFIED",
		1: "ACKNOWLEDGEMENT_ACK",
		2: "ACKNOWLEDGEMENT_NACK",
		3: "ACKNOWLEDGEMENT_REJECT",
	}
	AcknowledgementRequest_Acknowledgement_value = map[string]int32{
		"ACKNOWLEDGEMENT_UNSPECIFIED": 0,
		"ACKNOWLEDGEMENT_ACK":         1,
		"ACKNOWLEDGEMENT_NACK":        2,
		"ACKNOWLEDGEMENT_REJECT":      3,
	}
)

Enum value maps for AcknowledgementRequest_Acknowledgement.

View Source 
var DomainEventsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "events.v1.DomainEventsService",
	HandlerType: (*DomainEventsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Stream",
			Handler:    _DomainEventsService_Stream_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Publish",
			Handler:       _DomainEventsService_Publish_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _DomainEventsService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Acknowledgement",
			Handler:       _DomainEventsService_Acknowledgement_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "events/v1/domain.proto",
}

DomainEventsService_ServiceDesc is the grpc.ServiceDesc for DomainEventsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_events_v1_domain_proto protoreflect.FileDescriptor

Functions

func RegisterDomainEventsServiceServer 

func RegisterDomainEventsServiceServer(s grpc.ServiceRegistrar, srv DomainEventsServiceServer)

Types

type AcknowledgementRequest 

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

func (*AcknowledgementRequest) Descriptor deprecated 

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

Deprecated: Use AcknowledgementRequest.ProtoReflect.Descriptor instead.

func (*AcknowledgementRequest) GetId 

func (x *AcknowledgementRequest) GetId() string

func (*AcknowledgementRequest) ProtoMessage 

func (*AcknowledgementRequest) ProtoMessage()

func (*AcknowledgementRequest) ProtoReflect 

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

func (*AcknowledgementRequest) Reset 

func (x *AcknowledgementRequest) Reset()

func (*AcknowledgementRequest) String 

func (x *AcknowledgementRequest) String() string

type AcknowledgementRequest_Acknowledgement 

type AcknowledgementRequest_Acknowledgement int32
const (
	AcknowledgementRequest_ACKNOWLEDGEMENT_UNSPECIFIED AcknowledgementRequest_Acknowledgement = 0
	AcknowledgementRequest_ACKNOWLEDGEMENT_ACK         AcknowledgementRequest_Acknowledgement = 1
	AcknowledgementRequest_ACKNOWLEDGEMENT_NACK        AcknowledgementRequest_Acknowledgement = 2
	AcknowledgementRequest_ACKNOWLEDGEMENT_REJECT      AcknowledgementRequest_Acknowledgement = 3
)

func (AcknowledgementRequest_Acknowledgement) Descriptor 

func (AcknowledgementRequest_Acknowledgement) Descriptor() protoreflect.EnumDescriptor

func (AcknowledgementRequest_Acknowledgement) Enum 

func (x AcknowledgementRequest_Acknowledgement) Enum() *AcknowledgementRequest_Acknowledgement

func (AcknowledgementRequest_Acknowledgement) EnumDescriptor deprecated 

func (AcknowledgementRequest_Acknowledgement) EnumDescriptor() ([]byte, []int)

Deprecated: Use AcknowledgementRequest_Acknowledgement.Descriptor instead.

func (AcknowledgementRequest_Acknowledgement) Number 

func (x AcknowledgementRequest_Acknowledgement) Number() protoreflect.EnumNumber

func (AcknowledgementRequest_Acknowledgement) String 

func (x AcknowledgementRequest_Acknowledgement) String() string

func (AcknowledgementRequest_Acknowledgement) Type 

func (AcknowledgementRequest_Acknowledgement) Type() protoreflect.EnumType

type AcknowledgementResponse 

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

func (*AcknowledgementResponse) Descriptor deprecated 

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

Deprecated: Use AcknowledgementResponse.ProtoReflect.Descriptor instead.

func (*AcknowledgementResponse) ProtoMessage 

func (*AcknowledgementResponse) ProtoMessage()

func (*AcknowledgementResponse) ProtoReflect 

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

func (*AcknowledgementResponse) Reset 

func (x *AcknowledgementResponse) Reset()

func (*AcknowledgementResponse) String 

func (x *AcknowledgementResponse) String() string

type DomainEventsServiceClient 

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)
}

DomainEventsServiceClient is the client API for DomainEventsService 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.

func NewDomainEventsServiceClient 

func NewDomainEventsServiceClient(cc grpc.ClientConnInterface) DomainEventsServiceClient

type DomainEventsServiceServer 

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
}

DomainEventsServiceServer is the server API for DomainEventsService service. All implementations must embed UnimplementedDomainEventsServiceServer for forward compatibility

type DomainEventsService_AcknowledgementClient 

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

type DomainEventsService_AcknowledgementServer 

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

type DomainEventsService_PublishClient 

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

type DomainEventsService_PublishServer 

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

type DomainEventsService_SubscribeClient 

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

type DomainEventsService_SubscribeServer 

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

type PublishRequest 

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
}

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetAction 

func (m *PublishRequest) GetAction() isPublishRequest_Action

func (*PublishRequest) GetCron 

func (x *PublishRequest) GetCron() *v1.Cron

func (*PublishRequest) GetEvent 

func (x *PublishRequest) GetEvent() *v1.Event

func (*PublishRequest) GetEventTime 

func (x *PublishRequest) GetEventTime() *timestamppb.Timestamp

func (*PublishRequest) GetHeader 

func (x *PublishRequest) GetHeader() map[string]string

func (*PublishRequest) GetId 

func (x *PublishRequest) GetId() string

func (*PublishRequest) GetMessage 

func (x *PublishRequest) GetMessage() *anypb.Any

func (*PublishRequest) GetSubject 

func (x *PublishRequest) GetSubject() string

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

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

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type PublishRequest_Cron 

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

type PublishRequest_Event 

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

type PublishResponse 

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

func (*PublishResponse) Descriptor deprecated 

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect 

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

func (*PublishResponse) Reset 

func (x *PublishResponse) Reset()

func (*PublishResponse) String 

func (x *PublishResponse) String() string

type StreamRequest 

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
}

func (*StreamRequest) Descriptor deprecated 

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

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetAckWait 

func (x *StreamRequest) GetAckWait() *timestamppb.Timestamp

func (*StreamRequest) GetMaxDeliver 

func (x *StreamRequest) GetMaxDeliver() int32

func (*StreamRequest) GetName 

func (x *StreamRequest) GetName() string

func (*StreamRequest) GetPolicy 

func (x *StreamRequest) GetPolicy() v1.AckPolicy

func (*StreamRequest) GetReplicas 

func (x *StreamRequest) GetReplicas() string

func (*StreamRequest) GetSubject 

func (x *StreamRequest) GetSubject() string

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect 

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

func (*StreamRequest) Reset 

func (x *StreamRequest) Reset()

func (*StreamRequest) String 

func (x *StreamRequest) String() string

type StreamResponse 

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

func (*StreamResponse) Descriptor deprecated 

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetId 

func (x *StreamResponse) GetId() string

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect 

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

func (*StreamResponse) Reset 

func (x *StreamResponse) Reset()

func (*StreamResponse) String 

func (x *StreamResponse) String() string

type SubscribeRequest 

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
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetRateLimit 

func (x *SubscribeRequest) GetRateLimit() int32

func (*SubscribeRequest) GetStreamName 

func (x *SubscribeRequest) GetStreamName() string

func (*SubscribeRequest) GetSubject 

func (x *SubscribeRequest) GetSubject() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

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
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetEventTime 

func (x *SubscribeResponse) GetEventTime() *timestamppb.Timestamp

func (*SubscribeResponse) GetHeader 

func (x *SubscribeResponse) GetHeader() map[string]string

func (*SubscribeResponse) GetId 

func (x *SubscribeResponse) GetId() string

func (*SubscribeResponse) GetMessage 

func (x *SubscribeResponse) GetMessage() *anypb.Any

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type UnimplementedDomainEventsServiceServer 

type UnimplementedDomainEventsServiceServer struct {
}

UnimplementedDomainEventsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDomainEventsServiceServer) Acknowledgement 

func (UnimplementedDomainEventsServiceServer) Acknowledgement(DomainEventsService_AcknowledgementServer) error

func (UnimplementedDomainEventsServiceServer) Publish 

func (UnimplementedDomainEventsServiceServer) Publish(DomainEventsService_PublishServer) error

func (UnimplementedDomainEventsServiceServer) Stream 

func (UnimplementedDomainEventsServiceServer) Stream(context.Context, *StreamRequest) (*StreamResponse, error)

func (UnimplementedDomainEventsServiceServer) Subscribe 

func (UnimplementedDomainEventsServiceServer) Subscribe(*SubscribeRequest, DomainEventsService_SubscribeServer) error

type UnsafeDomainEventsServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.