proxy

package

Go to main page

Versions in this module

v0

v0.9.0

Sep 7, 2023

v0.8.0

Apr 17, 2023

Changes in this version

+ const ControllerProxy_CreateNamespace_FullMethodName

+ const ControllerProxy_CreateToken_FullMethodName

+ const ControllerProxy_CreateUser_FullMethodName

+ const ControllerProxy_DeleteNamespace_FullMethodName

+ const ControllerProxy_DeleteToken_FullMethodName

+ const ControllerProxy_DeleteUser_FullMethodName

+ const ControllerProxy_GetNamespace_FullMethodName

+ const ControllerProxy_GetResourceRole_FullMethodName

+ const ControllerProxy_GetUserRole_FullMethodName

+ const ControllerProxy_GetUserToken_FullMethodName

+ const ControllerProxy_GetUser_FullMethodName

+ const ControllerProxy_GrantRole_FullMethodName

+ const ControllerProxy_ListNamespace_FullMethodName

+ const ControllerProxy_ListToken_FullMethodName

+ const ControllerProxy_ListUser_FullMethodName

+ const ControllerProxy_RevokeRole_FullMethodName

type ControllerProxyClient

+ CreateNamespace func(ctx context.Context, in *controller.CreateNamespaceRequest, ...) (*meta.Namespace, error)

+ CreateToken func(ctx context.Context, in *controller.CreateTokenRequest, ...) (*meta.Token, error)

+ CreateUser func(ctx context.Context, in *controller.CreateUserRequest, opts ...grpc.CallOption) (*meta.User, error)

+ DeleteNamespace func(ctx context.Context, in *controller.DeleteNamespaceRequest, ...) (*emptypb.Empty, error)

+ DeleteToken func(ctx context.Context, in *controller.DeleteTokenRequest, ...) (*emptypb.Empty, error)

+ DeleteUser func(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetNamespace func(ctx context.Context, in *controller.GetNamespaceRequest, ...) (*meta.Namespace, error)

+ GetResourceRole func(ctx context.Context, in *controller.GetResourceRoleRequest, ...) (*controller.GetResourceRoleResponse, error)

+ GetUser func(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*meta.User, error)

+ GetUserRole func(ctx context.Context, in *controller.GetUserRoleRequest, ...) (*controller.GetUserRoleResponse, error)

+ GetUserToken func(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*controller.GetTokenResponse, error)

+ GrantRole func(ctx context.Context, in *controller.RoleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ ListNamespace func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*controller.ListNamespaceResponse, error)

+ ListToken func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*controller.ListTokenResponse, error)

+ ListUser func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*controller.ListUserResponse, error)

+ RevokeRole func(ctx context.Context, in *controller.RoleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

type ControllerProxyServer

+ CreateNamespace func(context.Context, *controller.CreateNamespaceRequest) (*meta.Namespace, error)

+ CreateToken func(context.Context, *controller.CreateTokenRequest) (*meta.Token, error)

+ CreateUser func(context.Context, *controller.CreateUserRequest) (*meta.User, error)

+ DeleteNamespace func(context.Context, *controller.DeleteNamespaceRequest) (*emptypb.Empty, error)

+ DeleteToken func(context.Context, *controller.DeleteTokenRequest) (*emptypb.Empty, error)

+ DeleteUser func(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)

+ GetNamespace func(context.Context, *controller.GetNamespaceRequest) (*meta.Namespace, error)

+ GetResourceRole func(context.Context, *controller.GetResourceRoleRequest) (*controller.GetResourceRoleResponse, error)

+ GetUser func(context.Context, *wrapperspb.StringValue) (*meta.User, error)

+ GetUserRole func(context.Context, *controller.GetUserRoleRequest) (*controller.GetUserRoleResponse, error)

+ GetUserToken func(context.Context, *wrapperspb.StringValue) (*controller.GetTokenResponse, error)

+ GrantRole func(context.Context, *controller.RoleRequest) (*emptypb.Empty, error)

+ ListNamespace func(context.Context, *emptypb.Empty) (*controller.ListNamespaceResponse, error)

+ ListToken func(context.Context, *emptypb.Empty) (*controller.ListTokenResponse, error)

+ ListUser func(context.Context, *emptypb.Empty) (*controller.ListUserResponse, error)

+ RevokeRole func(context.Context, *controller.RoleRequest) (*emptypb.Empty, error)

type UnimplementedControllerProxyServer

+ func (UnimplementedControllerProxyServer) CreateNamespace(context.Context, *controller.CreateNamespaceRequest) (*meta.Namespace, error)

+ func (UnimplementedControllerProxyServer) CreateToken(context.Context, *controller.CreateTokenRequest) (*meta.Token, error)

+ func (UnimplementedControllerProxyServer) CreateUser(context.Context, *controller.CreateUserRequest) (*meta.User, error)

+ func (UnimplementedControllerProxyServer) DeleteNamespace(context.Context, *controller.DeleteNamespaceRequest) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) DeleteToken(context.Context, *controller.DeleteTokenRequest) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) DeleteUser(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) GetNamespace(context.Context, *controller.GetNamespaceRequest) (*meta.Namespace, error)

