controller

package

Go to main page

Versions in this module

v0

v0.9.0

Sep 7, 2023

Changes in this version

type CreateEventbusRequest

+ Id uint64

+ func (x *CreateEventbusRequest) GetId() uint64

type CreateNamespaceRequest

+ Id uint64

+ func (x *CreateNamespaceRequest) GetId() uint64

type CreateSubscriptionRequest

+ Id uint64

+ func (x *CreateSubscriptionRequest) GetId() uint64

v0.8.0

Apr 17, 2023

Changes in this version

+ const AuthController_CreateToken_FullMethodName

+ const AuthController_CreateUser_FullMethodName

+ const AuthController_DeleteToken_FullMethodName

+ const AuthController_DeleteUser_FullMethodName

+ const AuthController_GetResourceRole_FullMethodName

+ const AuthController_GetToken_FullMethodName

+ const AuthController_GetUserByToken_FullMethodName

+ const AuthController_GetUserRole_FullMethodName

+ const AuthController_GetUserToken_FullMethodName

+ const AuthController_GetUser_FullMethodName

+ const AuthController_GrantRole_FullMethodName

+ const AuthController_ListToken_FullMethodName

+ const AuthController_ListUser_FullMethodName

+ const AuthController_RevokeRole_FullMethodName

+ var AuthController_ServiceDesc = grpc.ServiceDesc

+ func RegisterAuthControllerServer(s grpc.ServiceRegistrar, srv AuthControllerServer)

+ type AuthControllerClient interface

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

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

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

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

+ GetResourceRole func(ctx context.Context, in *GetResourceRoleRequest, opts ...grpc.CallOption) (*GetResourceRoleResponse, error)

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

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

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

+ GetUserRole func(ctx context.Context, in *GetUserRoleRequest, opts ...grpc.CallOption) (*GetUserRoleResponse, error)

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

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

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

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

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

+ func NewAuthControllerClient(cc grpc.ClientConnInterface) AuthControllerClient

+ type AuthControllerServer interface

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

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

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

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

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

+ GetToken func(context.Context, *wrapperspb.UInt64Value) (*meta.Token, error)

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

+ GetUserByToken func(context.Context, *wrapperspb.StringValue) (*wrapperspb.StringValue, error)

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

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

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

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

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

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

+ type CreateTokenRequest struct

+ Description string

+ UserIdentifier string

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

+ func (*CreateTokenRequest) ProtoMessage()

+ func (x *CreateTokenRequest) GetDescription() string

+ func (x *CreateTokenRequest) GetUserIdentifier() string

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

+ func (x *CreateTokenRequest) Reset()

+ func (x *CreateTokenRequest) String() string

+ type CreateUserRequest struct

+ Description string

+ Identifier string

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

+ func (*CreateUserRequest) ProtoMessage()

+ func (x *CreateUserRequest) GetDescription() string

+ func (x *CreateUserRequest) GetIdentifier() string

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

+ func (x *CreateUserRequest) Reset()

+ func (x *CreateUserRequest) String() string

+ type DeleteTokenRequest struct

+ Id uint64

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

+ func (*DeleteTokenRequest) ProtoMessage()

+ func (x *DeleteTokenRequest) GetId() uint64

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

+ func (x *DeleteTokenRequest) Reset()

+ func (x *DeleteTokenRequest) String() string

+ type DeleteUserResponse struct

+ Identifier string

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

+ func (*DeleteUserResponse) ProtoMessage()

+ func (x *DeleteUserResponse) GetIdentifier() string

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

+ func (x *DeleteUserResponse) Reset()

+ func (x *DeleteUserResponse) String() string

type DisableSubscriptionRequest

+ Declaratively bool

+ func (x *DisableSubscriptionRequest) GetDeclaratively() bool

+ type GetResourceRoleRequest struct

+ Id uint64

+ Kind string

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

+ func (*GetResourceRoleRequest) ProtoMessage()

+ func (x *GetResourceRoleRequest) GetId() uint64

+ func (x *GetResourceRoleRequest) GetKind() string

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

+ func (x *GetResourceRoleRequest) Reset()

+ func (x *GetResourceRoleRequest) String() string

+ type GetResourceRoleResponse struct

+ ResourceRole []*meta.ResourceRole

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

+ func (*GetResourceRoleResponse) ProtoMessage()

+ func (x *GetResourceRoleResponse) GetResourceRole() []*meta.ResourceRole

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

+ func (x *GetResourceRoleResponse) Reset()

+ func (x *GetResourceRoleResponse) String() string

+ type GetTokenResponse struct

+ Token []*meta.Token

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

+ func (*GetTokenResponse) ProtoMessage()

+ func (x *GetTokenResponse) GetToken() []*meta.Token

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

+ func (x *GetTokenResponse) Reset()

+ func (x *GetTokenResponse) String() string

+ type GetUserRoleRequest struct

+ UserIdentifier string

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

+ func (*GetUserRoleRequest) ProtoMessage()

+ func (x *GetUserRoleRequest) GetUserIdentifier() string

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

+ func (x *GetUserRoleRequest) Reset()

+ func (x *GetUserRoleRequest) String() string

+ type GetUserRoleResponse struct

+ UserRole []*meta.UserRole

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

+ func (*GetUserRoleResponse) ProtoMessage()

+ func (x *GetUserRoleResponse) GetUserRole() []*meta.UserRole

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

+ func (x *GetUserRoleResponse) Reset()

+ func (x *GetUserRoleResponse) String() string

+ type ListTokenResponse struct

+ Token []*meta.Token

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

+ func (*ListTokenResponse) ProtoMessage()

+ func (x *ListTokenResponse) GetToken() []*meta.Token

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

+ func (x *ListTokenResponse) Reset()

+ func (x *ListTokenResponse) String() string

+ type ListUserResponse struct

+ Users []*meta.User

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

+ func (*ListUserResponse) ProtoMessage()

+ func (x *ListUserResponse) GetUsers() []*meta.User

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

+ func (x *ListUserResponse) Reset()

+ func (x *ListUserResponse) String() string

+ type MockAuthControllerClient struct

+ func NewMockAuthControllerClient(ctrl *gomock.Controller) *MockAuthControllerClient

+ func (m *MockAuthControllerClient) CreateToken(ctx context.Context, in *CreateTokenRequest, opts ...grpc.CallOption) (*meta.Token, error)

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

