Versions in this module Expand all Collapse all v1 v1.7.0 Sep 14, 2026 Changes in this version + const InternalSubscriptionService_Subscribe_FullMethodName + var File_corelib_subscription_subscription_proto protoreflect.FileDescriptor + var File_corelib_subscription_subscription_service_proto protoreflect.FileDescriptor + var InternalSubscriptionService_ServiceDesc = grpc.ServiceDesc + var SubscriptionAnchor_name = map[int32]string + var SubscriptionAnchor_value = map[string]int32 + var SubscriptionEvent_Change_name = map[int32]string + var SubscriptionEvent_Change_value = map[string]int32 + var SubscriptionEvent_StateUnavailable_Reason_name = map[int32]string + var SubscriptionEvent_StateUnavailable_Reason_value = map[string]int32 + func RegisterInternalSubscriptionServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterInternalSubscriptionServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, ...) error + func RegisterInternalSubscriptionServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterInternalSubscriptionServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, ...) error + func RegisterInternalSubscriptionServiceServer(s grpc.ServiceRegistrar, srv InternalSubscriptionServiceServer) + type InternalSubscriptionServiceClient interface + Subscribe func(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscriptionMessage], error) + func NewInternalSubscriptionServiceClient(cc grpc.ClientConnInterface) InternalSubscriptionServiceClient + type InternalSubscriptionServiceServer interface + Subscribe func(*SubscriptionRequest, grpc.ServerStreamingServer[SubscriptionMessage]) error + type InternalSubscriptionService_SubscribeClient = grpc.ServerStreamingClient[SubscriptionMessage] + type InternalSubscriptionService_SubscribeServer = grpc.ServerStreamingServer[SubscriptionMessage] + type SubscriptionAnchor int32 + const SubscriptionAnchor_BEGINNING + const SubscriptionAnchor_CURRENT_END + const SubscriptionAnchor_SUBSCRIPTION_ANCHOR_UNSPECIFIED + func (SubscriptionAnchor) Descriptor() protoreflect.EnumDescriptor + func (SubscriptionAnchor) EnumDescriptor() ([]byte, []int) + func (SubscriptionAnchor) Type() protoreflect.EnumType + func (x SubscriptionAnchor) Enum() *SubscriptionAnchor + func (x SubscriptionAnchor) Number() protoreflect.EnumNumber + func (x SubscriptionAnchor) String() string + type SubscriptionEvent struct + Carrier isSubscriptionEvent_Carrier + Change SubscriptionEvent_Change + Kind string + Position string + ProjectId string + ResourceId string + func (*SubscriptionEvent) Descriptor() ([]byte, []int) + func (*SubscriptionEvent) ProtoMessage() + func (x *SubscriptionEvent) GetCarrier() isSubscriptionEvent_Carrier + func (x *SubscriptionEvent) GetChange() SubscriptionEvent_Change + func (x *SubscriptionEvent) GetKind() string + func (x *SubscriptionEvent) GetPosition() string + func (x *SubscriptionEvent) GetProjectId() string + func (x *SubscriptionEvent) GetResourceId() string + func (x *SubscriptionEvent) GetState() *anypb.Any + func (x *SubscriptionEvent) GetStateUnavailable() *SubscriptionEvent_StateUnavailable + func (x *SubscriptionEvent) ProtoReflect() protoreflect.Message + func (x *SubscriptionEvent) Reset() + func (x *SubscriptionEvent) String() string + type SubscriptionEvent_Change int32 + const SubscriptionEvent_CHANGE_UNSPECIFIED + const SubscriptionEvent_CREATED + const SubscriptionEvent_DELETED + const SubscriptionEvent_UPDATED + func (SubscriptionEvent_Change) Descriptor() protoreflect.EnumDescriptor + func (SubscriptionEvent_Change) EnumDescriptor() ([]byte, []int) + func (SubscriptionEvent_Change) Type() protoreflect.EnumType + func (x SubscriptionEvent_Change) Enum() *SubscriptionEvent_Change + func (x SubscriptionEvent_Change) Number() protoreflect.EnumNumber + func (x SubscriptionEvent_Change) String() string + type SubscriptionEvent_State struct + State *anypb.Any + type SubscriptionEvent_StateUnavailable struct + Reason SubscriptionEvent_StateUnavailable_Reason + func (*SubscriptionEvent_StateUnavailable) Descriptor() ([]byte, []int) + func (*SubscriptionEvent_StateUnavailable) ProtoMessage() + func (x *SubscriptionEvent_StateUnavailable) GetReason() SubscriptionEvent_StateUnavailable_Reason + func (x *SubscriptionEvent_StateUnavailable) ProtoReflect() protoreflect.Message + func (x *SubscriptionEvent_StateUnavailable) Reset() + func (x *SubscriptionEvent_StateUnavailable) String() string + type SubscriptionEvent_StateUnavailable_ struct + StateUnavailable *SubscriptionEvent_StateUnavailable + type SubscriptionEvent_StateUnavailable_Reason int32 + const SubscriptionEvent_StateUnavailable_NOT_PRODUCED + const SubscriptionEvent_StateUnavailable_NOT_RETAINED + const SubscriptionEvent_StateUnavailable_NOT_SERIALIZABLE + const SubscriptionEvent_StateUnavailable_REASON_UNSPECIFIED + const SubscriptionEvent_StateUnavailable_WITHHELD + func (SubscriptionEvent_StateUnavailable_Reason) Descriptor() protoreflect.EnumDescriptor + func (SubscriptionEvent_StateUnavailable_Reason) EnumDescriptor() ([]byte, []int) + func (SubscriptionEvent_StateUnavailable_Reason) Type() protoreflect.EnumType + func (x SubscriptionEvent_StateUnavailable_Reason) Enum() *SubscriptionEvent_StateUnavailable_Reason + func (x SubscriptionEvent_StateUnavailable_Reason) Number() protoreflect.EnumNumber + func (x SubscriptionEvent_StateUnavailable_Reason) String() string + type SubscriptionMessage struct + Message isSubscriptionMessage_Message + func (*SubscriptionMessage) Descriptor() ([]byte, []int) + func (*SubscriptionMessage) ProtoMessage() + func (x *SubscriptionMessage) GetEvent() *SubscriptionEvent + func (x *SubscriptionMessage) GetMessage() isSubscriptionMessage_Message + func (x *SubscriptionMessage) GetOpened() *SubscriptionOpened + func (x *SubscriptionMessage) ProtoReflect() protoreflect.Message + func (x *SubscriptionMessage) Reset() + func (x *SubscriptionMessage) String() string + type SubscriptionMessage_Event struct + Event *SubscriptionEvent + type SubscriptionMessage_Opened struct + Opened *SubscriptionOpened + type SubscriptionOpened struct + CaughtUp bool + EarliestResumablePosition string + HonoredFilters []string + KnownKinds []string + Position string + RetainsEverything bool + func (*SubscriptionOpened) Descriptor() ([]byte, []int) + func (*SubscriptionOpened) ProtoMessage() + func (x *SubscriptionOpened) GetCaughtUp() bool + func (x *SubscriptionOpened) GetEarliestResumablePosition() string + func (x *SubscriptionOpened) GetHonoredFilters() []string + func (x *SubscriptionOpened) GetKnownKinds() []string + func (x *SubscriptionOpened) GetPosition() string + func (x *SubscriptionOpened) GetRetainsEverything() bool + func (x *SubscriptionOpened) ProtoReflect() protoreflect.Message + func (x *SubscriptionOpened) Reset() + func (x *SubscriptionOpened) String() string + type SubscriptionRequest struct + Ids []string + Kinds []string + ProjectId string + Start isSubscriptionRequest_Start + func (*SubscriptionRequest) Descriptor() ([]byte, []int) + func (*SubscriptionRequest) ProtoMessage() + func (x *SubscriptionRequest) GetAnchor() SubscriptionAnchor + func (x *SubscriptionRequest) GetIds() []string + func (x *SubscriptionRequest) GetKinds() []string + func (x *SubscriptionRequest) GetPosition() string + func (x *SubscriptionRequest) GetProjectId() string + func (x *SubscriptionRequest) GetStart() isSubscriptionRequest_Start + func (x *SubscriptionRequest) ProtoReflect() protoreflect.Message + func (x *SubscriptionRequest) Reset() + func (x *SubscriptionRequest) String() string + type SubscriptionRequest_Anchor struct + Anchor SubscriptionAnchor + type SubscriptionRequest_Position struct + Position string + type UnimplementedInternalSubscriptionServiceServer struct + func (UnimplementedInternalSubscriptionServiceServer) Subscribe(*SubscriptionRequest, grpc.ServerStreamingServer[SubscriptionMessage]) error + type UnsafeInternalSubscriptionServiceServer interface
Go to main page