+ func (UnimplementedControllerProxyServer) GetResourceRole(context.Context, *controller.GetResourceRoleRequest) (*controller.GetResourceRoleResponse, error)

+ func (UnimplementedControllerProxyServer) GetUser(context.Context, *wrapperspb.StringValue) (*meta.User, error)

+ func (UnimplementedControllerProxyServer) GetUserRole(context.Context, *controller.GetUserRoleRequest) (*controller.GetUserRoleResponse, error)

+ func (UnimplementedControllerProxyServer) GetUserToken(context.Context, *wrapperspb.StringValue) (*controller.GetTokenResponse, error)

+ func (UnimplementedControllerProxyServer) GrantRole(context.Context, *controller.RoleRequest) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) ListNamespace(context.Context, *emptypb.Empty) (*controller.ListNamespaceResponse, error)

+ func (UnimplementedControllerProxyServer) ListToken(context.Context, *emptypb.Empty) (*controller.ListTokenResponse, error)

+ func (UnimplementedControllerProxyServer) ListUser(context.Context, *emptypb.Empty) (*controller.ListUserResponse, error)

+ func (UnimplementedControllerProxyServer) RevokeRole(context.Context, *controller.RoleRequest) (*emptypb.Empty, error)

v0.7.1

Mar 13, 2023

Changes in this version

+ const ControllerProxy_ClusterInfo_FullMethodName

+ const ControllerProxy_CreateEventbus_FullMethodName

+ const ControllerProxy_CreateSubscription_FullMethodName

+ const ControllerProxy_DeleteEventbus_FullMethodName

+ const ControllerProxy_DeleteSubscription_FullMethodName

+ const ControllerProxy_DisableSubscription_FullMethodName

+ const ControllerProxy_GetDeadLetterEvent_FullMethodName

+ const ControllerProxy_GetEvent_FullMethodName

+ const ControllerProxy_GetEventbusWithHumanFriendly_FullMethodName

+ const ControllerProxy_GetEventbus_FullMethodName

+ const ControllerProxy_GetNamespaceWithHumanFriendly_FullMethodName

+ const ControllerProxy_GetSubscription_FullMethodName

+ const ControllerProxy_ListEventbus_FullMethodName

+ const ControllerProxy_ListSegment_FullMethodName

+ const ControllerProxy_ListSubscription_FullMethodName

+ const ControllerProxy_LookupOffset_FullMethodName

+ const ControllerProxy_ResendDeadLetterEvent_FullMethodName

+ const ControllerProxy_ResetOffsetToTimestamp_FullMethodName

+ const ControllerProxy_ResumeSubscription_FullMethodName

+ const ControllerProxy_SetDeadLetterEventOffset_FullMethodName

+ const ControllerProxy_UpdateEventbus_FullMethodName

+ const ControllerProxy_UpdateSubscription_FullMethodName