+ func (m *MockAuthControllerClient) DeleteToken(ctx context.Context, in *DeleteTokenRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

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

+ func (m *MockAuthControllerClient) EXPECT() *MockAuthControllerClientMockRecorder

+ func (m *MockAuthControllerClient) GetResourceRole(ctx context.Context, in *GetResourceRoleRequest, opts ...grpc.CallOption) (*GetResourceRoleResponse, error)

+ func (m *MockAuthControllerClient) GetToken(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*meta.Token, error)

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

+ func (m *MockAuthControllerClient) GetUserByToken(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)

+ func (m *MockAuthControllerClient) GetUserRole(ctx context.Context, in *GetUserRoleRequest, opts ...grpc.CallOption) (*GetUserRoleResponse, error)

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

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

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

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

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

+ type MockAuthControllerClientMockRecorder struct

+ func (mr *MockAuthControllerClientMockRecorder) CreateToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) CreateUser(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) DeleteToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) DeleteUser(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) GetResourceRole(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) GetToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) GetUser(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) GetUserByToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) GetUserRole(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) GetUserToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) GrantRole(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) ListToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) ListUser(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockAuthControllerClientMockRecorder) RevokeRole(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ type MockAuthControllerServer struct

+ func NewMockAuthControllerServer(ctrl *gomock.Controller) *MockAuthControllerServer

+ func (m *MockAuthControllerServer) CreateToken(arg0 context.Context, arg1 *CreateTokenRequest) (*meta.Token, error)

+ func (m *MockAuthControllerServer) CreateUser(arg0 context.Context, arg1 *CreateUserRequest) (*meta.User, error)

+ func (m *MockAuthControllerServer) DeleteToken(arg0 context.Context, arg1 *DeleteTokenRequest) (*emptypb.Empty, error)

+ func (m *MockAuthControllerServer) DeleteUser(arg0 context.Context, arg1 *wrapperspb.StringValue) (*emptypb.Empty, error)

+ func (m *MockAuthControllerServer) EXPECT() *MockAuthControllerServerMockRecorder

+ func (m *MockAuthControllerServer) GetResourceRole(arg0 context.Context, arg1 *GetResourceRoleRequest) (*GetResourceRoleResponse, error)

+ func (m *MockAuthControllerServer) GetToken(arg0 context.Context, arg1 *wrapperspb.UInt64Value) (*meta.Token, error)

+ func (m *MockAuthControllerServer) GetUser(arg0 context.Context, arg1 *wrapperspb.StringValue) (*meta.User, error)

+ func (m *MockAuthControllerServer) GetUserByToken(arg0 context.Context, arg1 *wrapperspb.StringValue) (*wrapperspb.StringValue, error)

+ func (m *MockAuthControllerServer) GetUserRole(arg0 context.Context, arg1 *GetUserRoleRequest) (*GetUserRoleResponse, error)

+ func (m *MockAuthControllerServer) GetUserToken(arg0 context.Context, arg1 *wrapperspb.StringValue) (*GetTokenResponse, error)

+ func (m *MockAuthControllerServer) GrantRole(arg0 context.Context, arg1 *RoleRequest) (*emptypb.Empty, error)

+ func (m *MockAuthControllerServer) ListToken(arg0 context.Context, arg1 *emptypb.Empty) (*ListTokenResponse, error)

+ func (m *MockAuthControllerServer) ListUser(arg0 context.Context, arg1 *emptypb.Empty) (*ListUserResponse, error)

+ func (m *MockAuthControllerServer) RevokeRole(arg0 context.Context, arg1 *RoleRequest) (*emptypb.Empty, error)

+ type MockAuthControllerServerMockRecorder struct

+ func (mr *MockAuthControllerServerMockRecorder) CreateToken(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) CreateUser(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) DeleteToken(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) DeleteUser(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) GetResourceRole(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) GetToken(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) GetUser(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) GetUserByToken(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) GetUserRole(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) GetUserToken(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) GrantRole(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) ListToken(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) ListUser(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAuthControllerServerMockRecorder) RevokeRole(arg0, arg1 interface{}) *gomock.Call

+ type MockUnsafeAuthControllerServer struct

+ func NewMockUnsafeAuthControllerServer(ctrl *gomock.Controller) *MockUnsafeAuthControllerServer

+ func (m *MockUnsafeAuthControllerServer) EXPECT() *MockUnsafeAuthControllerServerMockRecorder

+ type MockUnsafeAuthControllerServerMockRecorder struct

+ type RoleRequest struct

+ ResourceId uint64

+ ResourceKind string

+ RoleId string

+ RoleName string

+ UserIdentifier string

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

+ func (*RoleRequest) ProtoMessage()

+ func (x *RoleRequest) GetResourceId() uint64

+ func (x *RoleRequest) GetResourceKind() string

+ func (x *RoleRequest) GetRoleId() string

+ func (x *RoleRequest) GetRoleName() string

+ func (x *RoleRequest) GetUserIdentifier() string

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

+ func (x *RoleRequest) Reset()

+ func (x *RoleRequest) String() string

+ type UnimplementedAuthControllerServer struct

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

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

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

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

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

+ func (UnimplementedAuthControllerServer) GetToken(context.Context, *wrapperspb.UInt64Value) (*meta.Token, error)

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

+ func (UnimplementedAuthControllerServer) GetUserByToken(context.Context, *wrapperspb.StringValue) (*wrapperspb.StringValue, error)

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

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

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

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

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

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

+ type UnsafeAuthControllerServer interface

v0.7.1

Mar 13, 2023

Changes in this version

+ const EventbusController_CreateEventbus_FullMethodName

+ const EventbusController_CreateSystemEventbus_FullMethodName

+ const EventbusController_DeleteEventbus_FullMethodName

+ const EventbusController_GetEventbusWithHumanFriendly_FullMethodName

+ const EventbusController_GetEventbus_FullMethodName

+ const EventbusController_ListEventbus_FullMethodName

+ const EventbusController_UpdateEventbus_FullMethodName

+ const EventlogController_GetAppendableSegment_FullMethodName

+ const EventlogController_ListSegment_FullMethodName

+ const NamespaceController_CreateNamespace_FullMethodName

+ const NamespaceController_DeleteNamespace_FullMethodName

+ const NamespaceController_GetNamespaceWithHumanFriendly_FullMethodName

+ const NamespaceController_GetNamespace_FullMethodName

+ const NamespaceController_ListNamespace_FullMethodName

+ const PingServer_Ping_FullMethodName

+ const SegmentController_QuerySegmentRouteInfo_FullMethodName

+ const SegmentController_RegisterSegmentServer_FullMethodName

+ const SegmentController_ReportSegmentBlockIsFull_FullMethodName

+ const SegmentController_ReportSegmentLeader_FullMethodName

+ const SegmentController_SegmentHeartbeat_FullMethodName

+ const SegmentController_UnregisterSegmentServer_FullMethodName

+ const SnowflakeController_GetClusterStartTime_FullMethodName

+ const SnowflakeController_RegisterNode_FullMethodName

+ const SnowflakeController_UnregisterNode_FullMethodName

+ const TriggerController_CommitOffset_FullMethodName

+ const TriggerController_CreateSubscription_FullMethodName

+ const TriggerController_DeleteSubscription_FullMethodName

+ const TriggerController_DisableSubscription_FullMethodName

+ const TriggerController_GetDeadLetterEventOffset_FullMethodName

+ const TriggerController_GetSubscription_FullMethodName

+ const TriggerController_ListSubscription_FullMethodName

+ const TriggerController_RegisterTriggerWorker_FullMethodName

+ const TriggerController_ResetOffsetToTimestamp_FullMethodName

+ const TriggerController_ResumeSubscription_FullMethodName

+ const TriggerController_SetDeadLetterEventOffset_FullMethodName

+ const TriggerController_TriggerWorkerHeartbeat_FullMethodName

+ const TriggerController_UnregisterTriggerWorker_FullMethodName

+ const TriggerController_UpdateSubscription_FullMethodName

+ var EventbusController_ServiceDesc = grpc.ServiceDesc

+ var EventlogController_ServiceDesc = grpc.ServiceDesc

+ var File_controller_proto protoreflect.FileDescriptor

+ var NamespaceController_ServiceDesc = grpc.ServiceDesc

+ var PingServer_ServiceDesc = grpc.ServiceDesc

+ var SegmentController_ServiceDesc = grpc.ServiceDesc

+ var SnowflakeController_ServiceDesc = grpc.ServiceDesc

+ var TriggerController_ServiceDesc = grpc.ServiceDesc

+ func RegisterEventbusControllerServer(s grpc.ServiceRegistrar, srv EventbusControllerServer)

+ func RegisterEventlogControllerServer(s grpc.ServiceRegistrar, srv EventlogControllerServer)

+ func RegisterNamespaceControllerServer(s grpc.ServiceRegistrar, srv NamespaceControllerServer)

+ func RegisterPingServerServer(s grpc.ServiceRegistrar, srv PingServerServer)

+ func RegisterSegmentControllerServer(s grpc.ServiceRegistrar, srv SegmentControllerServer)

+ func RegisterSnowflakeControllerServer(s grpc.ServiceRegistrar, srv SnowflakeControllerServer)

+ func RegisterTriggerControllerServer(s grpc.ServiceRegistrar, srv TriggerControllerServer)

+ type CommitOffsetRequest struct

+ ForceCommit bool

+ SubscriptionInfo []*meta.SubscriptionInfo

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

+ func (*CommitOffsetRequest) ProtoMessage()

+ func (x *CommitOffsetRequest) GetForceCommit() bool

+ func (x *CommitOffsetRequest) GetSubscriptionInfo() []*meta.SubscriptionInfo

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

+ func (x *CommitOffsetRequest) Reset()

+ func (x *CommitOffsetRequest) String() string

+ type CommitOffsetResponse struct

+ FailSubscriptionId []uint64

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

+ func (*CommitOffsetResponse) ProtoMessage()

+ func (x *CommitOffsetResponse) GetFailSubscriptionId() []uint64

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

+ func (x *CommitOffsetResponse) Reset()

+ func (x *CommitOffsetResponse) String() string

+ type CreateEventbusRequest struct

+ Description string

+ LogNumber int32

+ Name string

+ NamespaceId uint64

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

+ func (*CreateEventbusRequest) ProtoMessage()

+ func (x *CreateEventbusRequest) GetDescription() string

+ func (x *CreateEventbusRequest) GetLogNumber() int32

+ func (x *CreateEventbusRequest) GetName() string

+ func (x *CreateEventbusRequest) GetNamespaceId() uint64

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

+ func (x *CreateEventbusRequest) Reset()

+ func (x *CreateEventbusRequest) String() string

+ type CreateNamespaceRequest struct

+ Description string

+ Name string

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

+ func (*CreateNamespaceRequest) ProtoMessage()

+ func (x *CreateNamespaceRequest) GetDescription() string

+ func (x *CreateNamespaceRequest) GetName() string

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

+ func (x *CreateNamespaceRequest) Reset()

+ func (x *CreateNamespaceRequest) String() string

+ type CreateSubscriptionRequest struct

+ Subscription *SubscriptionRequest

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

+ func (*CreateSubscriptionRequest) ProtoMessage()

+ func (x *CreateSubscriptionRequest) GetSubscription() *SubscriptionRequest

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

+ func (x *CreateSubscriptionRequest) Reset()

+ func (x *CreateSubscriptionRequest) String() string

+ type DeleteNamespaceRequest struct

+ Id uint64

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

+ func (*DeleteNamespaceRequest) ProtoMessage()

+ func (x *DeleteNamespaceRequest) GetId() uint64

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

+ func (x *DeleteNamespaceRequest) Reset()

+ func (x *DeleteNamespaceRequest) String() string

+ type DeleteSubscriptionRequest struct

+ Id uint64

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

+ func (*DeleteSubscriptionRequest) ProtoMessage()

+ func (x *DeleteSubscriptionRequest) GetId() uint64

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

+ func (x *DeleteSubscriptionRequest) Reset()

+ func (x *DeleteSubscriptionRequest) String() string

+ type DisableSubscriptionRequest struct

+ Id uint64

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

+ func (*DisableSubscriptionRequest) ProtoMessage()

+ func (x *DisableSubscriptionRequest) GetId() uint64

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

+ func (x *DisableSubscriptionRequest) Reset()

+ func (x *DisableSubscriptionRequest) String() string

+ type EventbusControllerClient interface

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

+ CreateSystemEventbus func(ctx context.Context, in *CreateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)

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

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

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

+ ListEventbus func(ctx context.Context, in *ListEventbusRequest, opts ...grpc.CallOption) (*ListEventbusResponse, error)

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

+ func NewEventbusControllerClient(cc grpc.ClientConnInterface) EventbusControllerClient

+ type EventbusControllerServer interface

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

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

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

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

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

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

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

+ type EventlogControllerClient interface

+ GetAppendableSegment func(ctx context.Context, in *GetAppendableSegmentRequest, opts ...grpc.CallOption) (*GetAppendableSegmentResponse, error)

+ ListSegment func(ctx context.Context, in *ListSegmentRequest, opts ...grpc.CallOption) (*ListSegmentResponse, error)

+ func NewEventlogControllerClient(cc grpc.ClientConnInterface) EventlogControllerClient

+ type EventlogControllerServer interface

+ GetAppendableSegment func(context.Context, *GetAppendableSegmentRequest) (*GetAppendableSegmentResponse, error)

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

+ type GetAppendableSegmentRequest struct

+ EventbusId uint64

+ EventlogId uint64

+ Limited int32

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

+ func (*GetAppendableSegmentRequest) ProtoMessage()

+ func (x *GetAppendableSegmentRequest) GetEventbusId() uint64

+ func (x *GetAppendableSegmentRequest) GetEventlogId() uint64

+ func (x *GetAppendableSegmentRequest) GetLimited() int32

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

+ func (x *GetAppendableSegmentRequest) Reset()

+ func (x *GetAppendableSegmentRequest) String() string

+ type GetAppendableSegmentResponse struct

+ Segments []*meta.Segment

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

+ func (*GetAppendableSegmentResponse) ProtoMessage()

+ func (x *GetAppendableSegmentResponse) GetSegments() []*meta.Segment

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

+ func (x *GetAppendableSegmentResponse) Reset()

+ func (x *GetAppendableSegmentResponse) String() string

+ type GetDeadLetterEventOffsetRequest struct

+ SubscriptionId uint64

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

+ func (*GetDeadLetterEventOffsetRequest) ProtoMessage()

+ func (x *GetDeadLetterEventOffsetRequest) GetSubscriptionId() uint64

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

+ func (x *GetDeadLetterEventOffsetRequest) Reset()

+ func (x *GetDeadLetterEventOffsetRequest) String() string

+ type GetDeadLetterEventOffsetResponse struct

+ Offset uint64

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

+ func (*GetDeadLetterEventOffsetResponse) ProtoMessage()

+ func (x *GetDeadLetterEventOffsetResponse) GetOffset() uint64

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

+ func (x *GetDeadLetterEventOffsetResponse) Reset()

+ func (x *GetDeadLetterEventOffsetResponse) String() string

+ type GetEventbusWithHumanFriendlyRequest struct

+ EventbusName string

+ NamespaceId uint64

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

+ func (*GetEventbusWithHumanFriendlyRequest) ProtoMessage()

+ func (x *GetEventbusWithHumanFriendlyRequest) GetEventbusName() string

+ func (x *GetEventbusWithHumanFriendlyRequest) GetNamespaceId() uint64

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

+ func (x *GetEventbusWithHumanFriendlyRequest) Reset()

+ func (x *GetEventbusWithHumanFriendlyRequest) String() string

+ type GetNamespaceRequest struct

+ Id uint64

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

+ func (*GetNamespaceRequest) ProtoMessage()

+ func (x *GetNamespaceRequest) GetId() uint64

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

+ func (x *GetNamespaceRequest) Reset()

+ func (x *GetNamespaceRequest) String() string

+ type GetSubscriptionRequest struct

+ Id uint64

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

+ func (*GetSubscriptionRequest) ProtoMessage()

+ func (x *GetSubscriptionRequest) GetId() uint64

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

+ func (x *GetSubscriptionRequest) Reset()

+ func (x *GetSubscriptionRequest) String() string

+ type ListEventbusRequest struct

+ NamespaceId uint64

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

+ func (*ListEventbusRequest) ProtoMessage()

+ func (x *ListEventbusRequest) GetNamespaceId() uint64

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

+ func (x *ListEventbusRequest) Reset()

+ func (x *ListEventbusRequest) String() string

+ type ListEventbusResponse struct

+ Eventbus []*meta.Eventbus

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

+ func (*ListEventbusResponse) ProtoMessage()

+ func (x *ListEventbusResponse) GetEventbus() []*meta.Eventbus

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

+ func (x *ListEventbusResponse) Reset()

+ func (x *ListEventbusResponse) String() string

+ type ListNamespaceResponse struct

+ Namespace []*meta.Namespace

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

+ func (*ListNamespaceResponse) ProtoMessage()

+ func (x *ListNamespaceResponse) GetNamespace() []*meta.Namespace

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

+ func (x *ListNamespaceResponse) Reset()

+ func (x *ListNamespaceResponse) String() string

+ type ListSegmentRequest struct

+ EndOffset int64

+ EventbusId uint64

+ EventlogId uint64

+ Limited int32

+ StartOffset int64

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

+ func (*ListSegmentRequest) ProtoMessage()

+ func (x *ListSegmentRequest) GetEndOffset() int64

+ func (x *ListSegmentRequest) GetEventbusId() uint64

+ func (x *ListSegmentRequest) GetEventlogId() uint64

+ func (x *ListSegmentRequest) GetLimited() int32

+ func (x *ListSegmentRequest) GetStartOffset() int64

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

+ func (x *ListSegmentRequest) Reset()

+ func (x *ListSegmentRequest) String() string

+ type ListSegmentResponse struct

+ Segments []*meta.Segment

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

+ func (*ListSegmentResponse) ProtoMessage()

+ func (x *ListSegmentResponse) GetSegments() []*meta.Segment

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

+ func (x *ListSegmentResponse) Reset()

+ func (x *ListSegmentResponse) String() string

+ type ListSubscriptionRequest struct

+ EventbusId uint64

+ Name string

+ NamespaceId uint64

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

+ func (*ListSubscriptionRequest) ProtoMessage()

+ func (x *ListSubscriptionRequest) GetEventbusId() uint64

+ func (x *ListSubscriptionRequest) GetName() string

+ func (x *ListSubscriptionRequest) GetNamespaceId() uint64

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

+ func (x *ListSubscriptionRequest) Reset()

+ func (x *ListSubscriptionRequest) String() string

+ type ListSubscriptionResponse struct

+ Subscription []*meta.Subscription

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

+ func (*ListSubscriptionResponse) ProtoMessage()

+ func (x *ListSubscriptionResponse) GetSubscription() []*meta.Subscription

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

+ func (x *ListSubscriptionResponse) Reset()

+ func (x *ListSubscriptionResponse) String() string

+ type MockEventbusControllerClient struct

+ func NewMockEventbusControllerClient(ctrl *gomock.Controller) *MockEventbusControllerClient

+ func (m *MockEventbusControllerClient) CreateEventbus(ctx context.Context, in *CreateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)

+ func (m *MockEventbusControllerClient) CreateSystemEventbus(ctx context.Context, in *CreateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)

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

+ func (m *MockEventbusControllerClient) EXPECT() *MockEventbusControllerClientMockRecorder

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

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

+ func (m *MockEventbusControllerClient) ListEventbus(ctx context.Context, in *ListEventbusRequest, opts ...grpc.CallOption) (*ListEventbusResponse, error)

+ func (m *MockEventbusControllerClient) UpdateEventbus(ctx context.Context, in *UpdateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)

+ type MockEventbusControllerClientMockRecorder struct

+ func (mr *MockEventbusControllerClientMockRecorder) CreateEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockEventbusControllerClientMockRecorder) CreateSystemEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockEventbusControllerClientMockRecorder) DeleteEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockEventbusControllerClientMockRecorder) GetEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockEventbusControllerClientMockRecorder) GetEventbusWithHumanFriendly(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockEventbusControllerClientMockRecorder) ListEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockEventbusControllerClientMockRecorder) UpdateEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ type MockEventbusControllerServer struct