+ const ControllerProxy_ValidateSubscription_FullMethodName

+ const StoreProxy_Ack_FullMethodName

+ const StoreProxy_Publish_FullMethodName

+ const StoreProxy_Subscribe_FullMethodName

+ var ControllerProxy_ServiceDesc = grpc.ServiceDesc

+ var File_proxy_proto protoreflect.FileDescriptor

+ var StoreProxy_ServiceDesc = grpc.ServiceDesc

+ func RegisterControllerProxyServer(s grpc.ServiceRegistrar, srv ControllerProxyServer)

+ func RegisterStoreProxyServer(s grpc.ServiceRegistrar, srv StoreProxyServer)

+ type AckRequest struct

+ SequenceId uint64

+ SubscriptionId string

+ Success bool

+ func (*AckRequest) Descriptor() ([]byte, []int)

+ func (*AckRequest) ProtoMessage()

+ func (x *AckRequest) GetSequenceId() uint64

+ func (x *AckRequest) GetSubscriptionId() string

+ func (x *AckRequest) GetSuccess() bool

+ func (x *AckRequest) ProtoReflect() protoreflect.Message

+ func (x *AckRequest) Reset()

+ func (x *AckRequest) String() string

+ type ClusterInfoResponse struct

+ CloudeventsPort int64

+ ProxyPort int64

+ func (*ClusterInfoResponse) Descriptor() ([]byte, []int)

+ func (*ClusterInfoResponse) ProtoMessage()

+ func (x *ClusterInfoResponse) GetCloudeventsPort() int64

+ func (x *ClusterInfoResponse) GetProxyPort() int64

+ func (x *ClusterInfoResponse) ProtoReflect() protoreflect.Message

+ func (x *ClusterInfoResponse) Reset()

+ func (x *ClusterInfoResponse) String() string

+ type ControllerProxyClient interface

+ ClusterInfo func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClusterInfoResponse, error)

+ CreateEventbus func(ctx context.Context, in *controller.CreateEventbusRequest, ...) (*meta.Eventbus, error)

+ CreateSubscription func(ctx context.Context, in *controller.CreateSubscriptionRequest, ...) (*meta.Subscription, error)