+ func NewMockEventbusControllerServer(ctrl *gomock.Controller) *MockEventbusControllerServer

+ func (m *MockEventbusControllerServer) CreateEventbus(arg0 context.Context, arg1 *CreateEventbusRequest) (*meta.Eventbus, error)

+ func (m *MockEventbusControllerServer) CreateSystemEventbus(arg0 context.Context, arg1 *CreateEventbusRequest) (*meta.Eventbus, error)

+ func (m *MockEventbusControllerServer) DeleteEventbus(arg0 context.Context, arg1 *wrapperspb.UInt64Value) (*emptypb.Empty, error)

+ func (m *MockEventbusControllerServer) EXPECT() *MockEventbusControllerServerMockRecorder

+ func (m *MockEventbusControllerServer) GetEventbus(arg0 context.Context, arg1 *wrapperspb.UInt64Value) (*meta.Eventbus, error)

+ func (m *MockEventbusControllerServer) GetEventbusWithHumanFriendly(arg0 context.Context, arg1 *GetEventbusWithHumanFriendlyRequest) (*meta.Eventbus, error)

+ func (m *MockEventbusControllerServer) ListEventbus(arg0 context.Context, arg1 *ListEventbusRequest) (*ListEventbusResponse, error)

+ func (m *MockEventbusControllerServer) UpdateEventbus(arg0 context.Context, arg1 *UpdateEventbusRequest) (*meta.Eventbus, error)

+ type MockEventbusControllerServerMockRecorder struct

+ func (mr *MockEventbusControllerServerMockRecorder) CreateEventbus(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventbusControllerServerMockRecorder) CreateSystemEventbus(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventbusControllerServerMockRecorder) DeleteEventbus(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventbusControllerServerMockRecorder) GetEventbus(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventbusControllerServerMockRecorder) GetEventbusWithHumanFriendly(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventbusControllerServerMockRecorder) ListEventbus(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventbusControllerServerMockRecorder) UpdateEventbus(arg0, arg1 interface{}) *gomock.Call

+ type MockEventlogControllerClient struct

+ func NewMockEventlogControllerClient(ctrl *gomock.Controller) *MockEventlogControllerClient

+ func (m *MockEventlogControllerClient) EXPECT() *MockEventlogControllerClientMockRecorder

+ func (m *MockEventlogControllerClient) GetAppendableSegment(ctx context.Context, in *GetAppendableSegmentRequest, opts ...grpc.CallOption) (*GetAppendableSegmentResponse, error)

+ func (m *MockEventlogControllerClient) ListSegment(ctx context.Context, in *ListSegmentRequest, opts ...grpc.CallOption) (*ListSegmentResponse, error)

+ type MockEventlogControllerClientMockRecorder struct

+ func (mr *MockEventlogControllerClientMockRecorder) GetAppendableSegment(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockEventlogControllerClientMockRecorder) ListSegment(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ type MockEventlogControllerServer struct

+ func NewMockEventlogControllerServer(ctrl *gomock.Controller) *MockEventlogControllerServer

+ func (m *MockEventlogControllerServer) EXPECT() *MockEventlogControllerServerMockRecorder

+ func (m *MockEventlogControllerServer) GetAppendableSegment(arg0 context.Context, arg1 *GetAppendableSegmentRequest) (*GetAppendableSegmentResponse, error)

+ func (m *MockEventlogControllerServer) ListSegment(arg0 context.Context, arg1 *ListSegmentRequest) (*ListSegmentResponse, error)

+ type MockEventlogControllerServerMockRecorder struct

+ func (mr *MockEventlogControllerServerMockRecorder) GetAppendableSegment(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventlogControllerServerMockRecorder) ListSegment(arg0, arg1 interface{}) *gomock.Call

+ type MockNamespaceControllerClient struct

+ func NewMockNamespaceControllerClient(ctrl *gomock.Controller) *MockNamespaceControllerClient

+ func (m *MockNamespaceControllerClient) CreateNamespace(ctx context.Context, in *CreateNamespaceRequest, opts ...grpc.CallOption) (*meta.Namespace, error)

+ func (m *MockNamespaceControllerClient) DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func (m *MockNamespaceControllerClient) EXPECT() *MockNamespaceControllerClientMockRecorder

+ func (m *MockNamespaceControllerClient) GetNamespace(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*meta.Namespace, error)

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

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

+ type MockNamespaceControllerClientMockRecorder struct

+ func (mr *MockNamespaceControllerClientMockRecorder) CreateNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockNamespaceControllerClientMockRecorder) DeleteNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockNamespaceControllerClientMockRecorder) GetNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockNamespaceControllerClientMockRecorder) GetNamespaceWithHumanFriendly(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockNamespaceControllerClientMockRecorder) ListNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ type MockNamespaceControllerServer struct

+ func NewMockNamespaceControllerServer(ctrl *gomock.Controller) *MockNamespaceControllerServer

+ func (m *MockNamespaceControllerServer) CreateNamespace(arg0 context.Context, arg1 *CreateNamespaceRequest) (*meta.Namespace, error)

+ func (m *MockNamespaceControllerServer) DeleteNamespace(arg0 context.Context, arg1 *DeleteNamespaceRequest) (*emptypb.Empty, error)

+ func (m *MockNamespaceControllerServer) EXPECT() *MockNamespaceControllerServerMockRecorder

+ func (m *MockNamespaceControllerServer) GetNamespace(arg0 context.Context, arg1 *GetNamespaceRequest) (*meta.Namespace, error)

+ func (m *MockNamespaceControllerServer) GetNamespaceWithHumanFriendly(arg0 context.Context, arg1 *wrapperspb.StringValue) (*meta.Namespace, error)

+ func (m *MockNamespaceControllerServer) ListNamespace(arg0 context.Context, arg1 *emptypb.Empty) (*ListNamespaceResponse, error)

+ type MockNamespaceControllerServerMockRecorder struct

+ func (mr *MockNamespaceControllerServerMockRecorder) CreateNamespace(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockNamespaceControllerServerMockRecorder) DeleteNamespace(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockNamespaceControllerServerMockRecorder) GetNamespace(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockNamespaceControllerServerMockRecorder) GetNamespaceWithHumanFriendly(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockNamespaceControllerServerMockRecorder) ListNamespace(arg0, arg1 interface{}) *gomock.Call

+ type MockPingServerClient struct

+ func NewMockPingServerClient(ctrl *gomock.Controller) *MockPingServerClient

+ func (m *MockPingServerClient) EXPECT() *MockPingServerClientMockRecorder

+ func (m *MockPingServerClient) Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PingResponse, error)

+ type MockPingServerClientMockRecorder struct

+ func (mr *MockPingServerClientMockRecorder) Ping(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ type MockPingServerServer struct

+ func NewMockPingServerServer(ctrl *gomock.Controller) *MockPingServerServer

+ func (m *MockPingServerServer) EXPECT() *MockPingServerServerMockRecorder

+ func (m *MockPingServerServer) Ping(arg0 context.Context, arg1 *emptypb.Empty) (*PingResponse, error)

+ type MockPingServerServerMockRecorder struct

+ func (mr *MockPingServerServerMockRecorder) Ping(arg0, arg1 interface{}) *gomock.Call

+ type MockSegmentControllerClient struct

+ func NewMockSegmentControllerClient(ctrl *gomock.Controller) *MockSegmentControllerClient

+ func (m *MockSegmentControllerClient) EXPECT() *MockSegmentControllerClientMockRecorder

+ func (m *MockSegmentControllerClient) QuerySegmentRouteInfo(ctx context.Context, in *QuerySegmentRouteInfoRequest, opts ...grpc.CallOption) (*QuerySegmentRouteInfoResponse, error)

+ func (m *MockSegmentControllerClient) RegisterSegmentServer(ctx context.Context, in *RegisterSegmentServerRequest, opts ...grpc.CallOption) (*RegisterSegmentServerResponse, error)

+ func (m *MockSegmentControllerClient) ReportSegmentBlockIsFull(ctx context.Context, in *SegmentHeartbeatRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func (m *MockSegmentControllerClient) ReportSegmentLeader(ctx context.Context, in *ReportSegmentLeaderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func (m *MockSegmentControllerClient) SegmentHeartbeat(ctx context.Context, opts ...grpc.CallOption) (SegmentController_SegmentHeartbeatClient, error)

+ func (m *MockSegmentControllerClient) UnregisterSegmentServer(ctx context.Context, in *UnregisterSegmentServerRequest, ...) (*UnregisterSegmentServerResponse, error)

+ type MockSegmentControllerClientMockRecorder struct

+ func (mr *MockSegmentControllerClientMockRecorder) QuerySegmentRouteInfo(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockSegmentControllerClientMockRecorder) RegisterSegmentServer(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockSegmentControllerClientMockRecorder) ReportSegmentBlockIsFull(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockSegmentControllerClientMockRecorder) ReportSegmentLeader(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockSegmentControllerClientMockRecorder) SegmentHeartbeat(ctx interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockSegmentControllerClientMockRecorder) UnregisterSegmentServer(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ type MockSegmentControllerServer struct

+ func NewMockSegmentControllerServer(ctrl *gomock.Controller) *MockSegmentControllerServer

+ func (m *MockSegmentControllerServer) EXPECT() *MockSegmentControllerServerMockRecorder

+ func (m *MockSegmentControllerServer) QuerySegmentRouteInfo(arg0 context.Context, arg1 *QuerySegmentRouteInfoRequest) (*QuerySegmentRouteInfoResponse, error)

+ func (m *MockSegmentControllerServer) RegisterSegmentServer(arg0 context.Context, arg1 *RegisterSegmentServerRequest) (*RegisterSegmentServerResponse, error)

+ func (m *MockSegmentControllerServer) ReportSegmentBlockIsFull(arg0 context.Context, arg1 *SegmentHeartbeatRequest) (*emptypb.Empty, error)

+ func (m *MockSegmentControllerServer) ReportSegmentLeader(arg0 context.Context, arg1 *ReportSegmentLeaderRequest) (*emptypb.Empty, error)

+ func (m *MockSegmentControllerServer) SegmentHeartbeat(arg0 SegmentController_SegmentHeartbeatServer) error

+ func (m *MockSegmentControllerServer) UnregisterSegmentServer(arg0 context.Context, arg1 *UnregisterSegmentServerRequest) (*UnregisterSegmentServerResponse, error)

+ type MockSegmentControllerServerMockRecorder struct

+ func (mr *MockSegmentControllerServerMockRecorder) QuerySegmentRouteInfo(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSegmentControllerServerMockRecorder) RegisterSegmentServer(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSegmentControllerServerMockRecorder) ReportSegmentBlockIsFull(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSegmentControllerServerMockRecorder) ReportSegmentLeader(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSegmentControllerServerMockRecorder) SegmentHeartbeat(arg0 interface{}) *gomock.Call

+ func (mr *MockSegmentControllerServerMockRecorder) UnregisterSegmentServer(arg0, arg1 interface{}) *gomock.Call

+ type MockSegmentController_SegmentHeartbeatClient struct

+ func NewMockSegmentController_SegmentHeartbeatClient(ctrl *gomock.Controller) *MockSegmentController_SegmentHeartbeatClient

+ func (m *MockSegmentController_SegmentHeartbeatClient) CloseAndRecv() (*SegmentHeartbeatResponse, error)

+ func (m *MockSegmentController_SegmentHeartbeatClient) CloseSend() error

+ func (m *MockSegmentController_SegmentHeartbeatClient) Context() context.Context

+ func (m *MockSegmentController_SegmentHeartbeatClient) EXPECT() *MockSegmentController_SegmentHeartbeatClientMockRecorder

+ func (m *MockSegmentController_SegmentHeartbeatClient) Header() (metadata.MD, error)

+ func (m *MockSegmentController_SegmentHeartbeatClient) Send(arg0 *SegmentHeartbeatRequest) error

+ func (m *MockSegmentController_SegmentHeartbeatClient) Trailer() metadata.MD

+ func (m_2 *MockSegmentController_SegmentHeartbeatClient) RecvMsg(m interface{}) error

+ func (m_2 *MockSegmentController_SegmentHeartbeatClient) SendMsg(m interface{}) error

+ type MockSegmentController_SegmentHeartbeatClientMockRecorder struct

+ func (mr *MockSegmentController_SegmentHeartbeatClientMockRecorder) CloseAndRecv() *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatClientMockRecorder) CloseSend() *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatClientMockRecorder) Context() *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatClientMockRecorder) Header() *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatClientMockRecorder) Send(arg0 interface{}) *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatClientMockRecorder) SendMsg(m interface{}) *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatClientMockRecorder) Trailer() *gomock.Call