+ DeleteEventbus func(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteSubscription func(ctx context.Context, in *controller.DeleteSubscriptionRequest, ...) (*emptypb.Empty, error)

+ DisableSubscription func(ctx context.Context, in *controller.DisableSubscriptionRequest, ...) (*emptypb.Empty, error)

+ GetDeadLetterEvent func(ctx context.Context, in *GetDeadLetterEventRequest, opts ...grpc.CallOption) (*GetDeadLetterEventResponse, error)

+ GetEvent func(ctx context.Context, in *GetEventRequest, opts ...grpc.CallOption) (*GetEventResponse, error)

+ GetEventbus func(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*meta.Eventbus, error)

+ GetEventbusWithHumanFriendly func(ctx context.Context, in *controller.GetEventbusWithHumanFriendlyRequest, ...) (*meta.Eventbus, error)

+ GetNamespaceWithHumanFriendly func(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*meta.Namespace, error)

+ GetSubscription func(ctx context.Context, in *controller.GetSubscriptionRequest, ...) (*meta.Subscription, error)

+ ListEventbus func(ctx context.Context, in *controller.ListEventbusRequest, ...) (*controller.ListEventbusResponse, error)

+ ListSegment func(ctx context.Context, in *controller.ListSegmentRequest, ...) (*controller.ListSegmentResponse, error)

+ ListSubscription func(ctx context.Context, in *controller.ListSubscriptionRequest, ...) (*controller.ListSubscriptionResponse, error)

+ LookupOffset func(ctx context.Context, in *LookupOffsetRequest, opts ...grpc.CallOption) (*LookupOffsetResponse, error)

+ ResendDeadLetterEvent func(ctx context.Context, in *ResendDeadLetterEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ ResetOffsetToTimestamp func(ctx context.Context, in *controller.ResetOffsetToTimestampRequest, ...) (*controller.ResetOffsetToTimestampResponse, error)

+ ResumeSubscription func(ctx context.Context, in *controller.ResumeSubscriptionRequest, ...) (*emptypb.Empty, error)

+ SetDeadLetterEventOffset func(ctx context.Context, in *controller.SetDeadLetterEventOffsetRequest, ...) (*emptypb.Empty, error)

+ UpdateEventbus func(ctx context.Context, in *controller.UpdateEventbusRequest, ...) (*meta.Eventbus, error)

+ UpdateSubscription func(ctx context.Context, in *controller.UpdateSubscriptionRequest, ...) (*meta.Subscription, error)

+ ValidateSubscription func(ctx context.Context, in *ValidateSubscriptionRequest, opts ...grpc.CallOption) (*ValidateSubscriptionResponse, error)

+ func NewControllerProxyClient(cc grpc.ClientConnInterface) ControllerProxyClient

+ type ControllerProxyServer interface

+ ClusterInfo func(context.Context, *emptypb.Empty) (*ClusterInfoResponse, error)

+ CreateEventbus func(context.Context, *controller.CreateEventbusRequest) (*meta.Eventbus, error)

+ CreateSubscription func(context.Context, *controller.CreateSubscriptionRequest) (*meta.Subscription, error)

+ DeleteEventbus func(context.Context, *wrapperspb.UInt64Value) (*emptypb.Empty, error)

+ DeleteSubscription func(context.Context, *controller.DeleteSubscriptionRequest) (*emptypb.Empty, error)

+ DisableSubscription func(context.Context, *controller.DisableSubscriptionRequest) (*emptypb.Empty, error)

+ GetDeadLetterEvent func(context.Context, *GetDeadLetterEventRequest) (*GetDeadLetterEventResponse, error)

+ GetEvent func(context.Context, *GetEventRequest) (*GetEventResponse, error)

+ GetEventbus func(context.Context, *wrapperspb.UInt64Value) (*meta.Eventbus, error)

+ GetEventbusWithHumanFriendly func(context.Context, *controller.GetEventbusWithHumanFriendlyRequest) (*meta.Eventbus, error)

+ GetNamespaceWithHumanFriendly func(context.Context, *wrapperspb.StringValue) (*meta.Namespace, error)

+ GetSubscription func(context.Context, *controller.GetSubscriptionRequest) (*meta.Subscription, error)

+ ListEventbus func(context.Context, *controller.ListEventbusRequest) (*controller.ListEventbusResponse, error)

+ ListSegment func(context.Context, *controller.ListSegmentRequest) (*controller.ListSegmentResponse, error)

+ ListSubscription func(context.Context, *controller.ListSubscriptionRequest) (*controller.ListSubscriptionResponse, error)

+ LookupOffset func(context.Context, *LookupOffsetRequest) (*LookupOffsetResponse, error)

+ ResendDeadLetterEvent func(context.Context, *ResendDeadLetterEventRequest) (*emptypb.Empty, error)

+ ResetOffsetToTimestamp func(context.Context, *controller.ResetOffsetToTimestampRequest) (*controller.ResetOffsetToTimestampResponse, error)

+ ResumeSubscription func(context.Context, *controller.ResumeSubscriptionRequest) (*emptypb.Empty, error)

+ SetDeadLetterEventOffset func(context.Context, *controller.SetDeadLetterEventOffsetRequest) (*emptypb.Empty, error)

+ UpdateEventbus func(context.Context, *controller.UpdateEventbusRequest) (*meta.Eventbus, error)

+ UpdateSubscription func(context.Context, *controller.UpdateSubscriptionRequest) (*meta.Subscription, error)

+ ValidateSubscription func(context.Context, *ValidateSubscriptionRequest) (*ValidateSubscriptionResponse, error)

+ type GetDeadLetterEventRequest struct

+ Number int32

+ Offset uint64

+ SubscriptionId uint64

+ func (*GetDeadLetterEventRequest) Descriptor() ([]byte, []int)

+ func (*GetDeadLetterEventRequest) ProtoMessage()

+ func (x *GetDeadLetterEventRequest) GetNumber() int32

+ func (x *GetDeadLetterEventRequest) GetOffset() uint64

+ func (x *GetDeadLetterEventRequest) GetSubscriptionId() uint64

+ func (x *GetDeadLetterEventRequest) ProtoReflect() protoreflect.Message

+ func (x *GetDeadLetterEventRequest) Reset()

+ func (x *GetDeadLetterEventRequest) String() string

+ type GetDeadLetterEventResponse struct

+ Events []*wrapperspb.BytesValue

+ func (*GetDeadLetterEventResponse) Descriptor() ([]byte, []int)

+ func (*GetDeadLetterEventResponse) ProtoMessage()

+ func (x *GetDeadLetterEventResponse) GetEvents() []*wrapperspb.BytesValue

+ func (x *GetDeadLetterEventResponse) ProtoReflect() protoreflect.Message

+ func (x *GetDeadLetterEventResponse) Reset()

+ func (x *GetDeadLetterEventResponse) String() string

+ type GetEventRequest struct

+ EventId string

+ EventbusId uint64

+ EventlogId uint64

+ Number int32

+ Offset int64

+ func (*GetEventRequest) Descriptor() ([]byte, []int)

+ func (*GetEventRequest) ProtoMessage()

+ func (x *GetEventRequest) GetEventId() string

+ func (x *GetEventRequest) GetEventbusId() uint64

+ func (x *GetEventRequest) GetEventlogId() uint64

+ func (x *GetEventRequest) GetNumber() int32

+ func (x *GetEventRequest) GetOffset() int64

+ func (x *GetEventRequest) ProtoReflect() protoreflect.Message

+ func (x *GetEventRequest) Reset()

+ func (x *GetEventRequest) String() string

+ type GetEventResponse struct

+ Events []*wrapperspb.BytesValue

+ func (*GetEventResponse) Descriptor() ([]byte, []int)

+ func (*GetEventResponse) ProtoMessage()

+ func (x *GetEventResponse) GetEvents() []*wrapperspb.BytesValue

+ func (x *GetEventResponse) ProtoReflect() protoreflect.Message

+ func (x *GetEventResponse) Reset()

+ func (x *GetEventResponse) String() string

+ type LookupOffsetRequest struct

+ EventbusId uint64

+ EventlogId uint64

+ Timestamp int64

+ func (*LookupOffsetRequest) Descriptor() ([]byte, []int)

+ func (*LookupOffsetRequest) ProtoMessage()

+ func (x *LookupOffsetRequest) GetEventbusId() uint64

+ func (x *LookupOffsetRequest) GetEventlogId() uint64

+ func (x *LookupOffsetRequest) GetTimestamp() int64

+ func (x *LookupOffsetRequest) ProtoReflect() protoreflect.Message

+ func (x *LookupOffsetRequest) Reset()

+ func (x *LookupOffsetRequest) String() string

+ type LookupOffsetResponse struct

+ Offsets map[uint64]int64

+ func (*LookupOffsetResponse) Descriptor() ([]byte, []int)

+ func (*LookupOffsetResponse) ProtoMessage()

+ func (x *LookupOffsetResponse) GetOffsets() map[uint64]int64

+ func (x *LookupOffsetResponse) ProtoReflect() protoreflect.Message

+ func (x *LookupOffsetResponse) Reset()

+ func (x *LookupOffsetResponse) String() string

+ type PublishRequest struct

+ EventbusId uint64

+ Events *cloudevents.CloudEventBatch

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

+ func (*PublishRequest) ProtoMessage()

+ func (x *PublishRequest) GetEventbusId() uint64

+ func (x *PublishRequest) GetEvents() *cloudevents.CloudEventBatch

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

+ func (x *PublishRequest) Reset()

+ func (x *PublishRequest) String() string

+ type ResendDeadLetterEventRequest struct

+ EndOffset uint64

+ StartOffset uint64

+ SubscriptionId uint64

+ func (*ResendDeadLetterEventRequest) Descriptor() ([]byte, []int)

+ func (*ResendDeadLetterEventRequest) ProtoMessage()

+ func (x *ResendDeadLetterEventRequest) GetEndOffset() uint64

+ func (x *ResendDeadLetterEventRequest) GetStartOffset() uint64

+ func (x *ResendDeadLetterEventRequest) GetSubscriptionId() uint64

+ func (x *ResendDeadLetterEventRequest) ProtoReflect() protoreflect.Message

+ func (x *ResendDeadLetterEventRequest) Reset()

+ func (x *ResendDeadLetterEventRequest) String() string

+ type StoreProxyClient interface

+ Ack func(ctx context.Context, opts ...grpc.CallOption) (StoreProxy_AckClient, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (StoreProxy_SubscribeClient, error)

+ func NewStoreProxyClient(cc grpc.ClientConnInterface) StoreProxyClient

+ type StoreProxyServer interface

+ Ack func(StoreProxy_AckServer) error

+ Publish func(context.Context, *PublishRequest) (*emptypb.Empty, error)

+ Subscribe func(*SubscribeRequest, StoreProxy_SubscribeServer) error

+ type StoreProxy_AckClient interface

+ CloseAndRecv func() (*emptypb.Empty, error)

+ Send func(*AckRequest) error

+ type StoreProxy_AckServer interface

+ Recv func() (*AckRequest, error)

+ SendAndClose func(*emptypb.Empty) error

+ type StoreProxy_SubscribeClient interface

+ Recv func() (*SubscribeResponse, error)

+ type StoreProxy_SubscribeServer interface

+ Send func(*SubscribeResponse) error

+ type SubscribeRequest struct

+ EventbusId uint64

+ SubscriptionId string

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

+ func (*SubscribeRequest) ProtoMessage()

+ func (x *SubscribeRequest) GetEventbusId() uint64

+ func (x *SubscribeRequest) GetSubscriptionId() string

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

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type SubscribeResponse struct

+ Events *cloudevents.CloudEventBatch

+ SequenceId uint64

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

+ func (*SubscribeResponse) ProtoMessage()

+ func (x *SubscribeResponse) GetEvents() *cloudevents.CloudEventBatch

+ func (x *SubscribeResponse) GetSequenceId() uint64

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

+ func (x *SubscribeResponse) Reset()

+ func (x *SubscribeResponse) String() string

+ type UnimplementedControllerProxyServer struct

+ func (UnimplementedControllerProxyServer) ClusterInfo(context.Context, *emptypb.Empty) (*ClusterInfoResponse, error)

+ func (UnimplementedControllerProxyServer) CreateEventbus(context.Context, *controller.CreateEventbusRequest) (*meta.Eventbus, error)

+ func (UnimplementedControllerProxyServer) CreateSubscription(context.Context, *controller.CreateSubscriptionRequest) (*meta.Subscription, error)

+ func (UnimplementedControllerProxyServer) DeleteEventbus(context.Context, *wrapperspb.UInt64Value) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) DeleteSubscription(context.Context, *controller.DeleteSubscriptionRequest) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) DisableSubscription(context.Context, *controller.DisableSubscriptionRequest) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) GetDeadLetterEvent(context.Context, *GetDeadLetterEventRequest) (*GetDeadLetterEventResponse, error)