+ type MockSegmentController_SegmentHeartbeatServer struct

+ func NewMockSegmentController_SegmentHeartbeatServer(ctrl *gomock.Controller) *MockSegmentController_SegmentHeartbeatServer

+ func (m *MockSegmentController_SegmentHeartbeatServer) Context() context.Context

+ func (m *MockSegmentController_SegmentHeartbeatServer) EXPECT() *MockSegmentController_SegmentHeartbeatServerMockRecorder

+ func (m *MockSegmentController_SegmentHeartbeatServer) Recv() (*SegmentHeartbeatRequest, error)

+ func (m *MockSegmentController_SegmentHeartbeatServer) SendAndClose(arg0 *SegmentHeartbeatResponse) error

+ func (m *MockSegmentController_SegmentHeartbeatServer) SendHeader(arg0 metadata.MD) error

+ func (m *MockSegmentController_SegmentHeartbeatServer) SetHeader(arg0 metadata.MD) error

+ func (m *MockSegmentController_SegmentHeartbeatServer) SetTrailer(arg0 metadata.MD)

+ func (m_2 *MockSegmentController_SegmentHeartbeatServer) RecvMsg(m interface{}) error

+ func (m_2 *MockSegmentController_SegmentHeartbeatServer) SendMsg(m interface{}) error

+ type MockSegmentController_SegmentHeartbeatServerMockRecorder struct

+ func (mr *MockSegmentController_SegmentHeartbeatServerMockRecorder) Context() *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatServerMockRecorder) Recv() *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatServerMockRecorder) SendAndClose(arg0 interface{}) *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatServerMockRecorder) SendMsg(m interface{}) *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

+ func (mr *MockSegmentController_SegmentHeartbeatServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

+ type MockSnowflakeControllerClient struct

+ func NewMockSnowflakeControllerClient(ctrl *gomock.Controller) *MockSnowflakeControllerClient

+ func (m *MockSnowflakeControllerClient) EXPECT() *MockSnowflakeControllerClientMockRecorder

+ func (m *MockSnowflakeControllerClient) GetClusterStartTime(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*timestamppb.Timestamp, error)

+ func (m *MockSnowflakeControllerClient) RegisterNode(ctx context.Context, in *wrapperspb.UInt32Value, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func (m *MockSnowflakeControllerClient) UnregisterNode(ctx context.Context, in *wrapperspb.UInt32Value, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ type MockSnowflakeControllerClientMockRecorder struct

+ func (mr *MockSnowflakeControllerClientMockRecorder) GetClusterStartTime(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockSnowflakeControllerClientMockRecorder) RegisterNode(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockSnowflakeControllerClientMockRecorder) UnregisterNode(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ type MockSnowflakeControllerServer struct

+ func NewMockSnowflakeControllerServer(ctrl *gomock.Controller) *MockSnowflakeControllerServer

+ func (m *MockSnowflakeControllerServer) EXPECT() *MockSnowflakeControllerServerMockRecorder

+ func (m *MockSnowflakeControllerServer) GetClusterStartTime(arg0 context.Context, arg1 *emptypb.Empty) (*timestamppb.Timestamp, error)

+ func (m *MockSnowflakeControllerServer) RegisterNode(arg0 context.Context, arg1 *wrapperspb.UInt32Value) (*emptypb.Empty, error)

+ func (m *MockSnowflakeControllerServer) UnregisterNode(arg0 context.Context, arg1 *wrapperspb.UInt32Value) (*emptypb.Empty, error)

+ type MockSnowflakeControllerServerMockRecorder struct

+ func (mr *MockSnowflakeControllerServerMockRecorder) GetClusterStartTime(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSnowflakeControllerServerMockRecorder) RegisterNode(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSnowflakeControllerServerMockRecorder) UnregisterNode(arg0, arg1 interface{}) *gomock.Call

+ type MockTriggerControllerClient struct

+ func NewMockTriggerControllerClient(ctrl *gomock.Controller) *MockTriggerControllerClient

+ func (m *MockTriggerControllerClient) CommitOffset(ctx context.Context, in *CommitOffsetRequest, opts ...grpc.CallOption) (*CommitOffsetResponse, error)

+ func (m *MockTriggerControllerClient) CreateSubscription(ctx context.Context, in *CreateSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)

+ func (m *MockTriggerControllerClient) DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func (m *MockTriggerControllerClient) DisableSubscription(ctx context.Context, in *DisableSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func (m *MockTriggerControllerClient) EXPECT() *MockTriggerControllerClientMockRecorder

+ func (m *MockTriggerControllerClient) GetDeadLetterEventOffset(ctx context.Context, in *GetDeadLetterEventOffsetRequest, ...) (*GetDeadLetterEventOffsetResponse, error)

+ func (m *MockTriggerControllerClient) GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)

+ func (m *MockTriggerControllerClient) ListSubscription(ctx context.Context, in *ListSubscriptionRequest, opts ...grpc.CallOption) (*ListSubscriptionResponse, error)

+ func (m *MockTriggerControllerClient) RegisterTriggerWorker(ctx context.Context, in *RegisterTriggerWorkerRequest, opts ...grpc.CallOption) (*RegisterTriggerWorkerResponse, error)

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

+ func (m *MockTriggerControllerClient) ResumeSubscription(ctx context.Context, in *ResumeSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

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

+ func (m *MockTriggerControllerClient) TriggerWorkerHeartbeat(ctx context.Context, opts ...grpc.CallOption) (TriggerController_TriggerWorkerHeartbeatClient, error)

+ func (m *MockTriggerControllerClient) UnregisterTriggerWorker(ctx context.Context, in *UnregisterTriggerWorkerRequest, ...) (*UnregisterTriggerWorkerResponse, error)

+ func (m *MockTriggerControllerClient) UpdateSubscription(ctx context.Context, in *UpdateSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)

+ type MockTriggerControllerClientMockRecorder struct

+ func (mr *MockTriggerControllerClientMockRecorder) CommitOffset(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) CreateSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) DeleteSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) DisableSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) GetDeadLetterEventOffset(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) GetSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) ListSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) RegisterTriggerWorker(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) ResetOffsetToTimestamp(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) ResumeSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) SetDeadLetterEventOffset(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) TriggerWorkerHeartbeat(ctx interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) UnregisterTriggerWorker(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockTriggerControllerClientMockRecorder) UpdateSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

+ type MockTriggerControllerServer struct

+ func NewMockTriggerControllerServer(ctrl *gomock.Controller) *MockTriggerControllerServer

+ func (m *MockTriggerControllerServer) CommitOffset(arg0 context.Context, arg1 *CommitOffsetRequest) (*CommitOffsetResponse, error)

+ func (m *MockTriggerControllerServer) CreateSubscription(arg0 context.Context, arg1 *CreateSubscriptionRequest) (*meta.Subscription, error)

+ func (m *MockTriggerControllerServer) DeleteSubscription(arg0 context.Context, arg1 *DeleteSubscriptionRequest) (*emptypb.Empty, error)

+ func (m *MockTriggerControllerServer) DisableSubscription(arg0 context.Context, arg1 *DisableSubscriptionRequest) (*emptypb.Empty, error)

+ func (m *MockTriggerControllerServer) EXPECT() *MockTriggerControllerServerMockRecorder

+ func (m *MockTriggerControllerServer) GetDeadLetterEventOffset(arg0 context.Context, arg1 *GetDeadLetterEventOffsetRequest) (*GetDeadLetterEventOffsetResponse, error)

+ func (m *MockTriggerControllerServer) GetSubscription(arg0 context.Context, arg1 *GetSubscriptionRequest) (*meta.Subscription, error)

+ func (m *MockTriggerControllerServer) ListSubscription(arg0 context.Context, arg1 *ListSubscriptionRequest) (*ListSubscriptionResponse, error)

+ func (m *MockTriggerControllerServer) RegisterTriggerWorker(arg0 context.Context, arg1 *RegisterTriggerWorkerRequest) (*RegisterTriggerWorkerResponse, error)

+ func (m *MockTriggerControllerServer) ResetOffsetToTimestamp(arg0 context.Context, arg1 *ResetOffsetToTimestampRequest) (*ResetOffsetToTimestampResponse, error)

+ func (m *MockTriggerControllerServer) ResumeSubscription(arg0 context.Context, arg1 *ResumeSubscriptionRequest) (*emptypb.Empty, error)

+ func (m *MockTriggerControllerServer) SetDeadLetterEventOffset(arg0 context.Context, arg1 *SetDeadLetterEventOffsetRequest) (*emptypb.Empty, error)

+ func (m *MockTriggerControllerServer) TriggerWorkerHeartbeat(arg0 TriggerController_TriggerWorkerHeartbeatServer) error

+ func (m *MockTriggerControllerServer) UnregisterTriggerWorker(arg0 context.Context, arg1 *UnregisterTriggerWorkerRequest) (*UnregisterTriggerWorkerResponse, error)

+ func (m *MockTriggerControllerServer) UpdateSubscription(arg0 context.Context, arg1 *UpdateSubscriptionRequest) (*meta.Subscription, error)

+ type MockTriggerControllerServerMockRecorder struct

+ func (mr *MockTriggerControllerServerMockRecorder) CommitOffset(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) CreateSubscription(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) DeleteSubscription(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) DisableSubscription(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) GetDeadLetterEventOffset(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) GetSubscription(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) ListSubscription(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) RegisterTriggerWorker(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) ResetOffsetToTimestamp(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) ResumeSubscription(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) SetDeadLetterEventOffset(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) TriggerWorkerHeartbeat(arg0 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) UnregisterTriggerWorker(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTriggerControllerServerMockRecorder) UpdateSubscription(arg0, arg1 interface{}) *gomock.Call

+ type MockTriggerController_TriggerWorkerHeartbeatClient struct

+ func NewMockTriggerController_TriggerWorkerHeartbeatClient(ctrl *gomock.Controller) *MockTriggerController_TriggerWorkerHeartbeatClient

+ func (m *MockTriggerController_TriggerWorkerHeartbeatClient) CloseAndRecv() (*TriggerWorkerHeartbeatResponse, error)

+ func (m *MockTriggerController_TriggerWorkerHeartbeatClient) CloseSend() error

+ func (m *MockTriggerController_TriggerWorkerHeartbeatClient) Context() context.Context

+ func (m *MockTriggerController_TriggerWorkerHeartbeatClient) EXPECT() *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder

+ func (m *MockTriggerController_TriggerWorkerHeartbeatClient) Header() (metadata.MD, error)

+ func (m *MockTriggerController_TriggerWorkerHeartbeatClient) Send(arg0 *TriggerWorkerHeartbeatRequest) error

+ func (m *MockTriggerController_TriggerWorkerHeartbeatClient) Trailer() metadata.MD

+ func (m_2 *MockTriggerController_TriggerWorkerHeartbeatClient) RecvMsg(m interface{}) error

+ func (m_2 *MockTriggerController_TriggerWorkerHeartbeatClient) SendMsg(m interface{}) error

+ type MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder struct

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) CloseAndRecv() *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) CloseSend() *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Context() *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Header() *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Send(arg0 interface{}) *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) SendMsg(m interface{}) *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Trailer() *gomock.Call

+ type MockTriggerController_TriggerWorkerHeartbeatServer struct

+ func NewMockTriggerController_TriggerWorkerHeartbeatServer(ctrl *gomock.Controller) *MockTriggerController_TriggerWorkerHeartbeatServer

+ func (m *MockTriggerController_TriggerWorkerHeartbeatServer) Context() context.Context

+ func (m *MockTriggerController_TriggerWorkerHeartbeatServer) EXPECT() *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder

+ func (m *MockTriggerController_TriggerWorkerHeartbeatServer) Recv() (*TriggerWorkerHeartbeatRequest, error)

+ func (m *MockTriggerController_TriggerWorkerHeartbeatServer) SendAndClose(arg0 *TriggerWorkerHeartbeatResponse) error

+ func (m *MockTriggerController_TriggerWorkerHeartbeatServer) SendHeader(arg0 metadata.MD) error

+ func (m *MockTriggerController_TriggerWorkerHeartbeatServer) SetHeader(arg0 metadata.MD) error

+ func (m *MockTriggerController_TriggerWorkerHeartbeatServer) SetTrailer(arg0 metadata.MD)

+ func (m_2 *MockTriggerController_TriggerWorkerHeartbeatServer) RecvMsg(m interface{}) error

+ func (m_2 *MockTriggerController_TriggerWorkerHeartbeatServer) SendMsg(m interface{}) error

+ type MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder struct

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) Context() *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) Recv() *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SendAndClose(arg0 interface{}) *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SendMsg(m interface{}) *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