+ func (UnimplementedControllerProxyServer) GetEvent(context.Context, *GetEventRequest) (*GetEventResponse, error)

+ func (UnimplementedControllerProxyServer) GetEventbus(context.Context, *wrapperspb.UInt64Value) (*meta.Eventbus, error)

+ func (UnimplementedControllerProxyServer) GetEventbusWithHumanFriendly(context.Context, *controller.GetEventbusWithHumanFriendlyRequest) (*meta.Eventbus, error)

+ func (UnimplementedControllerProxyServer) GetNamespaceWithHumanFriendly(context.Context, *wrapperspb.StringValue) (*meta.Namespace, error)

+ func (UnimplementedControllerProxyServer) GetSubscription(context.Context, *controller.GetSubscriptionRequest) (*meta.Subscription, error)

+ func (UnimplementedControllerProxyServer) ListEventbus(context.Context, *controller.ListEventbusRequest) (*controller.ListEventbusResponse, error)

+ func (UnimplementedControllerProxyServer) ListSegment(context.Context, *controller.ListSegmentRequest) (*controller.ListSegmentResponse, error)

+ func (UnimplementedControllerProxyServer) ListSubscription(context.Context, *controller.ListSubscriptionRequest) (*controller.ListSubscriptionResponse, error)

+ func (UnimplementedControllerProxyServer) LookupOffset(context.Context, *LookupOffsetRequest) (*LookupOffsetResponse, error)