+ func (mr *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

+ type MockUnsafeEventbusControllerServer struct

+ func NewMockUnsafeEventbusControllerServer(ctrl *gomock.Controller) *MockUnsafeEventbusControllerServer

+ func (m *MockUnsafeEventbusControllerServer) EXPECT() *MockUnsafeEventbusControllerServerMockRecorder

+ type MockUnsafeEventbusControllerServerMockRecorder struct

+ type MockUnsafeEventlogControllerServer struct

+ func NewMockUnsafeEventlogControllerServer(ctrl *gomock.Controller) *MockUnsafeEventlogControllerServer

+ func (m *MockUnsafeEventlogControllerServer) EXPECT() *MockUnsafeEventlogControllerServerMockRecorder

+ type MockUnsafeEventlogControllerServerMockRecorder struct

+ type MockUnsafeNamespaceControllerServer struct

+ func NewMockUnsafeNamespaceControllerServer(ctrl *gomock.Controller) *MockUnsafeNamespaceControllerServer

+ func (m *MockUnsafeNamespaceControllerServer) EXPECT() *MockUnsafeNamespaceControllerServerMockRecorder

+ type MockUnsafeNamespaceControllerServerMockRecorder struct

+ type MockUnsafePingServerServer struct

+ func NewMockUnsafePingServerServer(ctrl *gomock.Controller) *MockUnsafePingServerServer

+ func (m *MockUnsafePingServerServer) EXPECT() *MockUnsafePingServerServerMockRecorder

+ type MockUnsafePingServerServerMockRecorder struct

+ type MockUnsafeSegmentControllerServer struct

+ func NewMockUnsafeSegmentControllerServer(ctrl *gomock.Controller) *MockUnsafeSegmentControllerServer

+ func (m *MockUnsafeSegmentControllerServer) EXPECT() *MockUnsafeSegmentControllerServerMockRecorder

+ type MockUnsafeSegmentControllerServerMockRecorder struct

+ type MockUnsafeSnowflakeControllerServer struct

+ func NewMockUnsafeSnowflakeControllerServer(ctrl *gomock.Controller) *MockUnsafeSnowflakeControllerServer

+ func (m *MockUnsafeSnowflakeControllerServer) EXPECT() *MockUnsafeSnowflakeControllerServerMockRecorder

+ type MockUnsafeSnowflakeControllerServerMockRecorder struct

+ type MockUnsafeTriggerControllerServer struct

+ func NewMockUnsafeTriggerControllerServer(ctrl *gomock.Controller) *MockUnsafeTriggerControllerServer

+ func (m *MockUnsafeTriggerControllerServer) EXPECT() *MockUnsafeTriggerControllerServerMockRecorder

+ type MockUnsafeTriggerControllerServerMockRecorder struct

+ type NamespaceControllerClient interface

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

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

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

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

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

+ func NewNamespaceControllerClient(cc grpc.ClientConnInterface) NamespaceControllerClient

+ type NamespaceControllerServer interface

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

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

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

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

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

+ type PingResponse struct

+ GatewayAddr string

+ IsEventbusReady bool

+ LeaderAddr string

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

+ func (*PingResponse) ProtoMessage()

+ func (x *PingResponse) GetGatewayAddr() string

+ func (x *PingResponse) GetIsEventbusReady() bool

+ func (x *PingResponse) GetLeaderAddr() string

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

+ func (x *PingResponse) Reset()

+ func (x *PingResponse) String() string

+ type PingServerClient interface

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

+ func NewPingServerClient(cc grpc.ClientConnInterface) PingServerClient

+ type PingServerServer interface

+ Ping func(context.Context, *emptypb.Empty) (*PingResponse, error)

+ type QuerySegmentRouteInfoRequest struct

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

+ func (*QuerySegmentRouteInfoRequest) ProtoMessage()

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

+ func (x *QuerySegmentRouteInfoRequest) Reset()

+ func (x *QuerySegmentRouteInfoRequest) String() string

+ type QuerySegmentRouteInfoResponse struct

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

+ func (*QuerySegmentRouteInfoResponse) ProtoMessage()

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

+ func (x *QuerySegmentRouteInfoResponse) Reset()

+ func (x *QuerySegmentRouteInfoResponse) String() string

+ type RegisterSegmentServerRequest struct

+ Address string

+ Capacity uint64

+ VolumeId uint64

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

+ func (*RegisterSegmentServerRequest) ProtoMessage()

+ func (x *RegisterSegmentServerRequest) GetAddress() string

+ func (x *RegisterSegmentServerRequest) GetCapacity() uint64

+ func (x *RegisterSegmentServerRequest) GetVolumeId() uint64

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

+ func (x *RegisterSegmentServerRequest) Reset()

+ func (x *RegisterSegmentServerRequest) String() string

+ type RegisterSegmentServerResponse struct

+ Segments map[uint64]*meta.Segment

+ VolumeId uint64

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

+ func (*RegisterSegmentServerResponse) ProtoMessage()

+ func (x *RegisterSegmentServerResponse) GetSegments() map[uint64]*meta.Segment

+ func (x *RegisterSegmentServerResponse) GetVolumeId() uint64

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

+ func (x *RegisterSegmentServerResponse) Reset()

+ func (x *RegisterSegmentServerResponse) String() string

+ type RegisterTriggerWorkerRequest struct

+ Address string

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

+ func (*RegisterTriggerWorkerRequest) ProtoMessage()

+ func (x *RegisterTriggerWorkerRequest) GetAddress() string

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

+ func (x *RegisterTriggerWorkerRequest) Reset()

+ func (x *RegisterTriggerWorkerRequest) String() string

+ type RegisterTriggerWorkerResponse struct

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

+ func (*RegisterTriggerWorkerResponse) ProtoMessage()

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

+ func (x *RegisterTriggerWorkerResponse) Reset()

+ func (x *RegisterTriggerWorkerResponse) String() string

+ type ReportSegmentLeaderRequest struct

+ LeaderId uint64

+ SegmentId uint64

+ Term uint64

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

+ func (*ReportSegmentLeaderRequest) ProtoMessage()

+ func (x *ReportSegmentLeaderRequest) GetLeaderId() uint64

+ func (x *ReportSegmentLeaderRequest) GetSegmentId() uint64

+ func (x *ReportSegmentLeaderRequest) GetTerm() uint64

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

+ func (x *ReportSegmentLeaderRequest) Reset()

+ func (x *ReportSegmentLeaderRequest) String() string

+ type ResetOffsetToTimestampRequest struct

+ SubscriptionId uint64

+ Timestamp uint64

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

+ func (*ResetOffsetToTimestampRequest) ProtoMessage()

+ func (x *ResetOffsetToTimestampRequest) GetSubscriptionId() uint64

+ func (x *ResetOffsetToTimestampRequest) GetTimestamp() uint64

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

+ func (x *ResetOffsetToTimestampRequest) Reset()

+ func (x *ResetOffsetToTimestampRequest) String() string

+ type ResetOffsetToTimestampResponse struct

+ Offsets []*meta.OffsetInfo

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

+ func (*ResetOffsetToTimestampResponse) ProtoMessage()

+ func (x *ResetOffsetToTimestampResponse) GetOffsets() []*meta.OffsetInfo

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

+ func (x *ResetOffsetToTimestampResponse) Reset()

+ func (x *ResetOffsetToTimestampResponse) String() string

+ type ResumeSubscriptionRequest struct

+ Id uint64

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

+ func (*ResumeSubscriptionRequest) ProtoMessage()

+ func (x *ResumeSubscriptionRequest) GetId() uint64

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

+ func (x *ResumeSubscriptionRequest) Reset()

+ func (x *ResumeSubscriptionRequest) String() string

+ type SegmentControllerClient interface

+ QuerySegmentRouteInfo func(ctx context.Context, in *QuerySegmentRouteInfoRequest, opts ...grpc.CallOption) (*QuerySegmentRouteInfoResponse, error)

+ RegisterSegmentServer func(ctx context.Context, in *RegisterSegmentServerRequest, opts ...grpc.CallOption) (*RegisterSegmentServerResponse, error)

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

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

+ SegmentHeartbeat func(ctx context.Context, opts ...grpc.CallOption) (SegmentController_SegmentHeartbeatClient, error)

+ UnregisterSegmentServer func(ctx context.Context, in *UnregisterSegmentServerRequest, ...) (*UnregisterSegmentServerResponse, error)

+ func NewSegmentControllerClient(cc grpc.ClientConnInterface) SegmentControllerClient

+ type SegmentControllerServer interface

+ QuerySegmentRouteInfo func(context.Context, *QuerySegmentRouteInfoRequest) (*QuerySegmentRouteInfoResponse, error)

+ RegisterSegmentServer func(context.Context, *RegisterSegmentServerRequest) (*RegisterSegmentServerResponse, error)

+ ReportSegmentBlockIsFull func(context.Context, *SegmentHeartbeatRequest) (*emptypb.Empty, error)

+ ReportSegmentLeader func(context.Context, *ReportSegmentLeaderRequest) (*emptypb.Empty, error)

+ SegmentHeartbeat func(SegmentController_SegmentHeartbeatServer) error

+ UnregisterSegmentServer func(context.Context, *UnregisterSegmentServerRequest) (*UnregisterSegmentServerResponse, error)

+ type SegmentController_SegmentHeartbeatClient interface

+ CloseAndRecv func() (*SegmentHeartbeatResponse, error)

+ Send func(*SegmentHeartbeatRequest) error

+ type SegmentController_SegmentHeartbeatServer interface

+ Recv func() (*SegmentHeartbeatRequest, error)

+ SendAndClose func(*SegmentHeartbeatResponse) error

+ type SegmentHeartbeatRequest struct

+ HealthInfo []*meta.SegmentHealthInfo

+ ReportTime string

+ ServerAddr string

+ VolumeId uint64

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

+ func (*SegmentHeartbeatRequest) ProtoMessage()

+ func (x *SegmentHeartbeatRequest) GetHealthInfo() []*meta.SegmentHealthInfo

+ func (x *SegmentHeartbeatRequest) GetReportTime() string

+ func (x *SegmentHeartbeatRequest) GetServerAddr() string

+ func (x *SegmentHeartbeatRequest) GetVolumeId() uint64

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

+ func (x *SegmentHeartbeatRequest) Reset()

+ func (x *SegmentHeartbeatRequest) String() string

+ type SegmentHeartbeatResponse struct

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

+ func (*SegmentHeartbeatResponse) ProtoMessage()

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

+ func (x *SegmentHeartbeatResponse) Reset()

+ func (x *SegmentHeartbeatResponse) String() string

+ type SetDeadLetterEventOffsetRequest struct

+ Offset uint64

+ SubscriptionId uint64

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

+ func (*SetDeadLetterEventOffsetRequest) ProtoMessage()

+ func (x *SetDeadLetterEventOffsetRequest) GetOffset() uint64

+ func (x *SetDeadLetterEventOffsetRequest) GetSubscriptionId() uint64

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

+ func (x *SetDeadLetterEventOffsetRequest) Reset()

+ func (x *SetDeadLetterEventOffsetRequest) String() string

+ type SnowflakeControllerClient interface

+ GetClusterStartTime func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*timestamppb.Timestamp, error)

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

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

+ func NewSnowflakeControllerClient(cc grpc.ClientConnInterface) SnowflakeControllerClient

+ type SnowflakeControllerServer interface

+ GetClusterStartTime func(context.Context, *emptypb.Empty) (*timestamppb.Timestamp, error)

+ RegisterNode func(context.Context, *wrapperspb.UInt32Value) (*emptypb.Empty, error)

+ UnregisterNode func(context.Context, *wrapperspb.UInt32Value) (*emptypb.Empty, error)

+ type SubscriptionRequest struct

+ Config *meta.SubscriptionConfig

+ Description string

+ Disable bool

+ EventbusId uint64

+ Filters []*meta.Filter

+ Name string

+ NamespaceId uint64

+ Protocol meta.Protocol

+ ProtocolSettings *meta.ProtocolSetting

+ Sink string

+ SinkCredential *meta.SinkCredential

+ Source string

+ Transformer *meta.Transformer

+ Types []string

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

+ func (*SubscriptionRequest) ProtoMessage()

+ func (x *SubscriptionRequest) GetConfig() *meta.SubscriptionConfig

+ func (x *SubscriptionRequest) GetDescription() string

+ func (x *SubscriptionRequest) GetDisable() bool

+ func (x *SubscriptionRequest) GetEventbusId() uint64

+ func (x *SubscriptionRequest) GetFilters() []*meta.Filter

+ func (x *SubscriptionRequest) GetName() string

+ func (x *SubscriptionRequest) GetNamespaceId() uint64

+ func (x *SubscriptionRequest) GetProtocol() meta.Protocol

+ func (x *SubscriptionRequest) GetProtocolSettings() *meta.ProtocolSetting

+ func (x *SubscriptionRequest) GetSink() string

+ func (x *SubscriptionRequest) GetSinkCredential() *meta.SinkCredential

+ func (x *SubscriptionRequest) GetSource() string

+ func (x *SubscriptionRequest) GetTransformer() *meta.Transformer

+ func (x *SubscriptionRequest) GetTypes() []string

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

+ func (x *SubscriptionRequest) Reset()

+ func (x *SubscriptionRequest) String() string

+ type TriggerControllerClient interface

+ CommitOffset func(ctx context.Context, in *CommitOffsetRequest, opts ...grpc.CallOption) (*CommitOffsetResponse, error)

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

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

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

+ GetDeadLetterEventOffset func(ctx context.Context, in *GetDeadLetterEventOffsetRequest, ...) (*GetDeadLetterEventOffsetResponse, error)

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

+ ListSubscription func(ctx context.Context, in *ListSubscriptionRequest, opts ...grpc.CallOption) (*ListSubscriptionResponse, error)

+ RegisterTriggerWorker func(ctx context.Context, in *RegisterTriggerWorkerRequest, opts ...grpc.CallOption) (*RegisterTriggerWorkerResponse, error)

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

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

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

+ TriggerWorkerHeartbeat func(ctx context.Context, opts ...grpc.CallOption) (TriggerController_TriggerWorkerHeartbeatClient, error)

+ UnregisterTriggerWorker func(ctx context.Context, in *UnregisterTriggerWorkerRequest, ...) (*UnregisterTriggerWorkerResponse, error)

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

+ func NewTriggerControllerClient(cc grpc.ClientConnInterface) TriggerControllerClient

+ type TriggerControllerServer interface

+ CommitOffset func(context.Context, *CommitOffsetRequest) (*CommitOffsetResponse, error)

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

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

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

+ GetDeadLetterEventOffset func(context.Context, *GetDeadLetterEventOffsetRequest) (*GetDeadLetterEventOffsetResponse, error)

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

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

+ RegisterTriggerWorker func(context.Context, *RegisterTriggerWorkerRequest) (*RegisterTriggerWorkerResponse, error)

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

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

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

+ TriggerWorkerHeartbeat func(TriggerController_TriggerWorkerHeartbeatServer) error

+ UnregisterTriggerWorker func(context.Context, *UnregisterTriggerWorkerRequest) (*UnregisterTriggerWorkerResponse, error)

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

+ type TriggerController_TriggerWorkerHeartbeatClient interface

+ CloseAndRecv func() (*TriggerWorkerHeartbeatResponse, error)

+ Send func(*TriggerWorkerHeartbeatRequest) error

+ type TriggerController_TriggerWorkerHeartbeatServer interface

+ Recv func() (*TriggerWorkerHeartbeatRequest, error)

+ SendAndClose func(*TriggerWorkerHeartbeatResponse) error

+ type TriggerWorkerHeartbeatRequest struct

+ Address string

+ Started bool

+ SubscriptionInfo []*meta.SubscriptionInfo

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

+ func (*TriggerWorkerHeartbeatRequest) ProtoMessage()

+ func (x *TriggerWorkerHeartbeatRequest) GetAddress() string

+ func (x *TriggerWorkerHeartbeatRequest) GetStarted() bool

+ func (x *TriggerWorkerHeartbeatRequest) GetSubscriptionInfo() []*meta.SubscriptionInfo

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

+ func (x *TriggerWorkerHeartbeatRequest) Reset()

+ func (x *TriggerWorkerHeartbeatRequest) String() string

+ type TriggerWorkerHeartbeatResponse struct

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

+ func (*TriggerWorkerHeartbeatResponse) ProtoMessage()

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

+ func (x *TriggerWorkerHeartbeatResponse) Reset()

+ func (x *TriggerWorkerHeartbeatResponse) String() string

+ type UnimplementedEventbusControllerServer struct

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

+ func (UnimplementedEventbusControllerServer) CreateSystemEventbus(context.Context, *CreateEventbusRequest) (*meta.Eventbus, error)

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

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

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

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

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

+ type UnimplementedEventlogControllerServer struct

+ func (UnimplementedEventlogControllerServer) GetAppendableSegment(context.Context, *GetAppendableSegmentRequest) (*GetAppendableSegmentResponse, error)

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

+ type UnimplementedNamespaceControllerServer struct

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

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

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

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

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

+ type UnimplementedPingServerServer struct

+ func (UnimplementedPingServerServer) Ping(context.Context, *emptypb.Empty) (*PingResponse, error)

+ type UnimplementedSegmentControllerServer struct

+ func (UnimplementedSegmentControllerServer) QuerySegmentRouteInfo(context.Context, *QuerySegmentRouteInfoRequest) (*QuerySegmentRouteInfoResponse, error)

+ func (UnimplementedSegmentControllerServer) RegisterSegmentServer(context.Context, *RegisterSegmentServerRequest) (*RegisterSegmentServerResponse, error)

+ func (UnimplementedSegmentControllerServer) ReportSegmentBlockIsFull(context.Context, *SegmentHeartbeatRequest) (*emptypb.Empty, error)

+ func (UnimplementedSegmentControllerServer) ReportSegmentLeader(context.Context, *ReportSegmentLeaderRequest) (*emptypb.Empty, error)

+ func (UnimplementedSegmentControllerServer) SegmentHeartbeat(SegmentController_SegmentHeartbeatServer) error

+ func (UnimplementedSegmentControllerServer) UnregisterSegmentServer(context.Context, *UnregisterSegmentServerRequest) (*UnregisterSegmentServerResponse, error)

+ type UnimplementedSnowflakeControllerServer struct

+ func (UnimplementedSnowflakeControllerServer) GetClusterStartTime(context.Context, *emptypb.Empty) (*timestamppb.Timestamp, error)

+ func (UnimplementedSnowflakeControllerServer) RegisterNode(context.Context, *wrapperspb.UInt32Value) (*emptypb.Empty, error)

+ func (UnimplementedSnowflakeControllerServer) UnregisterNode(context.Context, *wrapperspb.UInt32Value) (*emptypb.Empty, error)

+ type UnimplementedTriggerControllerServer struct

+ func (UnimplementedTriggerControllerServer) CommitOffset(context.Context, *CommitOffsetRequest) (*CommitOffsetResponse, error)

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

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

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

+ func (UnimplementedTriggerControllerServer) GetDeadLetterEventOffset(context.Context, *GetDeadLetterEventOffsetRequest) (*GetDeadLetterEventOffsetResponse, error)

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

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

+ func (UnimplementedTriggerControllerServer) RegisterTriggerWorker(context.Context, *RegisterTriggerWorkerRequest) (*RegisterTriggerWorkerResponse, error)

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

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

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

+ func (UnimplementedTriggerControllerServer) TriggerWorkerHeartbeat(TriggerController_TriggerWorkerHeartbeatServer) error

+ func (UnimplementedTriggerControllerServer) UnregisterTriggerWorker(context.Context, *UnregisterTriggerWorkerRequest) (*UnregisterTriggerWorkerResponse, error)

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

+ type UnregisterSegmentServerRequest struct

+ Address string

+ VolumeId uint64

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

+ func (*UnregisterSegmentServerRequest) ProtoMessage()

+ func (x *UnregisterSegmentServerRequest) GetAddress() string

+ func (x *UnregisterSegmentServerRequest) GetVolumeId() uint64

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

+ func (x *UnregisterSegmentServerRequest) Reset()

+ func (x *UnregisterSegmentServerRequest) String() string

+ type UnregisterSegmentServerResponse struct

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

+ func (*UnregisterSegmentServerResponse) ProtoMessage()

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

+ func (x *UnregisterSegmentServerResponse) Reset()

+ func (x *UnregisterSegmentServerResponse) String() string

+ type UnregisterTriggerWorkerRequest struct

+ Address string

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

+ func (*UnregisterTriggerWorkerRequest) ProtoMessage()

+ func (x *UnregisterTriggerWorkerRequest) GetAddress() string

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

+ func (x *UnregisterTriggerWorkerRequest) Reset()

+ func (x *UnregisterTriggerWorkerRequest) String() string

+ type UnregisterTriggerWorkerResponse struct

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

+ func (*UnregisterTriggerWorkerResponse) ProtoMessage()

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

+ func (x *UnregisterTriggerWorkerResponse) Reset()

+ func (x *UnregisterTriggerWorkerResponse) String() string

+ type UnsafeEventbusControllerServer interface

+ type UnsafeEventlogControllerServer interface

+ type UnsafeNamespaceControllerServer interface

+ type UnsafePingServerServer interface

+ type UnsafeSegmentControllerServer interface

+ type UnsafeSnowflakeControllerServer interface

+ type UnsafeTriggerControllerServer interface

+ type UpdateEventbusRequest struct

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

+ func (*UpdateEventbusRequest) ProtoMessage()

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

+ func (x *UpdateEventbusRequest) Reset()

+ func (x *UpdateEventbusRequest) String() string

+ type UpdateSubscriptionRequest struct

+ Id uint64

+ Subscription *SubscriptionRequest

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

+ func (*UpdateSubscriptionRequest) ProtoMessage()

+ func (x *UpdateSubscriptionRequest) GetId() uint64

+ func (x *UpdateSubscriptionRequest) GetSubscription() *SubscriptionRequest

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

+ func (x *UpdateSubscriptionRequest) Reset()

+ func (x *UpdateSubscriptionRequest) String() string

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