+ func (UnimplementedControllerProxyServer) ResendDeadLetterEvent(context.Context, *ResendDeadLetterEventRequest) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) ResetOffsetToTimestamp(context.Context, *controller.ResetOffsetToTimestampRequest) (*controller.ResetOffsetToTimestampResponse, error)

+ func (UnimplementedControllerProxyServer) ResumeSubscription(context.Context, *controller.ResumeSubscriptionRequest) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) SetDeadLetterEventOffset(context.Context, *controller.SetDeadLetterEventOffsetRequest) (*emptypb.Empty, error)

+ func (UnimplementedControllerProxyServer) UpdateEventbus(context.Context, *controller.UpdateEventbusRequest) (*meta.Eventbus, error)

+ func (UnimplementedControllerProxyServer) UpdateSubscription(context.Context, *controller.UpdateSubscriptionRequest) (*meta.Subscription, error)

+ func (UnimplementedControllerProxyServer) ValidateSubscription(context.Context, *ValidateSubscriptionRequest) (*ValidateSubscriptionResponse, error)

+ type UnimplementedStoreProxyServer struct

+ func (UnimplementedStoreProxyServer) Ack(StoreProxy_AckServer) error

+ func (UnimplementedStoreProxyServer) Publish(context.Context, *PublishRequest) (*emptypb.Empty, error)

+ func (UnimplementedStoreProxyServer) Subscribe(*SubscribeRequest, StoreProxy_SubscribeServer) error

+ type UnsafeControllerProxyServer interface

+ type UnsafeStoreProxyServer interface

+ type ValidateSubscriptionRequest struct

+ Event []byte

+ EventbusId uint64

+ Eventlog uint64

+ Offset int64

+ Subscription *controller.SubscriptionRequest

+ SubscriptionId uint64

+ func (*ValidateSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*ValidateSubscriptionRequest) ProtoMessage()

+ func (x *ValidateSubscriptionRequest) GetEvent() []byte

+ func (x *ValidateSubscriptionRequest) GetEventbusId() uint64

+ func (x *ValidateSubscriptionRequest) GetEventlog() uint64

+ func (x *ValidateSubscriptionRequest) GetOffset() int64

+ func (x *ValidateSubscriptionRequest) GetSubscription() *controller.SubscriptionRequest

+ func (x *ValidateSubscriptionRequest) GetSubscriptionId() uint64

+ func (x *ValidateSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateSubscriptionRequest) Reset()

+ func (x *ValidateSubscriptionRequest) String() string

+ type ValidateSubscriptionResponse struct

+ FilterResult bool

+ TransformerResult []byte

+ func (*ValidateSubscriptionResponse) Descriptor() ([]byte, []int)

+ func (*ValidateSubscriptionResponse) ProtoMessage()

+ func (x *ValidateSubscriptionResponse) GetFilterResult() bool

+ func (x *ValidateSubscriptionResponse) GetTransformerResult() []byte

+ func (x *ValidateSubscriptionResponse) ProtoReflect() protoreflect.Message

+ func (x *ValidateSubscriptionResponse) Reset()

+ func (x *ValidateSubscriptionResponse) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL