controller

package
v0.0.0-...-1334a7b Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NamespaceController_CreateNamespace_FullMethodName               = "/vanus.core.controller.NamespaceController/CreateNamespace"
	NamespaceController_ListNamespace_FullMethodName                 = "/vanus.core.controller.NamespaceController/ListNamespace"
	NamespaceController_GetNamespace_FullMethodName                  = "/vanus.core.controller.NamespaceController/GetNamespace"
	NamespaceController_DeleteNamespace_FullMethodName               = "/vanus.core.controller.NamespaceController/DeleteNamespace"
	NamespaceController_GetNamespaceWithHumanFriendly_FullMethodName = "/vanus.core.controller.NamespaceController/GetNamespaceWithHumanFriendly"
)
View Source 
const (
	EventbusController_CreateEventbus_FullMethodName               = "/vanus.core.controller.EventbusController/CreateEventbus"
	EventbusController_CreateSystemEventbus_FullMethodName         = "/vanus.core.controller.EventbusController/CreateSystemEventbus"
	EventbusController_DeleteEventbus_FullMethodName               = "/vanus.core.controller.EventbusController/DeleteEventbus"
	EventbusController_GetEventbus_FullMethodName                  = "/vanus.core.controller.EventbusController/GetEventbus"
	EventbusController_ListEventbus_FullMethodName                 = "/vanus.core.controller.EventbusController/ListEventbus"
	EventbusController_UpdateEventbus_FullMethodName               = "/vanus.core.controller.EventbusController/UpdateEventbus"
	EventbusController_GetEventbusWithHumanFriendly_FullMethodName = "/vanus.core.controller.EventbusController/GetEventbusWithHumanFriendly"
)
View Source 
const (
	EventlogController_ListSegment_FullMethodName          = "/vanus.core.controller.EventlogController/ListSegment"
	EventlogController_GetAppendableSegment_FullMethodName = "/vanus.core.controller.EventlogController/GetAppendableSegment"
)
View Source 
const (
	SegmentController_QuerySegmentRouteInfo_FullMethodName    = "/vanus.core.controller.SegmentController/QuerySegmentRouteInfo"
	SegmentController_SegmentHeartbeat_FullMethodName         = "/vanus.core.controller.SegmentController/SegmentHeartbeat"
	SegmentController_RegisterSegmentServer_FullMethodName    = "/vanus.core.controller.SegmentController/RegisterSegmentServer"
	SegmentController_UnregisterSegmentServer_FullMethodName  = "/vanus.core.controller.SegmentController/UnregisterSegmentServer"
	SegmentController_ReportSegmentBlockIsFull_FullMethodName = "/vanus.core.controller.SegmentController/ReportSegmentBlockIsFull"
	SegmentController_ReportSegmentLeader_FullMethodName      = "/vanus.core.controller.SegmentController/ReportSegmentLeader"
)
View Source 
const (
	TriggerController_CreateSubscription_FullMethodName       = "/vanus.core.controller.TriggerController/CreateSubscription"
	TriggerController_UpdateSubscription_FullMethodName       = "/vanus.core.controller.TriggerController/UpdateSubscription"
	TriggerController_DeleteSubscription_FullMethodName       = "/vanus.core.controller.TriggerController/DeleteSubscription"
	TriggerController_DisableSubscription_FullMethodName      = "/vanus.core.controller.TriggerController/DisableSubscription"
	TriggerController_ResumeSubscription_FullMethodName       = "/vanus.core.controller.TriggerController/ResumeSubscription"
	TriggerController_GetSubscription_FullMethodName          = "/vanus.core.controller.TriggerController/GetSubscription"
	TriggerController_ListSubscription_FullMethodName         = "/vanus.core.controller.TriggerController/ListSubscription"
	TriggerController_TriggerWorkerHeartbeat_FullMethodName   = "/vanus.core.controller.TriggerController/TriggerWorkerHeartbeat"
	TriggerController_RegisterTriggerWorker_FullMethodName    = "/vanus.core.controller.TriggerController/RegisterTriggerWorker"
	TriggerController_UnregisterTriggerWorker_FullMethodName  = "/vanus.core.controller.TriggerController/UnregisterTriggerWorker"
	TriggerController_ResetOffsetToTimestamp_FullMethodName   = "/vanus.core.controller.TriggerController/ResetOffsetToTimestamp"
	TriggerController_CommitOffset_FullMethodName             = "/vanus.core.controller.TriggerController/CommitOffset"
	TriggerController_SetDeadLetterEventOffset_FullMethodName = "/vanus.core.controller.TriggerController/SetDeadLetterEventOffset"
	TriggerController_GetDeadLetterEventOffset_FullMethodName = "/vanus.core.controller.TriggerController/GetDeadLetterEventOffset"
)
View Source 
const (
	SnowflakeController_GetClusterStartTime_FullMethodName = "/vanus.core.controller.SnowflakeController/GetClusterStartTime"
	SnowflakeController_RegisterNode_FullMethodName        = "/vanus.core.controller.SnowflakeController/RegisterNode"
	SnowflakeController_UnregisterNode_FullMethodName      = "/vanus.core.controller.SnowflakeController/UnregisterNode"
)
View Source 
const (
	AuthController_CreateUser_FullMethodName      = "/vanus.core.controller.AuthController/CreateUser"
	AuthController_DeleteUser_FullMethodName      = "/vanus.core.controller.AuthController/DeleteUser"
	AuthController_GetUser_FullMethodName         = "/vanus.core.controller.AuthController/GetUser"
	AuthController_ListUser_FullMethodName        = "/vanus.core.controller.AuthController/ListUser"
	AuthController_GetUserByToken_FullMethodName  = "/vanus.core.controller.AuthController/GetUserByToken"
	AuthController_CreateToken_FullMethodName     = "/vanus.core.controller.AuthController/CreateToken"
	AuthController_DeleteToken_FullMethodName     = "/vanus.core.controller.AuthController/DeleteToken"
	AuthController_GetToken_FullMethodName        = "/vanus.core.controller.AuthController/GetToken"
	AuthController_GetUserToken_FullMethodName    = "/vanus.core.controller.AuthController/GetUserToken"
	AuthController_ListToken_FullMethodName       = "/vanus.core.controller.AuthController/ListToken"
	AuthController_GrantRole_FullMethodName       = "/vanus.core.controller.AuthController/GrantRole"
	AuthController_RevokeRole_FullMethodName      = "/vanus.core.controller.AuthController/RevokeRole"
	AuthController_GetUserRole_FullMethodName     = "/vanus.core.controller.AuthController/GetUserRole"
	AuthController_GetResourceRole_FullMethodName = "/vanus.core.controller.AuthController/GetResourceRole"
)
View Source 
const (
	PingServer_Ping_FullMethodName = "/vanus.core.controller.PingServer/Ping"
)

Variables

View Source 
var AuthController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.controller.AuthController",
	HandlerType: (*AuthControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateUser",
			Handler:    _AuthController_CreateUser_Handler,
		},
		{
			MethodName: "DeleteUser",
			Handler:    _AuthController_DeleteUser_Handler,
		},
		{
			MethodName: "GetUser",
			Handler:    _AuthController_GetUser_Handler,
		},
		{
			MethodName: "ListUser",
			Handler:    _AuthController_ListUser_Handler,
		},
		{
			MethodName: "GetUserByToken",
			Handler:    _AuthController_GetUserByToken_Handler,
		},
		{
			MethodName: "CreateToken",
			Handler:    _AuthController_CreateToken_Handler,
		},
		{
			MethodName: "DeleteToken",
			Handler:    _AuthController_DeleteToken_Handler,
		},
		{
			MethodName: "GetToken",
			Handler:    _AuthController_GetToken_Handler,
		},
		{
			MethodName: "GetUserToken",
			Handler:    _AuthController_GetUserToken_Handler,
		},
		{
			MethodName: "ListToken",
			Handler:    _AuthController_ListToken_Handler,
		},
		{
			MethodName: "GrantRole",
			Handler:    _AuthController_GrantRole_Handler,
		},
		{
			MethodName: "RevokeRole",
			Handler:    _AuthController_RevokeRole_Handler,
		},
		{
			MethodName: "GetUserRole",
			Handler:    _AuthController_GetUserRole_Handler,
		},
		{
			MethodName: "GetResourceRole",
			Handler:    _AuthController_GetResourceRole_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vanus/core/controller/controller.proto",
}

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

View Source 
var EventbusController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.controller.EventbusController",
	HandlerType: (*EventbusControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateEventbus",
			Handler:    _EventbusController_CreateEventbus_Handler,
		},
		{
			MethodName: "CreateSystemEventbus",
			Handler:    _EventbusController_CreateSystemEventbus_Handler,
		},
		{
			MethodName: "DeleteEventbus",
			Handler:    _EventbusController_DeleteEventbus_Handler,
		},
		{
			MethodName: "GetEventbus",
			Handler:    _EventbusController_GetEventbus_Handler,
		},
		{
			MethodName: "ListEventbus",
			Handler:    _EventbusController_ListEventbus_Handler,
		},
		{
			MethodName: "UpdateEventbus",
			Handler:    _EventbusController_UpdateEventbus_Handler,
		},
		{
			MethodName: "GetEventbusWithHumanFriendly",
			Handler:    _EventbusController_GetEventbusWithHumanFriendly_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vanus/core/controller/controller.proto",
}

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

View Source 
var EventlogController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.controller.EventlogController",
	HandlerType: (*EventlogControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListSegment",
			Handler:    _EventlogController_ListSegment_Handler,
		},
		{
			MethodName: "GetAppendableSegment",
			Handler:    _EventlogController_GetAppendableSegment_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vanus/core/controller/controller.proto",
}

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

View Source 
var File_vanus_core_controller_controller_proto protoreflect.FileDescriptor
View Source 
var NamespaceController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.controller.NamespaceController",
	HandlerType: (*NamespaceControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNamespace",
			Handler:    _NamespaceController_CreateNamespace_Handler,
		},
		{
			MethodName: "ListNamespace",
			Handler:    _NamespaceController_ListNamespace_Handler,
		},
		{
			MethodName: "GetNamespace",
			Handler:    _NamespaceController_GetNamespace_Handler,
		},
		{
			MethodName: "DeleteNamespace",
			Handler:    _NamespaceController_DeleteNamespace_Handler,
		},
		{
			MethodName: "GetNamespaceWithHumanFriendly",
			Handler:    _NamespaceController_GetNamespaceWithHumanFriendly_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vanus/core/controller/controller.proto",
}

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

View Source 
var PingServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.controller.PingServer",
	HandlerType: (*PingServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _PingServer_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vanus/core/controller/controller.proto",
}

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

View Source 
var SegmentController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.controller.SegmentController",
	HandlerType: (*SegmentControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QuerySegmentRouteInfo",
			Handler:    _SegmentController_QuerySegmentRouteInfo_Handler,
		},
		{
			MethodName: "RegisterSegmentServer",
			Handler:    _SegmentController_RegisterSegmentServer_Handler,
		},
		{
			MethodName: "UnregisterSegmentServer",
			Handler:    _SegmentController_UnregisterSegmentServer_Handler,
		},
		{
			MethodName: "ReportSegmentBlockIsFull",
			Handler:    _SegmentController_ReportSegmentBlockIsFull_Handler,
		},
		{
			MethodName: "ReportSegmentLeader",
			Handler:    _SegmentController_ReportSegmentLeader_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SegmentHeartbeat",
			Handler:       _SegmentController_SegmentHeartbeat_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "vanus/core/controller/controller.proto",
}

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

View Source 
var SnowflakeController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.controller.SnowflakeController",
	HandlerType: (*SnowflakeControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetClusterStartTime",
			Handler:    _SnowflakeController_GetClusterStartTime_Handler,
		},
		{
			MethodName: "RegisterNode",
			Handler:    _SnowflakeController_RegisterNode_Handler,
		},
		{
			MethodName: "UnregisterNode",
			Handler:    _SnowflakeController_UnregisterNode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vanus/core/controller/controller.proto",
}

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

View Source 
var TriggerController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.controller.TriggerController",
	HandlerType: (*TriggerControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateSubscription",
			Handler:    _TriggerController_CreateSubscription_Handler,
		},
		{
			MethodName: "UpdateSubscription",
			Handler:    _TriggerController_UpdateSubscription_Handler,
		},
		{
			MethodName: "DeleteSubscription",
			Handler:    _TriggerController_DeleteSubscription_Handler,
		},
		{
			MethodName: "DisableSubscription",
			Handler:    _TriggerController_DisableSubscription_Handler,
		},
		{
			MethodName: "ResumeSubscription",
			Handler:    _TriggerController_ResumeSubscription_Handler,
		},
		{
			MethodName: "GetSubscription",
			Handler:    _TriggerController_GetSubscription_Handler,
		},
		{
			MethodName: "ListSubscription",
			Handler:    _TriggerController_ListSubscription_Handler,
		},
		{
			MethodName: "RegisterTriggerWorker",
			Handler:    _TriggerController_RegisterTriggerWorker_Handler,
		},
		{
			MethodName: "UnregisterTriggerWorker",
			Handler:    _TriggerController_UnregisterTriggerWorker_Handler,
		},
		{
			MethodName: "ResetOffsetToTimestamp",
			Handler:    _TriggerController_ResetOffsetToTimestamp_Handler,
		},
		{
			MethodName: "CommitOffset",
			Handler:    _TriggerController_CommitOffset_Handler,
		},
		{
			MethodName: "SetDeadLetterEventOffset",
			Handler:    _TriggerController_SetDeadLetterEventOffset_Handler,
		},
		{
			MethodName: "GetDeadLetterEventOffset",
			Handler:    _TriggerController_GetDeadLetterEventOffset_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TriggerWorkerHeartbeat",
			Handler:       _TriggerController_TriggerWorkerHeartbeat_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "vanus/core/controller/controller.proto",
}

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

Functions

func RegisterAuthControllerServer 

func RegisterAuthControllerServer(s grpc.ServiceRegistrar, srv AuthControllerServer)

func RegisterEventbusControllerServer 

func RegisterEventbusControllerServer(s grpc.ServiceRegistrar, srv EventbusControllerServer)

func RegisterEventlogControllerServer 

func RegisterEventlogControllerServer(s grpc.ServiceRegistrar, srv EventlogControllerServer)

func RegisterNamespaceControllerServer 

func RegisterNamespaceControllerServer(s grpc.ServiceRegistrar, srv NamespaceControllerServer)

func RegisterPingServerServer 

func RegisterPingServerServer(s grpc.ServiceRegistrar, srv PingServerServer)

func RegisterSegmentControllerServer 

func RegisterSegmentControllerServer(s grpc.ServiceRegistrar, srv SegmentControllerServer)

func RegisterSnowflakeControllerServer 

func RegisterSnowflakeControllerServer(s grpc.ServiceRegistrar, srv SnowflakeControllerServer)

func RegisterTriggerControllerServer 

func RegisterTriggerControllerServer(s grpc.ServiceRegistrar, srv TriggerControllerServer)

Types

type AuthControllerClient 

type AuthControllerClient interface {
	CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*meta.User, error)
	DeleteUser(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetUser(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*meta.User, error)
	ListUser(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListUserResponse, error)
	GetUserByToken(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)
	CreateToken(ctx context.Context, in *CreateTokenRequest, opts ...grpc.CallOption) (*meta.Token, error)
	DeleteToken(ctx context.Context, in *DeleteTokenRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetToken(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*meta.Token, error)
	GetUserToken(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*GetTokenResponse, error)
	ListToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTokenResponse, error)
	GrantRole(ctx context.Context, in *RoleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RevokeRole(ctx context.Context, in *RoleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetUserRole(ctx context.Context, in *GetUserRoleRequest, opts ...grpc.CallOption) (*GetUserRoleResponse, error)
	GetResourceRole(ctx context.Context, in *GetResourceRoleRequest, opts ...grpc.CallOption) (*GetResourceRoleResponse, error)
}

AuthControllerClient is the client API for AuthController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAuthControllerClient 

func NewAuthControllerClient(cc grpc.ClientConnInterface) AuthControllerClient

type AuthControllerServer 

type AuthControllerServer interface {
	CreateUser(context.Context, *CreateUserRequest) (*meta.User, error)
	DeleteUser(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)
	GetUser(context.Context, *wrapperspb.StringValue) (*meta.User, error)
	ListUser(context.Context, *emptypb.Empty) (*ListUserResponse, error)
	GetUserByToken(context.Context, *wrapperspb.StringValue) (*wrapperspb.StringValue, error)
	CreateToken(context.Context, *CreateTokenRequest) (*meta.Token, error)
	DeleteToken(context.Context, *DeleteTokenRequest) (*emptypb.Empty, error)
	GetToken(context.Context, *wrapperspb.UInt64Value) (*meta.Token, error)
	GetUserToken(context.Context, *wrapperspb.StringValue) (*GetTokenResponse, error)
	ListToken(context.Context, *emptypb.Empty) (*ListTokenResponse, error)
	GrantRole(context.Context, *RoleRequest) (*emptypb.Empty, error)
	RevokeRole(context.Context, *RoleRequest) (*emptypb.Empty, error)
	GetUserRole(context.Context, *GetUserRoleRequest) (*GetUserRoleResponse, error)
	GetResourceRole(context.Context, *GetResourceRoleRequest) (*GetResourceRoleResponse, error)
}

AuthControllerServer is the server API for AuthController service. All implementations should embed UnimplementedAuthControllerServer for forward compatibility

type CommitOffsetRequest 

type CommitOffsetRequest struct {
	SubscriptionInfo []*meta.SubscriptionInfo `protobuf:"bytes,1,rep,name=subscription_info,json=subscriptionInfo,proto3" json:"subscription_info,omitempty"`
	ForceCommit      bool                     `protobuf:"varint,2,opt,name=force_commit,json=forceCommit,proto3" json:"force_commit,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitOffsetRequest) Descriptor deprecated 

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

Deprecated: Use CommitOffsetRequest.ProtoReflect.Descriptor instead.

func (*CommitOffsetRequest) GetForceCommit 

func (x *CommitOffsetRequest) GetForceCommit() bool

func (*CommitOffsetRequest) GetSubscriptionInfo 

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

func (*CommitOffsetRequest) ProtoMessage 

func (*CommitOffsetRequest) ProtoMessage()

func (*CommitOffsetRequest) ProtoReflect 

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

func (*CommitOffsetRequest) Reset 

func (x *CommitOffsetRequest) Reset()

func (*CommitOffsetRequest) String 

func (x *CommitOffsetRequest) String() string

type CommitOffsetResponse 

type CommitOffsetResponse struct {
	FailSubscriptionId []uint64 `protobuf:"varint,1,rep,packed,name=fail_subscription_id,json=failSubscriptionId,proto3" json:"fail_subscription_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitOffsetResponse) Descriptor deprecated 

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

Deprecated: Use CommitOffsetResponse.ProtoReflect.Descriptor instead.

func (*CommitOffsetResponse) GetFailSubscriptionId 

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

func (*CommitOffsetResponse) ProtoMessage 

func (*CommitOffsetResponse) ProtoMessage()

func (*CommitOffsetResponse) ProtoReflect 

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

func (*CommitOffsetResponse) Reset 

func (x *CommitOffsetResponse) Reset()

func (*CommitOffsetResponse) String 

func (x *CommitOffsetResponse) String() string

type CreateEventbusRequest 

type CreateEventbusRequest struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	LogNumber   int32  `protobuf:"varint,2,opt,name=log_number,json=logNumber,proto3" json:"log_number,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	NamespaceId uint64 `protobuf:"varint,4,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Id          uint64 `protobuf:"varint,5,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateEventbusRequest) Descriptor deprecated 

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

Deprecated: Use CreateEventbusRequest.ProtoReflect.Descriptor instead.

func (*CreateEventbusRequest) GetDescription 

func (x *CreateEventbusRequest) GetDescription() string

func (*CreateEventbusRequest) GetId 

func (x *CreateEventbusRequest) GetId() uint64

func (*CreateEventbusRequest) GetLogNumber 

func (x *CreateEventbusRequest) GetLogNumber() int32

func (*CreateEventbusRequest) GetName 

func (x *CreateEventbusRequest) GetName() string

func (*CreateEventbusRequest) GetNamespaceId 

func (x *CreateEventbusRequest) GetNamespaceId() uint64

func (*CreateEventbusRequest) ProtoMessage 

func (*CreateEventbusRequest) ProtoMessage()

func (*CreateEventbusRequest) ProtoReflect 

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

func (*CreateEventbusRequest) Reset 

func (x *CreateEventbusRequest) Reset()

func (*CreateEventbusRequest) String 

func (x *CreateEventbusRequest) String() string

type CreateNamespaceRequest 

type CreateNamespaceRequest struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Id          uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use CreateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*CreateNamespaceRequest) GetDescription 

func (x *CreateNamespaceRequest) GetDescription() string

func (*CreateNamespaceRequest) GetId 

func (x *CreateNamespaceRequest) GetId() uint64

func (*CreateNamespaceRequest) GetName 

func (x *CreateNamespaceRequest) GetName() string

func (*CreateNamespaceRequest) ProtoMessage 

func (*CreateNamespaceRequest) ProtoMessage()

func (*CreateNamespaceRequest) ProtoReflect 

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

func (*CreateNamespaceRequest) Reset 

func (x *CreateNamespaceRequest) Reset()

func (*CreateNamespaceRequest) String 

func (x *CreateNamespaceRequest) String() string

type CreateSubscriptionRequest 

type CreateSubscriptionRequest struct {
	Subscription *SubscriptionRequest `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	Id           uint64               `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use CreateSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*CreateSubscriptionRequest) GetId 

func (x *CreateSubscriptionRequest) GetId() uint64

func (*CreateSubscriptionRequest) GetSubscription 

func (x *CreateSubscriptionRequest) GetSubscription() *SubscriptionRequest

func (*CreateSubscriptionRequest) ProtoMessage 

func (*CreateSubscriptionRequest) ProtoMessage()

func (*CreateSubscriptionRequest) ProtoReflect 

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

func (*CreateSubscriptionRequest) Reset 

func (x *CreateSubscriptionRequest) Reset()

func (*CreateSubscriptionRequest) String 

func (x *CreateSubscriptionRequest) String() string

type CreateTokenRequest 

type CreateTokenRequest struct {
	UserIdentifier string `protobuf:"bytes,1,opt,name=user_identifier,json=userIdentifier,proto3" json:"user_identifier,omitempty"`
	Description    string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTokenRequest) Descriptor deprecated 

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

Deprecated: Use CreateTokenRequest.ProtoReflect.Descriptor instead.

func (*CreateTokenRequest) GetDescription 

func (x *CreateTokenRequest) GetDescription() string

func (*CreateTokenRequest) GetUserIdentifier 

func (x *CreateTokenRequest) GetUserIdentifier() string

func (*CreateTokenRequest) ProtoMessage 

func (*CreateTokenRequest) ProtoMessage()

func (*CreateTokenRequest) ProtoReflect 

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

func (*CreateTokenRequest) Reset 

func (x *CreateTokenRequest) Reset()

func (*CreateTokenRequest) String 

func (x *CreateTokenRequest) String() string

type CreateUserRequest 

type CreateUserRequest struct {
	Identifier  string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateUserRequest) Descriptor deprecated 

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

Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.

func (*CreateUserRequest) GetDescription 

func (x *CreateUserRequest) GetDescription() string

func (*CreateUserRequest) GetIdentifier 

func (x *CreateUserRequest) GetIdentifier() string

func (*CreateUserRequest) ProtoMessage 

func (*CreateUserRequest) ProtoMessage()

func (*CreateUserRequest) ProtoReflect 

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

func (*CreateUserRequest) Reset 

func (x *CreateUserRequest) Reset()

func (*CreateUserRequest) String 

func (x *CreateUserRequest) String() string

type DeleteNamespaceRequest 

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

func (*DeleteNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceRequest) GetId 

func (x *DeleteNamespaceRequest) GetId() uint64

func (*DeleteNamespaceRequest) ProtoMessage 

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) ProtoReflect 

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

func (*DeleteNamespaceRequest) Reset 

func (x *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) String 

func (x *DeleteNamespaceRequest) String() string

type DeleteSubscriptionRequest 

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

func (*DeleteSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*DeleteSubscriptionRequest) GetId 

func (x *DeleteSubscriptionRequest) GetId() uint64

func (*DeleteSubscriptionRequest) ProtoMessage 

func (*DeleteSubscriptionRequest) ProtoMessage()

func (*DeleteSubscriptionRequest) ProtoReflect 

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

func (*DeleteSubscriptionRequest) Reset 

func (x *DeleteSubscriptionRequest) Reset()

func (*DeleteSubscriptionRequest) String 

func (x *DeleteSubscriptionRequest) String() string

type DeleteTokenRequest 

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

func (*DeleteTokenRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTokenRequest.ProtoReflect.Descriptor instead.

func (*DeleteTokenRequest) GetId 

func (x *DeleteTokenRequest) GetId() uint64

func (*DeleteTokenRequest) ProtoMessage 

func (*DeleteTokenRequest) ProtoMessage()

func (*DeleteTokenRequest) ProtoReflect 

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

func (*DeleteTokenRequest) Reset 

func (x *DeleteTokenRequest) Reset()

func (*DeleteTokenRequest) String 

func (x *DeleteTokenRequest) String() string

type DeleteUserResponse 

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

func (*DeleteUserResponse) Descriptor deprecated 

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

Deprecated: Use DeleteUserResponse.ProtoReflect.Descriptor instead.

func (*DeleteUserResponse) GetIdentifier 

func (x *DeleteUserResponse) GetIdentifier() string

func (*DeleteUserResponse) ProtoMessage 

func (*DeleteUserResponse) ProtoMessage()

func (*DeleteUserResponse) ProtoReflect 

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

func (*DeleteUserResponse) Reset 

func (x *DeleteUserResponse) Reset()

func (*DeleteUserResponse) String 

func (x *DeleteUserResponse) String() string

type DisableSubscriptionRequest 

type DisableSubscriptionRequest struct {
	Id            uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Declaratively bool   `protobuf:"varint,2,opt,name=declaratively,proto3" json:"declaratively,omitempty"`
	// contains filtered or unexported fields
}

func (*DisableSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use DisableSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*DisableSubscriptionRequest) GetDeclaratively 

func (x *DisableSubscriptionRequest) GetDeclaratively() bool

func (*DisableSubscriptionRequest) GetId 

func (x *DisableSubscriptionRequest) GetId() uint64

func (*DisableSubscriptionRequest) ProtoMessage 

func (*DisableSubscriptionRequest) ProtoMessage()

func (*DisableSubscriptionRequest) ProtoReflect 

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

func (*DisableSubscriptionRequest) Reset 

func (x *DisableSubscriptionRequest) Reset()

func (*DisableSubscriptionRequest) String 

func (x *DisableSubscriptionRequest) String() string

type EventbusControllerClient 

type EventbusControllerClient interface {
	// grpc -> HTTP
	CreateEventbus(ctx context.Context, in *CreateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)
	CreateSystemEventbus(ctx context.Context, in *CreateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)
	DeleteEventbus(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetEventbus(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*meta.Eventbus, error)
	ListEventbus(ctx context.Context, in *ListEventbusRequest, opts ...grpc.CallOption) (*ListEventbusResponse, error)
	UpdateEventbus(ctx context.Context, in *UpdateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)
	GetEventbusWithHumanFriendly(ctx context.Context, in *GetEventbusWithHumanFriendlyRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)
}

EventbusControllerClient is the client API for EventbusController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEventbusControllerClient 

func NewEventbusControllerClient(cc grpc.ClientConnInterface) EventbusControllerClient

type EventbusControllerServer 

type EventbusControllerServer interface {
	// grpc -> HTTP
	CreateEventbus(context.Context, *CreateEventbusRequest) (*meta.Eventbus, error)
	CreateSystemEventbus(context.Context, *CreateEventbusRequest) (*meta.Eventbus, error)
	DeleteEventbus(context.Context, *wrapperspb.UInt64Value) (*emptypb.Empty, error)
	GetEventbus(context.Context, *wrapperspb.UInt64Value) (*meta.Eventbus, error)
	ListEventbus(context.Context, *ListEventbusRequest) (*ListEventbusResponse, error)
	UpdateEventbus(context.Context, *UpdateEventbusRequest) (*meta.Eventbus, error)
	GetEventbusWithHumanFriendly(context.Context, *GetEventbusWithHumanFriendlyRequest) (*meta.Eventbus, error)
}

EventbusControllerServer is the server API for EventbusController service. All implementations should embed UnimplementedEventbusControllerServer for forward compatibility

type EventlogControllerClient 

type EventlogControllerClient interface {
	ListSegment(ctx context.Context, in *ListSegmentRequest, opts ...grpc.CallOption) (*ListSegmentResponse, error)
	GetAppendableSegment(ctx context.Context, in *GetAppendableSegmentRequest, opts ...grpc.CallOption) (*GetAppendableSegmentResponse, error)
}

EventlogControllerClient is the client API for EventlogController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEventlogControllerClient 

func NewEventlogControllerClient(cc grpc.ClientConnInterface) EventlogControllerClient

type EventlogControllerServer 

type EventlogControllerServer interface {
	ListSegment(context.Context, *ListSegmentRequest) (*ListSegmentResponse, error)
	GetAppendableSegment(context.Context, *GetAppendableSegmentRequest) (*GetAppendableSegmentResponse, error)
}

EventlogControllerServer is the server API for EventlogController service. All implementations should embed UnimplementedEventlogControllerServer for forward compatibility

type GetAppendableSegmentRequest 

type GetAppendableSegmentRequest struct {
	EventbusId uint64 `protobuf:"varint,1,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	EventlogId uint64 `protobuf:"varint,2,opt,name=eventlog_id,json=eventlogId,proto3" json:"eventlog_id,omitempty"`
	// max returned segment number, default is 2
	Limited int32 `protobuf:"varint,3,opt,name=limited,proto3" json:"limited,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAppendableSegmentRequest) Descriptor deprecated 

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

Deprecated: Use GetAppendableSegmentRequest.ProtoReflect.Descriptor instead.

func (*GetAppendableSegmentRequest) GetEventbusId 

func (x *GetAppendableSegmentRequest) GetEventbusId() uint64

func (*GetAppendableSegmentRequest) GetEventlogId 

func (x *GetAppendableSegmentRequest) GetEventlogId() uint64

func (*GetAppendableSegmentRequest) GetLimited 

func (x *GetAppendableSegmentRequest) GetLimited() int32

func (*GetAppendableSegmentRequest) ProtoMessage 

func (*GetAppendableSegmentRequest) ProtoMessage()

func (*GetAppendableSegmentRequest) ProtoReflect 

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

func (*GetAppendableSegmentRequest) Reset 

func (x *GetAppendableSegmentRequest) Reset()

func (*GetAppendableSegmentRequest) String 

func (x *GetAppendableSegmentRequest) String() string

type GetAppendableSegmentResponse 

type GetAppendableSegmentResponse struct {
	Segments []*meta.Segment `protobuf:"bytes,3,rep,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAppendableSegmentResponse) Descriptor deprecated 

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

Deprecated: Use GetAppendableSegmentResponse.ProtoReflect.Descriptor instead.

func (*GetAppendableSegmentResponse) GetSegments 

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

func (*GetAppendableSegmentResponse) ProtoMessage 

func (*GetAppendableSegmentResponse) ProtoMessage()

func (*GetAppendableSegmentResponse) ProtoReflect 

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

func (*GetAppendableSegmentResponse) Reset 

func (x *GetAppendableSegmentResponse) Reset()

func (*GetAppendableSegmentResponse) String 

func (x *GetAppendableSegmentResponse) String() string

type GetDeadLetterEventOffsetRequest 

type GetDeadLetterEventOffsetRequest struct {
	SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeadLetterEventOffsetRequest) Descriptor deprecated 

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

Deprecated: Use GetDeadLetterEventOffsetRequest.ProtoReflect.Descriptor instead.

func (*GetDeadLetterEventOffsetRequest) GetSubscriptionId 

func (x *GetDeadLetterEventOffsetRequest) GetSubscriptionId() uint64

func (*GetDeadLetterEventOffsetRequest) ProtoMessage 

func (*GetDeadLetterEventOffsetRequest) ProtoMessage()

func (*GetDeadLetterEventOffsetRequest) ProtoReflect 

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

func (*GetDeadLetterEventOffsetRequest) Reset 

func (x *GetDeadLetterEventOffsetRequest) Reset()

func (*GetDeadLetterEventOffsetRequest) String 

func (x *GetDeadLetterEventOffsetRequest) String() string

type GetDeadLetterEventOffsetResponse 

type GetDeadLetterEventOffsetResponse struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeadLetterEventOffsetResponse) Descriptor deprecated 

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

Deprecated: Use GetDeadLetterEventOffsetResponse.ProtoReflect.Descriptor instead.

func (*GetDeadLetterEventOffsetResponse) GetOffset 

func (x *GetDeadLetterEventOffsetResponse) GetOffset() uint64

func (*GetDeadLetterEventOffsetResponse) ProtoMessage 

func (*GetDeadLetterEventOffsetResponse) ProtoMessage()

func (*GetDeadLetterEventOffsetResponse) ProtoReflect 

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

func (*GetDeadLetterEventOffsetResponse) Reset 

func (x *GetDeadLetterEventOffsetResponse) Reset()

func (*GetDeadLetterEventOffsetResponse) String 

func (x *GetDeadLetterEventOffsetResponse) String() string

type GetEventbusWithHumanFriendlyRequest 

type GetEventbusWithHumanFriendlyRequest struct {
	NamespaceId  uint64 `protobuf:"varint,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	EventbusName string `protobuf:"bytes,2,opt,name=eventbus_name,json=eventbusName,proto3" json:"eventbus_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventbusWithHumanFriendlyRequest) Descriptor deprecated 

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

Deprecated: Use GetEventbusWithHumanFriendlyRequest.ProtoReflect.Descriptor instead.

func (*GetEventbusWithHumanFriendlyRequest) GetEventbusName 

func (x *GetEventbusWithHumanFriendlyRequest) GetEventbusName() string

func (*GetEventbusWithHumanFriendlyRequest) GetNamespaceId 

func (x *GetEventbusWithHumanFriendlyRequest) GetNamespaceId() uint64

func (*GetEventbusWithHumanFriendlyRequest) ProtoMessage 

func (*GetEventbusWithHumanFriendlyRequest) ProtoMessage()

func (*GetEventbusWithHumanFriendlyRequest) ProtoReflect 

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

func (*GetEventbusWithHumanFriendlyRequest) Reset 

func (x *GetEventbusWithHumanFriendlyRequest) Reset()

func (*GetEventbusWithHumanFriendlyRequest) String 

func (x *GetEventbusWithHumanFriendlyRequest) String() string

type GetNamespaceRequest 

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

func (*GetNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use GetNamespaceRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceRequest) GetId 

func (x *GetNamespaceRequest) GetId() uint64

func (*GetNamespaceRequest) ProtoMessage 

func (*GetNamespaceRequest) ProtoMessage()

func (*GetNamespaceRequest) ProtoReflect 

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

func (*GetNamespaceRequest) Reset 

func (x *GetNamespaceRequest) Reset()

func (*GetNamespaceRequest) String 

func (x *GetNamespaceRequest) String() string

type GetResourceRoleRequest 

type GetResourceRoleRequest struct {
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResourceRoleRequest) Descriptor deprecated 

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

Deprecated: Use GetResourceRoleRequest.ProtoReflect.Descriptor instead.

func (*GetResourceRoleRequest) GetId 

func (x *GetResourceRoleRequest) GetId() uint64

func (*GetResourceRoleRequest) GetKind 

func (x *GetResourceRoleRequest) GetKind() string

func (*GetResourceRoleRequest) ProtoMessage 

func (*GetResourceRoleRequest) ProtoMessage()

func (*GetResourceRoleRequest) ProtoReflect 

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

func (*GetResourceRoleRequest) Reset 

func (x *GetResourceRoleRequest) Reset()

func (*GetResourceRoleRequest) String 

func (x *GetResourceRoleRequest) String() string

type GetResourceRoleResponse 

type GetResourceRoleResponse struct {
	ResourceRole []*meta.ResourceRole `protobuf:"bytes,1,rep,name=resource_role,json=resourceRole,proto3" json:"resource_role,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResourceRoleResponse) Descriptor deprecated 

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

Deprecated: Use GetResourceRoleResponse.ProtoReflect.Descriptor instead.

func (*GetResourceRoleResponse) GetResourceRole 

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

func (*GetResourceRoleResponse) ProtoMessage 

func (*GetResourceRoleResponse) ProtoMessage()

func (*GetResourceRoleResponse) ProtoReflect 

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

func (*GetResourceRoleResponse) Reset 

func (x *GetResourceRoleResponse) Reset()

func (*GetResourceRoleResponse) String 

func (x *GetResourceRoleResponse) String() string

type GetSubscriptionRequest 

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

func (*GetSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use GetSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*GetSubscriptionRequest) GetId 

func (x *GetSubscriptionRequest) GetId() uint64

func (*GetSubscriptionRequest) ProtoMessage 

func (*GetSubscriptionRequest) ProtoMessage()

func (*GetSubscriptionRequest) ProtoReflect 

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

func (*GetSubscriptionRequest) Reset 

func (x *GetSubscriptionRequest) Reset()

func (*GetSubscriptionRequest) String 

func (x *GetSubscriptionRequest) String() string

type GetTokenResponse 

type GetTokenResponse struct {
	Token []*meta.Token `protobuf:"bytes,1,rep,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTokenResponse) Descriptor deprecated 

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

Deprecated: Use GetTokenResponse.ProtoReflect.Descriptor instead.

func (*GetTokenResponse) GetToken 

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

func (*GetTokenResponse) ProtoMessage 

func (*GetTokenResponse) ProtoMessage()

func (*GetTokenResponse) ProtoReflect 

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

func (*GetTokenResponse) Reset 

func (x *GetTokenResponse) Reset()

func (*GetTokenResponse) String 

func (x *GetTokenResponse) String() string

type GetUserRoleRequest 

type GetUserRoleRequest struct {
	UserIdentifier string `protobuf:"bytes,1,opt,name=user_identifier,json=userIdentifier,proto3" json:"user_identifier,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserRoleRequest) Descriptor deprecated 

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

Deprecated: Use GetUserRoleRequest.ProtoReflect.Descriptor instead.

func (*GetUserRoleRequest) GetUserIdentifier 

func (x *GetUserRoleRequest) GetUserIdentifier() string

func (*GetUserRoleRequest) ProtoMessage 

func (*GetUserRoleRequest) ProtoMessage()

func (*GetUserRoleRequest) ProtoReflect 

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

func (*GetUserRoleRequest) Reset 

func (x *GetUserRoleRequest) Reset()

func (*GetUserRoleRequest) String 

func (x *GetUserRoleRequest) String() string

type GetUserRoleResponse 

type GetUserRoleResponse struct {
	UserRole []*meta.UserRole `protobuf:"bytes,1,rep,name=user_role,json=userRole,proto3" json:"user_role,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserRoleResponse) Descriptor deprecated 

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

Deprecated: Use GetUserRoleResponse.ProtoReflect.Descriptor instead.

func (*GetUserRoleResponse) GetUserRole 

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

func (*GetUserRoleResponse) ProtoMessage 

func (*GetUserRoleResponse) ProtoMessage()

func (*GetUserRoleResponse) ProtoReflect 

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

func (*GetUserRoleResponse) Reset 

func (x *GetUserRoleResponse) Reset()

func (*GetUserRoleResponse) String 

func (x *GetUserRoleResponse) String() string

type ListEventbusRequest 

type ListEventbusRequest struct {
	NamespaceId uint64 `protobuf:"varint,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEventbusRequest) Descriptor deprecated 

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

Deprecated: Use ListEventbusRequest.ProtoReflect.Descriptor instead.

func (*ListEventbusRequest) GetNamespaceId 

func (x *ListEventbusRequest) GetNamespaceId() uint64

func (*ListEventbusRequest) ProtoMessage 

func (*ListEventbusRequest) ProtoMessage()

func (*ListEventbusRequest) ProtoReflect 

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

func (*ListEventbusRequest) Reset 

func (x *ListEventbusRequest) Reset()

func (*ListEventbusRequest) String 

func (x *ListEventbusRequest) String() string

type ListEventbusResponse 

type ListEventbusResponse struct {
	Eventbus []*meta.Eventbus `protobuf:"bytes,1,rep,name=eventbus,proto3" json:"eventbus,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEventbusResponse) Descriptor deprecated 

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

Deprecated: Use ListEventbusResponse.ProtoReflect.Descriptor instead.

func (*ListEventbusResponse) GetEventbus 

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

func (*ListEventbusResponse) ProtoMessage 

func (*ListEventbusResponse) ProtoMessage()

func (*ListEventbusResponse) ProtoReflect 

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

func (*ListEventbusResponse) Reset 

func (x *ListEventbusResponse) Reset()

func (*ListEventbusResponse) String 

func (x *ListEventbusResponse) String() string

type ListNamespaceResponse 

type ListNamespaceResponse struct {
	Namespace []*meta.Namespace `protobuf:"bytes,1,rep,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use ListNamespaceResponse.ProtoReflect.Descriptor instead.

func (*ListNamespaceResponse) GetNamespace 

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

func (*ListNamespaceResponse) ProtoMessage 

func (*ListNamespaceResponse) ProtoMessage()

func (*ListNamespaceResponse) ProtoReflect 

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

func (*ListNamespaceResponse) Reset 

func (x *ListNamespaceResponse) Reset()

func (*ListNamespaceResponse) String 

func (x *ListNamespaceResponse) String() string

type ListSegmentRequest 

type ListSegmentRequest struct {
	EventbusId uint64 `protobuf:"varint,1,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	EventlogId uint64 `protobuf:"varint,2,opt,name=eventlog_id,json=eventlogId,proto3" json:"eventlog_id,omitempty"`
	// if a segment has the range [a, b), if a <= start_offset < b, the segment
	// will be returned
	StartOffset int64 `protobuf:"varint,3,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	// if a segment has the range [c, d), if end_offset = c, the segment will not
	// be returned
	EndOffset int64 `protobuf:"varint,4,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	// max returned segment number, default is 16
	Limited int32 `protobuf:"varint,5,opt,name=limited,proto3" json:"limited,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSegmentRequest) Descriptor deprecated 

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

Deprecated: Use ListSegmentRequest.ProtoReflect.Descriptor instead.

func (*ListSegmentRequest) GetEndOffset 

func (x *ListSegmentRequest) GetEndOffset() int64

func (*ListSegmentRequest) GetEventbusId 

func (x *ListSegmentRequest) GetEventbusId() uint64

func (*ListSegmentRequest) GetEventlogId 

func (x *ListSegmentRequest) GetEventlogId() uint64

func (*ListSegmentRequest) GetLimited 

func (x *ListSegmentRequest) GetLimited() int32

func (*ListSegmentRequest) GetStartOffset 

func (x *ListSegmentRequest) GetStartOffset() int64

func (*ListSegmentRequest) ProtoMessage 

func (*ListSegmentRequest) ProtoMessage()

func (*ListSegmentRequest) ProtoReflect 

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

func (*ListSegmentRequest) Reset 

func (x *ListSegmentRequest) Reset()

func (*ListSegmentRequest) String 

func (x *ListSegmentRequest) String() string

type ListSegmentResponse 

type ListSegmentResponse struct {
	Segments []*meta.Segment `protobuf:"bytes,1,rep,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSegmentResponse) Descriptor deprecated 

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

Deprecated: Use ListSegmentResponse.ProtoReflect.Descriptor instead.

func (*ListSegmentResponse) GetSegments 

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

func (*ListSegmentResponse) ProtoMessage 

func (*ListSegmentResponse) ProtoMessage()

func (*ListSegmentResponse) ProtoReflect 

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

func (*ListSegmentResponse) Reset 

func (x *ListSegmentResponse) Reset()

func (*ListSegmentResponse) String 

func (x *ListSegmentResponse) String() string

type ListSubscriptionRequest 

type ListSubscriptionRequest struct {
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	EventbusId  uint64 `protobuf:"varint,3,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	NamespaceId uint64 `protobuf:"varint,4,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use ListSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*ListSubscriptionRequest) GetEventbusId 

func (x *ListSubscriptionRequest) GetEventbusId() uint64

func (*ListSubscriptionRequest) GetName 

func (x *ListSubscriptionRequest) GetName() string

func (*ListSubscriptionRequest) GetNamespaceId 

func (x *ListSubscriptionRequest) GetNamespaceId() uint64

func (*ListSubscriptionRequest) ProtoMessage 

func (*ListSubscriptionRequest) ProtoMessage()

func (*ListSubscriptionRequest) ProtoReflect 

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

func (*ListSubscriptionRequest) Reset 

func (x *ListSubscriptionRequest) Reset()

func (*ListSubscriptionRequest) String 

func (x *ListSubscriptionRequest) String() string

type ListSubscriptionResponse 

type ListSubscriptionResponse struct {
	Subscription []*meta.Subscription `protobuf:"bytes,1,rep,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use ListSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*ListSubscriptionResponse) GetSubscription 

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

func (*ListSubscriptionResponse) ProtoMessage 

func (*ListSubscriptionResponse) ProtoMessage()

func (*ListSubscriptionResponse) ProtoReflect 

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

func (*ListSubscriptionResponse) Reset 

func (x *ListSubscriptionResponse) Reset()

func (*ListSubscriptionResponse) String 

func (x *ListSubscriptionResponse) String() string

type ListTokenResponse 

type ListTokenResponse struct {
	Token []*meta.Token `protobuf:"bytes,1,rep,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTokenResponse) Descriptor deprecated 

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

Deprecated: Use ListTokenResponse.ProtoReflect.Descriptor instead.

func (*ListTokenResponse) GetToken 

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

func (*ListTokenResponse) ProtoMessage 

func (*ListTokenResponse) ProtoMessage()

func (*ListTokenResponse) ProtoReflect 

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

func (*ListTokenResponse) Reset 

func (x *ListTokenResponse) Reset()

func (*ListTokenResponse) String 

func (x *ListTokenResponse) String() string

type ListUserResponse 

type ListUserResponse struct {
	Users []*meta.User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

func (*ListUserResponse) Descriptor deprecated 

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

Deprecated: Use ListUserResponse.ProtoReflect.Descriptor instead.

func (*ListUserResponse) GetUsers 

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

func (*ListUserResponse) ProtoMessage 

func (*ListUserResponse) ProtoMessage()

func (*ListUserResponse) ProtoReflect 

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

func (*ListUserResponse) Reset 

func (x *ListUserResponse) Reset()

func (*ListUserResponse) String 

func (x *ListUserResponse) String() string

type MockAuthControllerClient 

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

MockAuthControllerClient is a mock of AuthControllerClient interface.

func NewMockAuthControllerClient 

func NewMockAuthControllerClient(ctrl *gomock.Controller) *MockAuthControllerClient

NewMockAuthControllerClient creates a new mock instance.

func (*MockAuthControllerClient) CreateToken 

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

CreateToken mocks base method.

func (*MockAuthControllerClient) CreateUser 

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

CreateUser mocks base method.

func (*MockAuthControllerClient) DeleteToken 

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

DeleteToken mocks base method.

func (*MockAuthControllerClient) DeleteUser 

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

DeleteUser mocks base method.

func (*MockAuthControllerClient) EXPECT 

func (m *MockAuthControllerClient) EXPECT() *MockAuthControllerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAuthControllerClient) GetResourceRole 

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

GetResourceRole mocks base method.

func (*MockAuthControllerClient) GetToken 

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

GetToken mocks base method.

func (*MockAuthControllerClient) GetUser 

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

GetUser mocks base method.

func (*MockAuthControllerClient) GetUserByToken 

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

GetUserByToken mocks base method.

func (*MockAuthControllerClient) GetUserRole 

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

GetUserRole mocks base method.

func (*MockAuthControllerClient) GetUserToken 

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

GetUserToken mocks base method.

func (*MockAuthControllerClient) GrantRole 

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

GrantRole mocks base method.

func (*MockAuthControllerClient) ListToken 

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

ListToken mocks base method.

func (*MockAuthControllerClient) ListUser 

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

ListUser mocks base method.

func (*MockAuthControllerClient) RevokeRole 

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

RevokeRole mocks base method.

type MockAuthControllerClientMockRecorder 

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

MockAuthControllerClientMockRecorder is the mock recorder for MockAuthControllerClient.

func (*MockAuthControllerClientMockRecorder) CreateToken 

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

CreateToken indicates an expected call of CreateToken.

func (*MockAuthControllerClientMockRecorder) CreateUser 

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

CreateUser indicates an expected call of CreateUser.

func (*MockAuthControllerClientMockRecorder) DeleteToken 

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

DeleteToken indicates an expected call of DeleteToken.

func (*MockAuthControllerClientMockRecorder) DeleteUser 

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

DeleteUser indicates an expected call of DeleteUser.

func (*MockAuthControllerClientMockRecorder) GetResourceRole 

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

GetResourceRole indicates an expected call of GetResourceRole.

func (*MockAuthControllerClientMockRecorder) GetToken 

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

GetToken indicates an expected call of GetToken.

func (*MockAuthControllerClientMockRecorder) GetUser 

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

GetUser indicates an expected call of GetUser.

func (*MockAuthControllerClientMockRecorder) GetUserByToken 

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

GetUserByToken indicates an expected call of GetUserByToken.

func (*MockAuthControllerClientMockRecorder) GetUserRole 

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

GetUserRole indicates an expected call of GetUserRole.

func (*MockAuthControllerClientMockRecorder) GetUserToken 

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

GetUserToken indicates an expected call of GetUserToken.

func (*MockAuthControllerClientMockRecorder) GrantRole 

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

GrantRole indicates an expected call of GrantRole.

func (*MockAuthControllerClientMockRecorder) ListToken 

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

ListToken indicates an expected call of ListToken.

func (*MockAuthControllerClientMockRecorder) ListUser 

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

ListUser indicates an expected call of ListUser.

func (*MockAuthControllerClientMockRecorder) RevokeRole 

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

RevokeRole indicates an expected call of RevokeRole.

type MockAuthControllerServer 

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

MockAuthControllerServer is a mock of AuthControllerServer interface.

func NewMockAuthControllerServer 

func NewMockAuthControllerServer(ctrl *gomock.Controller) *MockAuthControllerServer

NewMockAuthControllerServer creates a new mock instance.

func (*MockAuthControllerServer) CreateToken 

func (m *MockAuthControllerServer) CreateToken(ctx context.Context, in *CreateTokenRequest) (*meta.Token, error)

CreateToken mocks base method.

func (*MockAuthControllerServer) CreateUser 

func (m *MockAuthControllerServer) CreateUser(ctx context.Context, in *CreateUserRequest) (*meta.User, error)

CreateUser mocks base method.

func (*MockAuthControllerServer) DeleteToken 

func (m *MockAuthControllerServer) DeleteToken(ctx context.Context, in *DeleteTokenRequest) (*emptypb.Empty, error)

DeleteToken mocks base method.

func (*MockAuthControllerServer) DeleteUser 

func (m *MockAuthControllerServer) DeleteUser(ctx context.Context, in *wrapperspb.StringValue) (*emptypb.Empty, error)

DeleteUser mocks base method.

func (*MockAuthControllerServer) EXPECT 

func (m *MockAuthControllerServer) EXPECT() *MockAuthControllerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAuthControllerServer) GetResourceRole 

func (m *MockAuthControllerServer) GetResourceRole(ctx context.Context, in *GetResourceRoleRequest) (*GetResourceRoleResponse, error)

GetResourceRole mocks base method.

func (*MockAuthControllerServer) GetToken 

func (m *MockAuthControllerServer) GetToken(ctx context.Context, in *wrapperspb.UInt64Value) (*meta.Token, error)

GetToken mocks base method.

func (*MockAuthControllerServer) GetUser 

func (m *MockAuthControllerServer) GetUser(ctx context.Context, in *wrapperspb.StringValue) (*meta.User, error)

GetUser mocks base method.

func (*MockAuthControllerServer) GetUserByToken 

func (m *MockAuthControllerServer) GetUserByToken(ctx context.Context, in *wrapperspb.StringValue) (*wrapperspb.StringValue, error)

GetUserByToken mocks base method.

func (*MockAuthControllerServer) GetUserRole 

func (m *MockAuthControllerServer) GetUserRole(ctx context.Context, in *GetUserRoleRequest) (*GetUserRoleResponse, error)

GetUserRole mocks base method.

func (*MockAuthControllerServer) GetUserToken 

func (m *MockAuthControllerServer) GetUserToken(ctx context.Context, in *wrapperspb.StringValue) (*GetTokenResponse, error)

GetUserToken mocks base method.

func (*MockAuthControllerServer) GrantRole 

func (m *MockAuthControllerServer) GrantRole(ctx context.Context, in *RoleRequest) (*emptypb.Empty, error)

GrantRole mocks base method.

func (*MockAuthControllerServer) ListToken 

func (m *MockAuthControllerServer) ListToken(ctx context.Context, in *emptypb.Empty) (*ListTokenResponse, error)

ListToken mocks base method.

func (*MockAuthControllerServer) ListUser 

func (m *MockAuthControllerServer) ListUser(ctx context.Context, in *emptypb.Empty) (*ListUserResponse, error)

ListUser mocks base method.

func (*MockAuthControllerServer) RevokeRole 

func (m *MockAuthControllerServer) RevokeRole(ctx context.Context, in *RoleRequest) (*emptypb.Empty, error)

RevokeRole mocks base method.

type MockAuthControllerServerMockRecorder 

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

MockAuthControllerServerMockRecorder is the mock recorder for MockAuthControllerServer.

func (*MockAuthControllerServerMockRecorder) CreateToken 

func (mr *MockAuthControllerServerMockRecorder) CreateToken(ctx, in interface{}) *gomock.Call

CreateToken indicates an expected call of CreateToken.

func (*MockAuthControllerServerMockRecorder) CreateUser 

func (mr *MockAuthControllerServerMockRecorder) CreateUser(ctx, in interface{}) *gomock.Call

CreateUser indicates an expected call of CreateUser.

func (*MockAuthControllerServerMockRecorder) DeleteToken 

func (mr *MockAuthControllerServerMockRecorder) DeleteToken(ctx, in interface{}) *gomock.Call

DeleteToken indicates an expected call of DeleteToken.

func (*MockAuthControllerServerMockRecorder) DeleteUser 

func (mr *MockAuthControllerServerMockRecorder) DeleteUser(ctx, in interface{}) *gomock.Call

DeleteUser indicates an expected call of DeleteUser.

func (*MockAuthControllerServerMockRecorder) GetResourceRole 

func (mr *MockAuthControllerServerMockRecorder) GetResourceRole(ctx, in interface{}) *gomock.Call

GetResourceRole indicates an expected call of GetResourceRole.

func (*MockAuthControllerServerMockRecorder) GetToken 

func (mr *MockAuthControllerServerMockRecorder) GetToken(ctx, in interface{}) *gomock.Call

GetToken indicates an expected call of GetToken.

func (*MockAuthControllerServerMockRecorder) GetUser 

func (mr *MockAuthControllerServerMockRecorder) GetUser(ctx, in interface{}) *gomock.Call

GetUser indicates an expected call of GetUser.

func (*MockAuthControllerServerMockRecorder) GetUserByToken 

func (mr *MockAuthControllerServerMockRecorder) GetUserByToken(ctx, in interface{}) *gomock.Call

GetUserByToken indicates an expected call of GetUserByToken.

func (*MockAuthControllerServerMockRecorder) GetUserRole 

func (mr *MockAuthControllerServerMockRecorder) GetUserRole(ctx, in interface{}) *gomock.Call

GetUserRole indicates an expected call of GetUserRole.

func (*MockAuthControllerServerMockRecorder) GetUserToken 

func (mr *MockAuthControllerServerMockRecorder) GetUserToken(ctx, in interface{}) *gomock.Call

GetUserToken indicates an expected call of GetUserToken.

func (*MockAuthControllerServerMockRecorder) GrantRole 

func (mr *MockAuthControllerServerMockRecorder) GrantRole(ctx, in interface{}) *gomock.Call

GrantRole indicates an expected call of GrantRole.

func (*MockAuthControllerServerMockRecorder) ListToken 

func (mr *MockAuthControllerServerMockRecorder) ListToken(ctx, in interface{}) *gomock.Call

ListToken indicates an expected call of ListToken.

func (*MockAuthControllerServerMockRecorder) ListUser 

func (mr *MockAuthControllerServerMockRecorder) ListUser(ctx, in interface{}) *gomock.Call

ListUser indicates an expected call of ListUser.

func (*MockAuthControllerServerMockRecorder) RevokeRole 

func (mr *MockAuthControllerServerMockRecorder) RevokeRole(ctx, in interface{}) *gomock.Call

RevokeRole indicates an expected call of RevokeRole.

type MockEventbusControllerClient 

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

MockEventbusControllerClient is a mock of EventbusControllerClient interface.

func NewMockEventbusControllerClient 

func NewMockEventbusControllerClient(ctrl *gomock.Controller) *MockEventbusControllerClient

NewMockEventbusControllerClient creates a new mock instance.

func (*MockEventbusControllerClient) CreateEventbus 

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

CreateEventbus mocks base method.

func (*MockEventbusControllerClient) CreateSystemEventbus 

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

CreateSystemEventbus mocks base method.

func (*MockEventbusControllerClient) DeleteEventbus 

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

DeleteEventbus mocks base method.

func (*MockEventbusControllerClient) EXPECT 

func (m *MockEventbusControllerClient) EXPECT() *MockEventbusControllerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEventbusControllerClient) GetEventbus 

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

GetEventbus mocks base method.

func (*MockEventbusControllerClient) GetEventbusWithHumanFriendly 

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

GetEventbusWithHumanFriendly mocks base method.

func (*MockEventbusControllerClient) ListEventbus 

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

ListEventbus mocks base method.

func (*MockEventbusControllerClient) UpdateEventbus 

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

UpdateEventbus mocks base method.

type MockEventbusControllerClientMockRecorder 

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

MockEventbusControllerClientMockRecorder is the mock recorder for MockEventbusControllerClient.

func (*MockEventbusControllerClientMockRecorder) CreateEventbus 

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

CreateEventbus indicates an expected call of CreateEventbus.

func (*MockEventbusControllerClientMockRecorder) CreateSystemEventbus 

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

CreateSystemEventbus indicates an expected call of CreateSystemEventbus.

func (*MockEventbusControllerClientMockRecorder) DeleteEventbus 

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

DeleteEventbus indicates an expected call of DeleteEventbus.

func (*MockEventbusControllerClientMockRecorder) GetEventbus 

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

GetEventbus indicates an expected call of GetEventbus.

func (*MockEventbusControllerClientMockRecorder) GetEventbusWithHumanFriendly 

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

GetEventbusWithHumanFriendly indicates an expected call of GetEventbusWithHumanFriendly.

func (*MockEventbusControllerClientMockRecorder) ListEventbus 

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

ListEventbus indicates an expected call of ListEventbus.

func (*MockEventbusControllerClientMockRecorder) UpdateEventbus 

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

UpdateEventbus indicates an expected call of UpdateEventbus.

type MockEventbusControllerServer 

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

MockEventbusControllerServer is a mock of EventbusControllerServer interface.

func NewMockEventbusControllerServer 

func NewMockEventbusControllerServer(ctrl *gomock.Controller) *MockEventbusControllerServer

NewMockEventbusControllerServer creates a new mock instance.

func (*MockEventbusControllerServer) CreateEventbus 

func (m *MockEventbusControllerServer) CreateEventbus(ctx context.Context, in *CreateEventbusRequest) (*meta.Eventbus, error)

CreateEventbus mocks base method.

func (*MockEventbusControllerServer) CreateSystemEventbus 

func (m *MockEventbusControllerServer) CreateSystemEventbus(ctx context.Context, in *CreateEventbusRequest) (*meta.Eventbus, error)

CreateSystemEventbus mocks base method.

func (*MockEventbusControllerServer) DeleteEventbus 

func (m *MockEventbusControllerServer) DeleteEventbus(ctx context.Context, in *wrapperspb.UInt64Value) (*emptypb.Empty, error)

DeleteEventbus mocks base method.

func (*MockEventbusControllerServer) EXPECT 

func (m *MockEventbusControllerServer) EXPECT() *MockEventbusControllerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEventbusControllerServer) GetEventbus 

func (m *MockEventbusControllerServer) GetEventbus(ctx context.Context, in *wrapperspb.UInt64Value) (*meta.Eventbus, error)

GetEventbus mocks base method.

func (*MockEventbusControllerServer) GetEventbusWithHumanFriendly 

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

GetEventbusWithHumanFriendly mocks base method.

func (*MockEventbusControllerServer) ListEventbus 

func (m *MockEventbusControllerServer) ListEventbus(ctx context.Context, in *ListEventbusRequest) (*ListEventbusResponse, error)

ListEventbus mocks base method.

func (*MockEventbusControllerServer) UpdateEventbus 

func (m *MockEventbusControllerServer) UpdateEventbus(ctx context.Context, in *UpdateEventbusRequest) (*meta.Eventbus, error)

UpdateEventbus mocks base method.

type MockEventbusControllerServerMockRecorder 

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

MockEventbusControllerServerMockRecorder is the mock recorder for MockEventbusControllerServer.

func (*MockEventbusControllerServerMockRecorder) CreateEventbus 

func (mr *MockEventbusControllerServerMockRecorder) CreateEventbus(ctx, in interface{}) *gomock.Call

CreateEventbus indicates an expected call of CreateEventbus.

func (*MockEventbusControllerServerMockRecorder) CreateSystemEventbus 

func (mr *MockEventbusControllerServerMockRecorder) CreateSystemEventbus(ctx, in interface{}) *gomock.Call

CreateSystemEventbus indicates an expected call of CreateSystemEventbus.

func (*MockEventbusControllerServerMockRecorder) DeleteEventbus 

func (mr *MockEventbusControllerServerMockRecorder) DeleteEventbus(ctx, in interface{}) *gomock.Call

DeleteEventbus indicates an expected call of DeleteEventbus.

func (*MockEventbusControllerServerMockRecorder) GetEventbus 

func (mr *MockEventbusControllerServerMockRecorder) GetEventbus(ctx, in interface{}) *gomock.Call

GetEventbus indicates an expected call of GetEventbus.

func (*MockEventbusControllerServerMockRecorder) GetEventbusWithHumanFriendly 

func (mr *MockEventbusControllerServerMockRecorder) GetEventbusWithHumanFriendly(ctx, in interface{}) *gomock.Call

GetEventbusWithHumanFriendly indicates an expected call of GetEventbusWithHumanFriendly.

func (*MockEventbusControllerServerMockRecorder) ListEventbus 

func (mr *MockEventbusControllerServerMockRecorder) ListEventbus(ctx, in interface{}) *gomock.Call

ListEventbus indicates an expected call of ListEventbus.

func (*MockEventbusControllerServerMockRecorder) UpdateEventbus 

func (mr *MockEventbusControllerServerMockRecorder) UpdateEventbus(ctx, in interface{}) *gomock.Call

UpdateEventbus indicates an expected call of UpdateEventbus.

type MockEventlogControllerClient 

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

MockEventlogControllerClient is a mock of EventlogControllerClient interface.

func NewMockEventlogControllerClient 

func NewMockEventlogControllerClient(ctrl *gomock.Controller) *MockEventlogControllerClient

NewMockEventlogControllerClient creates a new mock instance.

func (*MockEventlogControllerClient) EXPECT 

func (m *MockEventlogControllerClient) EXPECT() *MockEventlogControllerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEventlogControllerClient) GetAppendableSegment 

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

GetAppendableSegment mocks base method.

func (*MockEventlogControllerClient) ListSegment 

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

ListSegment mocks base method.

type MockEventlogControllerClientMockRecorder 

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

MockEventlogControllerClientMockRecorder is the mock recorder for MockEventlogControllerClient.

func (*MockEventlogControllerClientMockRecorder) GetAppendableSegment 

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

GetAppendableSegment indicates an expected call of GetAppendableSegment.

func (*MockEventlogControllerClientMockRecorder) ListSegment 

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

ListSegment indicates an expected call of ListSegment.

type MockEventlogControllerServer 

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

MockEventlogControllerServer is a mock of EventlogControllerServer interface.

func NewMockEventlogControllerServer 

func NewMockEventlogControllerServer(ctrl *gomock.Controller) *MockEventlogControllerServer

NewMockEventlogControllerServer creates a new mock instance.

func (*MockEventlogControllerServer) EXPECT 

func (m *MockEventlogControllerServer) EXPECT() *MockEventlogControllerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEventlogControllerServer) GetAppendableSegment 

func (m *MockEventlogControllerServer) GetAppendableSegment(ctx context.Context, in *GetAppendableSegmentRequest) (*GetAppendableSegmentResponse, error)

GetAppendableSegment mocks base method.

func (*MockEventlogControllerServer) ListSegment 

func (m *MockEventlogControllerServer) ListSegment(ctx context.Context, in *ListSegmentRequest) (*ListSegmentResponse, error)

ListSegment mocks base method.

type MockEventlogControllerServerMockRecorder 

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

MockEventlogControllerServerMockRecorder is the mock recorder for MockEventlogControllerServer.

func (*MockEventlogControllerServerMockRecorder) GetAppendableSegment 

func (mr *MockEventlogControllerServerMockRecorder) GetAppendableSegment(ctx, in interface{}) *gomock.Call

GetAppendableSegment indicates an expected call of GetAppendableSegment.

func (*MockEventlogControllerServerMockRecorder) ListSegment 

func (mr *MockEventlogControllerServerMockRecorder) ListSegment(ctx, in interface{}) *gomock.Call

ListSegment indicates an expected call of ListSegment.

type MockNamespaceControllerClient 

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

MockNamespaceControllerClient is a mock of NamespaceControllerClient interface.

func NewMockNamespaceControllerClient 

func NewMockNamespaceControllerClient(ctrl *gomock.Controller) *MockNamespaceControllerClient

NewMockNamespaceControllerClient creates a new mock instance.

func (*MockNamespaceControllerClient) CreateNamespace 

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

CreateNamespace mocks base method.

func (*MockNamespaceControllerClient) DeleteNamespace 

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

DeleteNamespace mocks base method.

func (*MockNamespaceControllerClient) EXPECT 

func (m *MockNamespaceControllerClient) EXPECT() *MockNamespaceControllerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNamespaceControllerClient) GetNamespace 

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

GetNamespace mocks base method.

func (*MockNamespaceControllerClient) GetNamespaceWithHumanFriendly 

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

GetNamespaceWithHumanFriendly mocks base method.

func (*MockNamespaceControllerClient) ListNamespace 

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

ListNamespace mocks base method.

type MockNamespaceControllerClientMockRecorder 

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

MockNamespaceControllerClientMockRecorder is the mock recorder for MockNamespaceControllerClient.

func (*MockNamespaceControllerClientMockRecorder) CreateNamespace 

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

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockNamespaceControllerClientMockRecorder) DeleteNamespace 

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

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockNamespaceControllerClientMockRecorder) GetNamespace 

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

GetNamespace indicates an expected call of GetNamespace.

func (*MockNamespaceControllerClientMockRecorder) GetNamespaceWithHumanFriendly 

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

GetNamespaceWithHumanFriendly indicates an expected call of GetNamespaceWithHumanFriendly.

func (*MockNamespaceControllerClientMockRecorder) ListNamespace 

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

ListNamespace indicates an expected call of ListNamespace.

type MockNamespaceControllerServer 

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

MockNamespaceControllerServer is a mock of NamespaceControllerServer interface.

func NewMockNamespaceControllerServer 

func NewMockNamespaceControllerServer(ctrl *gomock.Controller) *MockNamespaceControllerServer

NewMockNamespaceControllerServer creates a new mock instance.

func (*MockNamespaceControllerServer) CreateNamespace 

func (m *MockNamespaceControllerServer) CreateNamespace(ctx context.Context, in *CreateNamespaceRequest) (*meta.Namespace, error)

CreateNamespace mocks base method.

func (*MockNamespaceControllerServer) DeleteNamespace 

func (m *MockNamespaceControllerServer) DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest) (*emptypb.Empty, error)

DeleteNamespace mocks base method.

func (*MockNamespaceControllerServer) EXPECT 

func (m *MockNamespaceControllerServer) EXPECT() *MockNamespaceControllerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNamespaceControllerServer) GetNamespace 

func (m *MockNamespaceControllerServer) GetNamespace(ctx context.Context, in *GetNamespaceRequest) (*meta.Namespace, error)

GetNamespace mocks base method.

func (*MockNamespaceControllerServer) GetNamespaceWithHumanFriendly 

func (m *MockNamespaceControllerServer) GetNamespaceWithHumanFriendly(ctx context.Context, in *wrapperspb.StringValue) (*meta.Namespace, error)

GetNamespaceWithHumanFriendly mocks base method.

func (*MockNamespaceControllerServer) ListNamespace 

func (m *MockNamespaceControllerServer) ListNamespace(ctx context.Context, in *emptypb.Empty) (*ListNamespaceResponse, error)

ListNamespace mocks base method.

type MockNamespaceControllerServerMockRecorder 

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

MockNamespaceControllerServerMockRecorder is the mock recorder for MockNamespaceControllerServer.

func (*MockNamespaceControllerServerMockRecorder) CreateNamespace 

func (mr *MockNamespaceControllerServerMockRecorder) CreateNamespace(ctx, in interface{}) *gomock.Call

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockNamespaceControllerServerMockRecorder) DeleteNamespace 

func (mr *MockNamespaceControllerServerMockRecorder) DeleteNamespace(ctx, in interface{}) *gomock.Call

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockNamespaceControllerServerMockRecorder) GetNamespace 

func (mr *MockNamespaceControllerServerMockRecorder) GetNamespace(ctx, in interface{}) *gomock.Call

GetNamespace indicates an expected call of GetNamespace.

func (*MockNamespaceControllerServerMockRecorder) GetNamespaceWithHumanFriendly 

func (mr *MockNamespaceControllerServerMockRecorder) GetNamespaceWithHumanFriendly(ctx, in interface{}) *gomock.Call

GetNamespaceWithHumanFriendly indicates an expected call of GetNamespaceWithHumanFriendly.

func (*MockNamespaceControllerServerMockRecorder) ListNamespace 

func (mr *MockNamespaceControllerServerMockRecorder) ListNamespace(ctx, in interface{}) *gomock.Call

ListNamespace indicates an expected call of ListNamespace.

type MockPingServerClient 

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

MockPingServerClient is a mock of PingServerClient interface.

func NewMockPingServerClient 

func NewMockPingServerClient(ctrl *gomock.Controller) *MockPingServerClient

NewMockPingServerClient creates a new mock instance.

func (*MockPingServerClient) EXPECT 

func (m *MockPingServerClient) EXPECT() *MockPingServerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPingServerClient) Ping 

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

Ping mocks base method.

type MockPingServerClientMockRecorder 

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

MockPingServerClientMockRecorder is the mock recorder for MockPingServerClient.

func (*MockPingServerClientMockRecorder) Ping 

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

Ping indicates an expected call of Ping.

type MockPingServerServer 

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

MockPingServerServer is a mock of PingServerServer interface.

func NewMockPingServerServer 

func NewMockPingServerServer(ctrl *gomock.Controller) *MockPingServerServer

NewMockPingServerServer creates a new mock instance.

func (*MockPingServerServer) EXPECT 

func (m *MockPingServerServer) EXPECT() *MockPingServerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPingServerServer) Ping 

func (m *MockPingServerServer) Ping(ctx context.Context, in *emptypb.Empty) (*PingResponse, error)

Ping mocks base method.

type MockPingServerServerMockRecorder 

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

MockPingServerServerMockRecorder is the mock recorder for MockPingServerServer.

func (*MockPingServerServerMockRecorder) Ping 

func (mr *MockPingServerServerMockRecorder) Ping(ctx, in interface{}) *gomock.Call

Ping indicates an expected call of Ping.

type MockSegmentControllerClient 

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

MockSegmentControllerClient is a mock of SegmentControllerClient interface.

func NewMockSegmentControllerClient 

func NewMockSegmentControllerClient(ctrl *gomock.Controller) *MockSegmentControllerClient

NewMockSegmentControllerClient creates a new mock instance.

func (*MockSegmentControllerClient) EXPECT 

func (m *MockSegmentControllerClient) EXPECT() *MockSegmentControllerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSegmentControllerClient) QuerySegmentRouteInfo 

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

QuerySegmentRouteInfo mocks base method.

func (*MockSegmentControllerClient) RegisterSegmentServer 

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

RegisterSegmentServer mocks base method.

func (*MockSegmentControllerClient) ReportSegmentBlockIsFull 

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

ReportSegmentBlockIsFull mocks base method.

func (*MockSegmentControllerClient) ReportSegmentLeader 

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

ReportSegmentLeader mocks base method.

func (*MockSegmentControllerClient) SegmentHeartbeat 

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

SegmentHeartbeat mocks base method.

func (*MockSegmentControllerClient) UnregisterSegmentServer 

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

UnregisterSegmentServer mocks base method.

type MockSegmentControllerClientMockRecorder 

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

MockSegmentControllerClientMockRecorder is the mock recorder for MockSegmentControllerClient.

func (*MockSegmentControllerClientMockRecorder) QuerySegmentRouteInfo 

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

QuerySegmentRouteInfo indicates an expected call of QuerySegmentRouteInfo.

func (*MockSegmentControllerClientMockRecorder) RegisterSegmentServer 

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

RegisterSegmentServer indicates an expected call of RegisterSegmentServer.

func (*MockSegmentControllerClientMockRecorder) ReportSegmentBlockIsFull 

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

ReportSegmentBlockIsFull indicates an expected call of ReportSegmentBlockIsFull.

func (*MockSegmentControllerClientMockRecorder) ReportSegmentLeader 

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

ReportSegmentLeader indicates an expected call of ReportSegmentLeader.

func (*MockSegmentControllerClientMockRecorder) SegmentHeartbeat 

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

SegmentHeartbeat indicates an expected call of SegmentHeartbeat.

func (*MockSegmentControllerClientMockRecorder) UnregisterSegmentServer 

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

UnregisterSegmentServer indicates an expected call of UnregisterSegmentServer.

type MockSegmentControllerServer 

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

MockSegmentControllerServer is a mock of SegmentControllerServer interface.

func NewMockSegmentControllerServer 

func NewMockSegmentControllerServer(ctrl *gomock.Controller) *MockSegmentControllerServer

NewMockSegmentControllerServer creates a new mock instance.

func (*MockSegmentControllerServer) EXPECT 

func (m *MockSegmentControllerServer) EXPECT() *MockSegmentControllerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSegmentControllerServer) QuerySegmentRouteInfo 

func (m *MockSegmentControllerServer) QuerySegmentRouteInfo(ctx context.Context, in *QuerySegmentRouteInfoRequest) (*QuerySegmentRouteInfoResponse, error)

QuerySegmentRouteInfo mocks base method.

func (*MockSegmentControllerServer) RegisterSegmentServer 

func (m *MockSegmentControllerServer) RegisterSegmentServer(ctx context.Context, in *RegisterSegmentServerRequest) (*RegisterSegmentServerResponse, error)

RegisterSegmentServer mocks base method.

func (*MockSegmentControllerServer) ReportSegmentBlockIsFull 

func (m *MockSegmentControllerServer) ReportSegmentBlockIsFull(ctx context.Context, in *SegmentHeartbeatRequest) (*emptypb.Empty, error)

ReportSegmentBlockIsFull mocks base method.

func (*MockSegmentControllerServer) ReportSegmentLeader 

func (m *MockSegmentControllerServer) ReportSegmentLeader(ctx context.Context, in *ReportSegmentLeaderRequest) (*emptypb.Empty, error)

ReportSegmentLeader mocks base method.

func (*MockSegmentControllerServer) SegmentHeartbeat 

func (m *MockSegmentControllerServer) SegmentHeartbeat(server SegmentController_SegmentHeartbeatServer) error

SegmentHeartbeat mocks base method.

func (*MockSegmentControllerServer) UnregisterSegmentServer 

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

UnregisterSegmentServer mocks base method.

type MockSegmentControllerServerMockRecorder 

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

MockSegmentControllerServerMockRecorder is the mock recorder for MockSegmentControllerServer.

func (*MockSegmentControllerServerMockRecorder) QuerySegmentRouteInfo 

func (mr *MockSegmentControllerServerMockRecorder) QuerySegmentRouteInfo(ctx, in interface{}) *gomock.Call

QuerySegmentRouteInfo indicates an expected call of QuerySegmentRouteInfo.

func (*MockSegmentControllerServerMockRecorder) RegisterSegmentServer 

func (mr *MockSegmentControllerServerMockRecorder) RegisterSegmentServer(ctx, in interface{}) *gomock.Call

RegisterSegmentServer indicates an expected call of RegisterSegmentServer.

func (*MockSegmentControllerServerMockRecorder) ReportSegmentBlockIsFull 

func (mr *MockSegmentControllerServerMockRecorder) ReportSegmentBlockIsFull(ctx, in interface{}) *gomock.Call

ReportSegmentBlockIsFull indicates an expected call of ReportSegmentBlockIsFull.

func (*MockSegmentControllerServerMockRecorder) ReportSegmentLeader 

func (mr *MockSegmentControllerServerMockRecorder) ReportSegmentLeader(ctx, in interface{}) *gomock.Call

ReportSegmentLeader indicates an expected call of ReportSegmentLeader.

func (*MockSegmentControllerServerMockRecorder) SegmentHeartbeat 

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

SegmentHeartbeat indicates an expected call of SegmentHeartbeat.

func (*MockSegmentControllerServerMockRecorder) UnregisterSegmentServer 

func (mr *MockSegmentControllerServerMockRecorder) UnregisterSegmentServer(ctx, in interface{}) *gomock.Call

UnregisterSegmentServer indicates an expected call of UnregisterSegmentServer.

type MockSegmentController_SegmentHeartbeatClient 

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

MockSegmentController_SegmentHeartbeatClient is a mock of SegmentController_SegmentHeartbeatClient interface.

func NewMockSegmentController_SegmentHeartbeatClient 

func NewMockSegmentController_SegmentHeartbeatClient(ctrl *gomock.Controller) *MockSegmentController_SegmentHeartbeatClient

NewMockSegmentController_SegmentHeartbeatClient creates a new mock instance.

func (*MockSegmentController_SegmentHeartbeatClient) CloseAndRecv 

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

CloseAndRecv mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) CloseSend 

func (m *MockSegmentController_SegmentHeartbeatClient) CloseSend() error

CloseSend mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) Context 

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

Context mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) EXPECT 

func (m *MockSegmentController_SegmentHeartbeatClient) EXPECT() *MockSegmentController_SegmentHeartbeatClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSegmentController_SegmentHeartbeatClient) Header 

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

Header mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) RecvMsg 

func (m *MockSegmentController_SegmentHeartbeatClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) Send 

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

Send mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) SendMsg 

func (m *MockSegmentController_SegmentHeartbeatClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) Trailer 

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

Trailer mocks base method.

type MockSegmentController_SegmentHeartbeatClientMockRecorder 

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

MockSegmentController_SegmentHeartbeatClientMockRecorder is the mock recorder for MockSegmentController_SegmentHeartbeatClient.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) CloseAndRecv 

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

CloseAndRecv indicates an expected call of CloseAndRecv.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) CloseSend 

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

CloseSend indicates an expected call of CloseSend.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) Header 

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

Header indicates an expected call of Header.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) Trailer 

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

Trailer indicates an expected call of Trailer.

type MockSegmentController_SegmentHeartbeatServer 

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

MockSegmentController_SegmentHeartbeatServer is a mock of SegmentController_SegmentHeartbeatServer interface.

func NewMockSegmentController_SegmentHeartbeatServer 

func NewMockSegmentController_SegmentHeartbeatServer(ctrl *gomock.Controller) *MockSegmentController_SegmentHeartbeatServer

NewMockSegmentController_SegmentHeartbeatServer creates a new mock instance.

func (*MockSegmentController_SegmentHeartbeatServer) Context 

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

Context mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) EXPECT 

func (m *MockSegmentController_SegmentHeartbeatServer) EXPECT() *MockSegmentController_SegmentHeartbeatServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSegmentController_SegmentHeartbeatServer) Recv 

func (m *MockSegmentController_SegmentHeartbeatServer) Recv() (*SegmentHeartbeatResponse, error)

Recv mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) RecvMsg 

func (m *MockSegmentController_SegmentHeartbeatServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SendAndClose 

func (m *MockSegmentController_SegmentHeartbeatServer) SendAndClose(arg0 *SegmentHeartbeatRequest) error

SendAndClose mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SendHeader 

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

SendHeader mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SendMsg 

func (m *MockSegmentController_SegmentHeartbeatServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SetHeader 

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

SetHeader mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SetTrailer 

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

SetTrailer mocks base method.

type MockSegmentController_SegmentHeartbeatServerMockRecorder 

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

MockSegmentController_SegmentHeartbeatServerMockRecorder is the mock recorder for MockSegmentController_SegmentHeartbeatServer.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) Recv 

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

Recv indicates an expected call of Recv.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) SendAndClose 

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

SendAndClose indicates an expected call of SendAndClose.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type MockSnowflakeControllerClient 

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

MockSnowflakeControllerClient is a mock of SnowflakeControllerClient interface.

func NewMockSnowflakeControllerClient 

func NewMockSnowflakeControllerClient(ctrl *gomock.Controller) *MockSnowflakeControllerClient

NewMockSnowflakeControllerClient creates a new mock instance.

func (*MockSnowflakeControllerClient) EXPECT 

func (m *MockSnowflakeControllerClient) EXPECT() *MockSnowflakeControllerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSnowflakeControllerClient) GetClusterStartTime 

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

GetClusterStartTime mocks base method.

func (*MockSnowflakeControllerClient) RegisterNode 

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

RegisterNode mocks base method.

func (*MockSnowflakeControllerClient) UnregisterNode 

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

UnregisterNode mocks base method.

type MockSnowflakeControllerClientMockRecorder 

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

MockSnowflakeControllerClientMockRecorder is the mock recorder for MockSnowflakeControllerClient.

func (*MockSnowflakeControllerClientMockRecorder) GetClusterStartTime 

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

GetClusterStartTime indicates an expected call of GetClusterStartTime.

func (*MockSnowflakeControllerClientMockRecorder) RegisterNode 

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

RegisterNode indicates an expected call of RegisterNode.

func (*MockSnowflakeControllerClientMockRecorder) UnregisterNode 

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

UnregisterNode indicates an expected call of UnregisterNode.

type MockSnowflakeControllerServer 

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

MockSnowflakeControllerServer is a mock of SnowflakeControllerServer interface.

func NewMockSnowflakeControllerServer 

func NewMockSnowflakeControllerServer(ctrl *gomock.Controller) *MockSnowflakeControllerServer

NewMockSnowflakeControllerServer creates a new mock instance.

func (*MockSnowflakeControllerServer) EXPECT 

func (m *MockSnowflakeControllerServer) EXPECT() *MockSnowflakeControllerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSnowflakeControllerServer) GetClusterStartTime 

func (m *MockSnowflakeControllerServer) GetClusterStartTime(ctx context.Context, in *emptypb.Empty) (*timestamppb.Timestamp, error)

GetClusterStartTime mocks base method.

func (*MockSnowflakeControllerServer) RegisterNode 

func (m *MockSnowflakeControllerServer) RegisterNode(ctx context.Context, in *wrapperspb.UInt32Value) (*emptypb.Empty, error)

RegisterNode mocks base method.

func (*MockSnowflakeControllerServer) UnregisterNode 

func (m *MockSnowflakeControllerServer) UnregisterNode(ctx context.Context, in *wrapperspb.UInt32Value) (*emptypb.Empty, error)

UnregisterNode mocks base method.

type MockSnowflakeControllerServerMockRecorder 

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

MockSnowflakeControllerServerMockRecorder is the mock recorder for MockSnowflakeControllerServer.

func (*MockSnowflakeControllerServerMockRecorder) GetClusterStartTime 

func (mr *MockSnowflakeControllerServerMockRecorder) GetClusterStartTime(ctx, in interface{}) *gomock.Call

GetClusterStartTime indicates an expected call of GetClusterStartTime.

func (*MockSnowflakeControllerServerMockRecorder) RegisterNode 

func (mr *MockSnowflakeControllerServerMockRecorder) RegisterNode(ctx, in interface{}) *gomock.Call

RegisterNode indicates an expected call of RegisterNode.

func (*MockSnowflakeControllerServerMockRecorder) UnregisterNode 

func (mr *MockSnowflakeControllerServerMockRecorder) UnregisterNode(ctx, in interface{}) *gomock.Call

UnregisterNode indicates an expected call of UnregisterNode.

type MockTriggerControllerClient 

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

MockTriggerControllerClient is a mock of TriggerControllerClient interface.

func NewMockTriggerControllerClient 

func NewMockTriggerControllerClient(ctrl *gomock.Controller) *MockTriggerControllerClient

NewMockTriggerControllerClient creates a new mock instance.

func (*MockTriggerControllerClient) CommitOffset 

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

CommitOffset mocks base method.

func (*MockTriggerControllerClient) CreateSubscription 

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

CreateSubscription mocks base method.

func (*MockTriggerControllerClient) DeleteSubscription 

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

DeleteSubscription mocks base method.

func (*MockTriggerControllerClient) DisableSubscription 

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

DisableSubscription mocks base method.

func (*MockTriggerControllerClient) EXPECT 

func (m *MockTriggerControllerClient) EXPECT() *MockTriggerControllerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTriggerControllerClient) GetDeadLetterEventOffset 

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

GetDeadLetterEventOffset mocks base method.

func (*MockTriggerControllerClient) GetSubscription 

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

GetSubscription mocks base method.

func (*MockTriggerControllerClient) ListSubscription 

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

ListSubscription mocks base method.

func (*MockTriggerControllerClient) RegisterTriggerWorker 

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

RegisterTriggerWorker mocks base method.

func (*MockTriggerControllerClient) ResetOffsetToTimestamp 

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

ResetOffsetToTimestamp mocks base method.

func (*MockTriggerControllerClient) ResumeSubscription 

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

ResumeSubscription mocks base method.

func (*MockTriggerControllerClient) SetDeadLetterEventOffset 

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

SetDeadLetterEventOffset mocks base method.

func (*MockTriggerControllerClient) TriggerWorkerHeartbeat 

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

TriggerWorkerHeartbeat mocks base method.

func (*MockTriggerControllerClient) UnregisterTriggerWorker 

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

UnregisterTriggerWorker mocks base method.

func (*MockTriggerControllerClient) UpdateSubscription 

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

UpdateSubscription mocks base method.

type MockTriggerControllerClientMockRecorder 

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

MockTriggerControllerClientMockRecorder is the mock recorder for MockTriggerControllerClient.

func (*MockTriggerControllerClientMockRecorder) CommitOffset 

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

CommitOffset indicates an expected call of CommitOffset.

func (*MockTriggerControllerClientMockRecorder) CreateSubscription 

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

CreateSubscription indicates an expected call of CreateSubscription.

func (*MockTriggerControllerClientMockRecorder) DeleteSubscription 

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

DeleteSubscription indicates an expected call of DeleteSubscription.

func (*MockTriggerControllerClientMockRecorder) DisableSubscription 

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

DisableSubscription indicates an expected call of DisableSubscription.

func (*MockTriggerControllerClientMockRecorder) GetDeadLetterEventOffset 

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

GetDeadLetterEventOffset indicates an expected call of GetDeadLetterEventOffset.

func (*MockTriggerControllerClientMockRecorder) GetSubscription 

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

GetSubscription indicates an expected call of GetSubscription.

func (*MockTriggerControllerClientMockRecorder) ListSubscription 

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

ListSubscription indicates an expected call of ListSubscription.

func (*MockTriggerControllerClientMockRecorder) RegisterTriggerWorker 

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

RegisterTriggerWorker indicates an expected call of RegisterTriggerWorker.

func (*MockTriggerControllerClientMockRecorder) ResetOffsetToTimestamp 

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

ResetOffsetToTimestamp indicates an expected call of ResetOffsetToTimestamp.

func (*MockTriggerControllerClientMockRecorder) ResumeSubscription 

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

ResumeSubscription indicates an expected call of ResumeSubscription.

func (*MockTriggerControllerClientMockRecorder) SetDeadLetterEventOffset 

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

SetDeadLetterEventOffset indicates an expected call of SetDeadLetterEventOffset.

func (*MockTriggerControllerClientMockRecorder) TriggerWorkerHeartbeat 

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

TriggerWorkerHeartbeat indicates an expected call of TriggerWorkerHeartbeat.

func (*MockTriggerControllerClientMockRecorder) UnregisterTriggerWorker 

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

UnregisterTriggerWorker indicates an expected call of UnregisterTriggerWorker.

func (*MockTriggerControllerClientMockRecorder) UpdateSubscription 

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

UpdateSubscription indicates an expected call of UpdateSubscription.

type MockTriggerControllerServer 

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

MockTriggerControllerServer is a mock of TriggerControllerServer interface.

func NewMockTriggerControllerServer 

func NewMockTriggerControllerServer(ctrl *gomock.Controller) *MockTriggerControllerServer

NewMockTriggerControllerServer creates a new mock instance.

func (*MockTriggerControllerServer) CommitOffset 

func (m *MockTriggerControllerServer) CommitOffset(ctx context.Context, in *CommitOffsetRequest) (*CommitOffsetResponse, error)

CommitOffset mocks base method.

func (*MockTriggerControllerServer) CreateSubscription 

func (m *MockTriggerControllerServer) CreateSubscription(ctx context.Context, in *CreateSubscriptionRequest) (*meta.Subscription, error)

CreateSubscription mocks base method.

func (*MockTriggerControllerServer) DeleteSubscription 

func (m *MockTriggerControllerServer) DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest) (*emptypb.Empty, error)

DeleteSubscription mocks base method.

func (*MockTriggerControllerServer) DisableSubscription 

func (m *MockTriggerControllerServer) DisableSubscription(ctx context.Context, in *DisableSubscriptionRequest) (*emptypb.Empty, error)

DisableSubscription mocks base method.

func (*MockTriggerControllerServer) EXPECT 

func (m *MockTriggerControllerServer) EXPECT() *MockTriggerControllerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTriggerControllerServer) GetDeadLetterEventOffset 

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

GetDeadLetterEventOffset mocks base method.

func (*MockTriggerControllerServer) GetSubscription 

func (m *MockTriggerControllerServer) GetSubscription(ctx context.Context, in *GetSubscriptionRequest) (*meta.Subscription, error)

GetSubscription mocks base method.

func (*MockTriggerControllerServer) ListSubscription 

func (m *MockTriggerControllerServer) ListSubscription(ctx context.Context, in *ListSubscriptionRequest) (*ListSubscriptionResponse, error)

ListSubscription mocks base method.

func (*MockTriggerControllerServer) RegisterTriggerWorker 

func (m *MockTriggerControllerServer) RegisterTriggerWorker(ctx context.Context, in *RegisterTriggerWorkerRequest) (*RegisterTriggerWorkerResponse, error)

RegisterTriggerWorker mocks base method.

func (*MockTriggerControllerServer) ResetOffsetToTimestamp 

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

ResetOffsetToTimestamp mocks base method.

func (*MockTriggerControllerServer) ResumeSubscription 

func (m *MockTriggerControllerServer) ResumeSubscription(ctx context.Context, in *ResumeSubscriptionRequest) (*emptypb.Empty, error)

ResumeSubscription mocks base method.

func (*MockTriggerControllerServer) SetDeadLetterEventOffset 

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

SetDeadLetterEventOffset mocks base method.

func (*MockTriggerControllerServer) TriggerWorkerHeartbeat 

func (m *MockTriggerControllerServer) TriggerWorkerHeartbeat(server TriggerController_TriggerWorkerHeartbeatServer) error

TriggerWorkerHeartbeat mocks base method.

func (*MockTriggerControllerServer) UnregisterTriggerWorker 

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

UnregisterTriggerWorker mocks base method.

func (*MockTriggerControllerServer) UpdateSubscription 

func (m *MockTriggerControllerServer) UpdateSubscription(ctx context.Context, in *UpdateSubscriptionRequest) (*meta.Subscription, error)

UpdateSubscription mocks base method.

type MockTriggerControllerServerMockRecorder 

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

MockTriggerControllerServerMockRecorder is the mock recorder for MockTriggerControllerServer.

func (*MockTriggerControllerServerMockRecorder) CommitOffset 

func (mr *MockTriggerControllerServerMockRecorder) CommitOffset(ctx, in interface{}) *gomock.Call

CommitOffset indicates an expected call of CommitOffset.

func (*MockTriggerControllerServerMockRecorder) CreateSubscription 

func (mr *MockTriggerControllerServerMockRecorder) CreateSubscription(ctx, in interface{}) *gomock.Call

CreateSubscription indicates an expected call of CreateSubscription.

func (*MockTriggerControllerServerMockRecorder) DeleteSubscription 

func (mr *MockTriggerControllerServerMockRecorder) DeleteSubscription(ctx, in interface{}) *gomock.Call

DeleteSubscription indicates an expected call of DeleteSubscription.

func (*MockTriggerControllerServerMockRecorder) DisableSubscription 

func (mr *MockTriggerControllerServerMockRecorder) DisableSubscription(ctx, in interface{}) *gomock.Call

DisableSubscription indicates an expected call of DisableSubscription.

func (*MockTriggerControllerServerMockRecorder) GetDeadLetterEventOffset 

func (mr *MockTriggerControllerServerMockRecorder) GetDeadLetterEventOffset(ctx, in interface{}) *gomock.Call

GetDeadLetterEventOffset indicates an expected call of GetDeadLetterEventOffset.

func (*MockTriggerControllerServerMockRecorder) GetSubscription 

func (mr *MockTriggerControllerServerMockRecorder) GetSubscription(ctx, in interface{}) *gomock.Call

GetSubscription indicates an expected call of GetSubscription.

func (*MockTriggerControllerServerMockRecorder) ListSubscription 

func (mr *MockTriggerControllerServerMockRecorder) ListSubscription(ctx, in interface{}) *gomock.Call

ListSubscription indicates an expected call of ListSubscription.

func (*MockTriggerControllerServerMockRecorder) RegisterTriggerWorker 

func (mr *MockTriggerControllerServerMockRecorder) RegisterTriggerWorker(ctx, in interface{}) *gomock.Call

RegisterTriggerWorker indicates an expected call of RegisterTriggerWorker.

func (*MockTriggerControllerServerMockRecorder) ResetOffsetToTimestamp 

func (mr *MockTriggerControllerServerMockRecorder) ResetOffsetToTimestamp(ctx, in interface{}) *gomock.Call

ResetOffsetToTimestamp indicates an expected call of ResetOffsetToTimestamp.

func (*MockTriggerControllerServerMockRecorder) ResumeSubscription 

func (mr *MockTriggerControllerServerMockRecorder) ResumeSubscription(ctx, in interface{}) *gomock.Call

ResumeSubscription indicates an expected call of ResumeSubscription.

func (*MockTriggerControllerServerMockRecorder) SetDeadLetterEventOffset 

func (mr *MockTriggerControllerServerMockRecorder) SetDeadLetterEventOffset(ctx, in interface{}) *gomock.Call

SetDeadLetterEventOffset indicates an expected call of SetDeadLetterEventOffset.

func (*MockTriggerControllerServerMockRecorder) TriggerWorkerHeartbeat 

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

TriggerWorkerHeartbeat indicates an expected call of TriggerWorkerHeartbeat.

func (*MockTriggerControllerServerMockRecorder) UnregisterTriggerWorker 

func (mr *MockTriggerControllerServerMockRecorder) UnregisterTriggerWorker(ctx, in interface{}) *gomock.Call

UnregisterTriggerWorker indicates an expected call of UnregisterTriggerWorker.

func (*MockTriggerControllerServerMockRecorder) UpdateSubscription 

func (mr *MockTriggerControllerServerMockRecorder) UpdateSubscription(ctx, in interface{}) *gomock.Call

UpdateSubscription indicates an expected call of UpdateSubscription.

type MockTriggerController_TriggerWorkerHeartbeatClient 

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

MockTriggerController_TriggerWorkerHeartbeatClient is a mock of TriggerController_TriggerWorkerHeartbeatClient interface.

func NewMockTriggerController_TriggerWorkerHeartbeatClient 

func NewMockTriggerController_TriggerWorkerHeartbeatClient(ctrl *gomock.Controller) *MockTriggerController_TriggerWorkerHeartbeatClient

NewMockTriggerController_TriggerWorkerHeartbeatClient creates a new mock instance.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) CloseAndRecv 

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

CloseAndRecv mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) CloseSend 

func (m *MockTriggerController_TriggerWorkerHeartbeatClient) CloseSend() error

CloseSend mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) Context 

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

Context mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) EXPECT 

func (m *MockTriggerController_TriggerWorkerHeartbeatClient) EXPECT() *MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) Header 

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

Header mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) RecvMsg 

func (m *MockTriggerController_TriggerWorkerHeartbeatClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) Send 

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

Send mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) SendMsg 

func (m *MockTriggerController_TriggerWorkerHeartbeatClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) Trailer 

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

Trailer mocks base method.

type MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder 

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

MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder is the mock recorder for MockTriggerController_TriggerWorkerHeartbeatClient.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) CloseAndRecv 

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

CloseAndRecv indicates an expected call of CloseAndRecv.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) CloseSend 

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

CloseSend indicates an expected call of CloseSend.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Header 

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

Header indicates an expected call of Header.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Trailer 

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

Trailer indicates an expected call of Trailer.

type MockTriggerController_TriggerWorkerHeartbeatServer 

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

MockTriggerController_TriggerWorkerHeartbeatServer is a mock of TriggerController_TriggerWorkerHeartbeatServer interface.

func NewMockTriggerController_TriggerWorkerHeartbeatServer 

func NewMockTriggerController_TriggerWorkerHeartbeatServer(ctrl *gomock.Controller) *MockTriggerController_TriggerWorkerHeartbeatServer

NewMockTriggerController_TriggerWorkerHeartbeatServer creates a new mock instance.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) Context 

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

Context mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) EXPECT 

func (m *MockTriggerController_TriggerWorkerHeartbeatServer) EXPECT() *MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) Recv 

func (m *MockTriggerController_TriggerWorkerHeartbeatServer) Recv() (*TriggerWorkerHeartbeatResponse, error)

Recv mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) RecvMsg 

func (m *MockTriggerController_TriggerWorkerHeartbeatServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SendAndClose 

func (m *MockTriggerController_TriggerWorkerHeartbeatServer) SendAndClose(arg0 *TriggerWorkerHeartbeatRequest) error

SendAndClose mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SendHeader 

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

SendHeader mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SendMsg 

func (m *MockTriggerController_TriggerWorkerHeartbeatServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SetHeader 

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

SetHeader mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SetTrailer 

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

SetTrailer mocks base method.

type MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder 

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

MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder is the mock recorder for MockTriggerController_TriggerWorkerHeartbeatServer.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) Recv 

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

Recv indicates an expected call of Recv.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SendAndClose 

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

SendAndClose indicates an expected call of SendAndClose.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type NamespaceControllerClient 

type NamespaceControllerClient interface {
	CreateNamespace(ctx context.Context, in *CreateNamespaceRequest, opts ...grpc.CallOption) (*meta.Namespace, error)
	ListNamespace(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListNamespaceResponse, error)
	GetNamespace(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*meta.Namespace, error)
	DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetNamespaceWithHumanFriendly(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*meta.Namespace, error)
}

NamespaceControllerClient is the client API for NamespaceController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNamespaceControllerClient 

func NewNamespaceControllerClient(cc grpc.ClientConnInterface) NamespaceControllerClient

type NamespaceControllerServer 

type NamespaceControllerServer interface {
	CreateNamespace(context.Context, *CreateNamespaceRequest) (*meta.Namespace, error)
	ListNamespace(context.Context, *emptypb.Empty) (*ListNamespaceResponse, error)
	GetNamespace(context.Context, *GetNamespaceRequest) (*meta.Namespace, error)
	DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*emptypb.Empty, error)
	GetNamespaceWithHumanFriendly(context.Context, *wrapperspb.StringValue) (*meta.Namespace, error)
}

NamespaceControllerServer is the server API for NamespaceController service. All implementations should embed UnimplementedNamespaceControllerServer for forward compatibility

type PingResponse 

type PingResponse struct {
	LeaderAddr      string `protobuf:"bytes,1,opt,name=leader_addr,json=leaderAddr,proto3" json:"leader_addr,omitempty"`
	GatewayAddr     string `protobuf:"bytes,2,opt,name=gateway_addr,json=gatewayAddr,proto3" json:"gateway_addr,omitempty"`
	IsEventbusReady bool   `protobuf:"varint,3,opt,name=is_eventbus_ready,json=isEventbusReady,proto3" json:"is_eventbus_ready,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetGatewayAddr 

func (x *PingResponse) GetGatewayAddr() string

func (*PingResponse) GetIsEventbusReady 

func (x *PingResponse) GetIsEventbusReady() bool

func (*PingResponse) GetLeaderAddr 

func (x *PingResponse) GetLeaderAddr() string

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type PingServerClient 

type PingServerClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PingResponse, error)
}

PingServerClient is the client API for PingServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPingServerClient 

func NewPingServerClient(cc grpc.ClientConnInterface) PingServerClient

type PingServerServer 

type PingServerServer interface {
	Ping(context.Context, *emptypb.Empty) (*PingResponse, error)
}

PingServerServer is the server API for PingServer service. All implementations should embed UnimplementedPingServerServer for forward compatibility

type QuerySegmentRouteInfoRequest 

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

func (*QuerySegmentRouteInfoRequest) Descriptor deprecated 

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

Deprecated: Use QuerySegmentRouteInfoRequest.ProtoReflect.Descriptor instead.

func (*QuerySegmentRouteInfoRequest) ProtoMessage 

func (*QuerySegmentRouteInfoRequest) ProtoMessage()

func (*QuerySegmentRouteInfoRequest) ProtoReflect 

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

func (*QuerySegmentRouteInfoRequest) Reset 

func (x *QuerySegmentRouteInfoRequest) Reset()

func (*QuerySegmentRouteInfoRequest) String 

func (x *QuerySegmentRouteInfoRequest) String() string

type QuerySegmentRouteInfoResponse 

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

func (*QuerySegmentRouteInfoResponse) Descriptor deprecated 

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

Deprecated: Use QuerySegmentRouteInfoResponse.ProtoReflect.Descriptor instead.

func (*QuerySegmentRouteInfoResponse) ProtoMessage 

func (*QuerySegmentRouteInfoResponse) ProtoMessage()

func (*QuerySegmentRouteInfoResponse) ProtoReflect 

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

func (*QuerySegmentRouteInfoResponse) Reset 

func (x *QuerySegmentRouteInfoResponse) Reset()

func (*QuerySegmentRouteInfoResponse) String 

func (x *QuerySegmentRouteInfoResponse) String() string

type RegisterSegmentServerRequest 

type RegisterSegmentServerRequest struct {
	Address  string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	VolumeId uint64 `protobuf:"varint,2,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Capacity uint64 `protobuf:"varint,3,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterSegmentServerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterSegmentServerRequest.ProtoReflect.Descriptor instead.

func (*RegisterSegmentServerRequest) GetAddress 

func (x *RegisterSegmentServerRequest) GetAddress() string

func (*RegisterSegmentServerRequest) GetCapacity 

func (x *RegisterSegmentServerRequest) GetCapacity() uint64

func (*RegisterSegmentServerRequest) GetVolumeId 

func (x *RegisterSegmentServerRequest) GetVolumeId() uint64

func (*RegisterSegmentServerRequest) ProtoMessage 

func (*RegisterSegmentServerRequest) ProtoMessage()

func (*RegisterSegmentServerRequest) ProtoReflect 

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

func (*RegisterSegmentServerRequest) Reset 

func (x *RegisterSegmentServerRequest) Reset()

func (*RegisterSegmentServerRequest) String 

func (x *RegisterSegmentServerRequest) String() string

type RegisterSegmentServerResponse 

type RegisterSegmentServerResponse struct {
	Segments map[uint64]*meta.Segment `` /* 158-byte string literal not displayed */
	VolumeId uint64                   `protobuf:"varint,3,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterSegmentServerResponse) Descriptor deprecated 

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

Deprecated: Use RegisterSegmentServerResponse.ProtoReflect.Descriptor instead.

func (*RegisterSegmentServerResponse) GetSegments 

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

func (*RegisterSegmentServerResponse) GetVolumeId 

func (x *RegisterSegmentServerResponse) GetVolumeId() uint64

func (*RegisterSegmentServerResponse) ProtoMessage 

func (*RegisterSegmentServerResponse) ProtoMessage()

func (*RegisterSegmentServerResponse) ProtoReflect 

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

func (*RegisterSegmentServerResponse) Reset 

func (x *RegisterSegmentServerResponse) Reset()

func (*RegisterSegmentServerResponse) String 

func (x *RegisterSegmentServerResponse) String() string

type RegisterTriggerWorkerRequest 

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

func (*RegisterTriggerWorkerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterTriggerWorkerRequest.ProtoReflect.Descriptor instead.

func (*RegisterTriggerWorkerRequest) GetAddress 

func (x *RegisterTriggerWorkerRequest) GetAddress() string

func (*RegisterTriggerWorkerRequest) ProtoMessage 

func (*RegisterTriggerWorkerRequest) ProtoMessage()

func (*RegisterTriggerWorkerRequest) ProtoReflect 

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

func (*RegisterTriggerWorkerRequest) Reset 

func (x *RegisterTriggerWorkerRequest) Reset()

func (*RegisterTriggerWorkerRequest) String 

func (x *RegisterTriggerWorkerRequest) String() string

type RegisterTriggerWorkerResponse 

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

func (*RegisterTriggerWorkerResponse) Descriptor deprecated 

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

Deprecated: Use RegisterTriggerWorkerResponse.ProtoReflect.Descriptor instead.

func (*RegisterTriggerWorkerResponse) ProtoMessage 

func (*RegisterTriggerWorkerResponse) ProtoMessage()

func (*RegisterTriggerWorkerResponse) ProtoReflect 

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

func (*RegisterTriggerWorkerResponse) Reset 

func (x *RegisterTriggerWorkerResponse) Reset()

func (*RegisterTriggerWorkerResponse) String 

func (x *RegisterTriggerWorkerResponse) String() string

type ReportSegmentLeaderRequest 

type ReportSegmentLeaderRequest struct {
	SegmentId uint64 `protobuf:"varint,3,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	LeaderId  uint64 `protobuf:"varint,1,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	Term      uint64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportSegmentLeaderRequest) Descriptor deprecated 

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

Deprecated: Use ReportSegmentLeaderRequest.ProtoReflect.Descriptor instead.

func (*ReportSegmentLeaderRequest) GetLeaderId 

func (x *ReportSegmentLeaderRequest) GetLeaderId() uint64

func (*ReportSegmentLeaderRequest) GetSegmentId 

func (x *ReportSegmentLeaderRequest) GetSegmentId() uint64

func (*ReportSegmentLeaderRequest) GetTerm 

func (x *ReportSegmentLeaderRequest) GetTerm() uint64

func (*ReportSegmentLeaderRequest) ProtoMessage 

func (*ReportSegmentLeaderRequest) ProtoMessage()

func (*ReportSegmentLeaderRequest) ProtoReflect 

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

func (*ReportSegmentLeaderRequest) Reset 

func (x *ReportSegmentLeaderRequest) Reset()

func (*ReportSegmentLeaderRequest) String 

func (x *ReportSegmentLeaderRequest) String() string

type ResetOffsetToTimestampRequest 

type ResetOffsetToTimestampRequest struct {
	SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// utc time milliseconds
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetOffsetToTimestampRequest) Descriptor deprecated 

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

Deprecated: Use ResetOffsetToTimestampRequest.ProtoReflect.Descriptor instead.

func (*ResetOffsetToTimestampRequest) GetSubscriptionId 

func (x *ResetOffsetToTimestampRequest) GetSubscriptionId() uint64

func (*ResetOffsetToTimestampRequest) GetTimestamp 

func (x *ResetOffsetToTimestampRequest) GetTimestamp() uint64

func (*ResetOffsetToTimestampRequest) ProtoMessage 

func (*ResetOffsetToTimestampRequest) ProtoMessage()

func (*ResetOffsetToTimestampRequest) ProtoReflect 

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

func (*ResetOffsetToTimestampRequest) Reset 

func (x *ResetOffsetToTimestampRequest) Reset()

func (*ResetOffsetToTimestampRequest) String 

func (x *ResetOffsetToTimestampRequest) String() string

type ResetOffsetToTimestampResponse 

type ResetOffsetToTimestampResponse struct {
	Offsets []*meta.OffsetInfo `protobuf:"bytes,1,rep,name=offsets,proto3" json:"offsets,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetOffsetToTimestampResponse) Descriptor deprecated 

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

Deprecated: Use ResetOffsetToTimestampResponse.ProtoReflect.Descriptor instead.

func (*ResetOffsetToTimestampResponse) GetOffsets 

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

func (*ResetOffsetToTimestampResponse) ProtoMessage 

func (*ResetOffsetToTimestampResponse) ProtoMessage()

func (*ResetOffsetToTimestampResponse) ProtoReflect 

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

func (*ResetOffsetToTimestampResponse) Reset 

func (x *ResetOffsetToTimestampResponse) Reset()

func (*ResetOffsetToTimestampResponse) String 

func (x *ResetOffsetToTimestampResponse) String() string

type ResumeSubscriptionRequest 

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

func (*ResumeSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use ResumeSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*ResumeSubscriptionRequest) GetId 

func (x *ResumeSubscriptionRequest) GetId() uint64

func (*ResumeSubscriptionRequest) ProtoMessage 

func (*ResumeSubscriptionRequest) ProtoMessage()

func (*ResumeSubscriptionRequest) ProtoReflect 

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

func (*ResumeSubscriptionRequest) Reset 

func (x *ResumeSubscriptionRequest) Reset()

func (*ResumeSubscriptionRequest) String 

func (x *ResumeSubscriptionRequest) String() string

type RoleRequest 

type RoleRequest struct {
	UserIdentifier string `protobuf:"bytes,1,opt,name=user_identifier,json=userIdentifier,proto3" json:"user_identifier,omitempty"`
	// for custom defined role
	RoleId string `protobuf:"bytes,2,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	// for built-in role
	RoleName     string `protobuf:"bytes,3,opt,name=role_name,json=roleName,proto3" json:"role_name,omitempty"`
	ResourceId   uint64 `protobuf:"varint,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceKind string `protobuf:"bytes,5,opt,name=resource_kind,json=resourceKind,proto3" json:"resource_kind,omitempty"`
	// contains filtered or unexported fields
}

func (*RoleRequest) Descriptor deprecated 

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

Deprecated: Use RoleRequest.ProtoReflect.Descriptor instead.

func (*RoleRequest) GetResourceId 

func (x *RoleRequest) GetResourceId() uint64

func (*RoleRequest) GetResourceKind 

func (x *RoleRequest) GetResourceKind() string

func (*RoleRequest) GetRoleId 

func (x *RoleRequest) GetRoleId() string

func (*RoleRequest) GetRoleName 

func (x *RoleRequest) GetRoleName() string

func (*RoleRequest) GetUserIdentifier 

func (x *RoleRequest) GetUserIdentifier() string

func (*RoleRequest) ProtoMessage 

func (*RoleRequest) ProtoMessage()

func (*RoleRequest) ProtoReflect 

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

func (*RoleRequest) Reset 

func (x *RoleRequest) Reset()

func (*RoleRequest) String 

func (x *RoleRequest) String() string

type SegmentControllerClient 

type SegmentControllerClient interface {
	QuerySegmentRouteInfo(ctx context.Context, in *QuerySegmentRouteInfoRequest, opts ...grpc.CallOption) (*QuerySegmentRouteInfoResponse, error)
	SegmentHeartbeat(ctx context.Context, opts ...grpc.CallOption) (SegmentController_SegmentHeartbeatClient, error)
	RegisterSegmentServer(ctx context.Context, in *RegisterSegmentServerRequest, opts ...grpc.CallOption) (*RegisterSegmentServerResponse, error)
	UnregisterSegmentServer(ctx context.Context, in *UnregisterSegmentServerRequest, opts ...grpc.CallOption) (*UnregisterSegmentServerResponse, error)
	ReportSegmentBlockIsFull(ctx context.Context, in *SegmentHeartbeatRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportSegmentLeader(ctx context.Context, in *ReportSegmentLeaderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SegmentControllerClient is the client API for SegmentController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSegmentControllerClient 

func NewSegmentControllerClient(cc grpc.ClientConnInterface) SegmentControllerClient

type SegmentControllerServer 

type SegmentControllerServer interface {
	QuerySegmentRouteInfo(context.Context, *QuerySegmentRouteInfoRequest) (*QuerySegmentRouteInfoResponse, error)
	SegmentHeartbeat(SegmentController_SegmentHeartbeatServer) error
	RegisterSegmentServer(context.Context, *RegisterSegmentServerRequest) (*RegisterSegmentServerResponse, error)
	UnregisterSegmentServer(context.Context, *UnregisterSegmentServerRequest) (*UnregisterSegmentServerResponse, error)
	ReportSegmentBlockIsFull(context.Context, *SegmentHeartbeatRequest) (*emptypb.Empty, error)
	ReportSegmentLeader(context.Context, *ReportSegmentLeaderRequest) (*emptypb.Empty, error)
}

SegmentControllerServer is the server API for SegmentController service. All implementations should embed UnimplementedSegmentControllerServer for forward compatibility

type SegmentController_SegmentHeartbeatClient 

type SegmentController_SegmentHeartbeatClient interface {
	Send(*SegmentHeartbeatRequest) error
	CloseAndRecv() (*SegmentHeartbeatResponse, error)
	grpc.ClientStream
}

type SegmentController_SegmentHeartbeatServer 

type SegmentController_SegmentHeartbeatServer interface {
	SendAndClose(*SegmentHeartbeatResponse) error
	Recv() (*SegmentHeartbeatRequest, error)
	grpc.ServerStream
}

type SegmentHeartbeatRequest 

type SegmentHeartbeatRequest struct {
	VolumeId   uint64                    `protobuf:"varint,2,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	HealthInfo []*meta.SegmentHealthInfo `protobuf:"bytes,3,rep,name=health_info,json=healthInfo,proto3" json:"health_info,omitempty"`
	ReportTime string                    `protobuf:"bytes,4,opt,name=report_time,json=reportTime,proto3" json:"report_time,omitempty"`
	ServerAddr string                    `protobuf:"bytes,5,opt,name=server_addr,json=serverAddr,proto3" json:"server_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentHeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use SegmentHeartbeatRequest.ProtoReflect.Descriptor instead.

func (*SegmentHeartbeatRequest) GetHealthInfo 

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

func (*SegmentHeartbeatRequest) GetReportTime 

func (x *SegmentHeartbeatRequest) GetReportTime() string

func (*SegmentHeartbeatRequest) GetServerAddr 

func (x *SegmentHeartbeatRequest) GetServerAddr() string

func (*SegmentHeartbeatRequest) GetVolumeId 

func (x *SegmentHeartbeatRequest) GetVolumeId() uint64

func (*SegmentHeartbeatRequest) ProtoMessage 

func (*SegmentHeartbeatRequest) ProtoMessage()

func (*SegmentHeartbeatRequest) ProtoReflect 

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

func (*SegmentHeartbeatRequest) Reset 

func (x *SegmentHeartbeatRequest) Reset()

func (*SegmentHeartbeatRequest) String 

func (x *SegmentHeartbeatRequest) String() string

type SegmentHeartbeatResponse 

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

func (*SegmentHeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use SegmentHeartbeatResponse.ProtoReflect.Descriptor instead.

func (*SegmentHeartbeatResponse) ProtoMessage 

func (*SegmentHeartbeatResponse) ProtoMessage()

func (*SegmentHeartbeatResponse) ProtoReflect 

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

func (*SegmentHeartbeatResponse) Reset 

func (x *SegmentHeartbeatResponse) Reset()

func (*SegmentHeartbeatResponse) String 

func (x *SegmentHeartbeatResponse) String() string

type SetDeadLetterEventOffsetRequest 

type SetDeadLetterEventOffsetRequest struct {
	SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	Offset         uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*SetDeadLetterEventOffsetRequest) Descriptor deprecated 

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

Deprecated: Use SetDeadLetterEventOffsetRequest.ProtoReflect.Descriptor instead.

func (*SetDeadLetterEventOffsetRequest) GetOffset 

func (x *SetDeadLetterEventOffsetRequest) GetOffset() uint64

func (*SetDeadLetterEventOffsetRequest) GetSubscriptionId 

func (x *SetDeadLetterEventOffsetRequest) GetSubscriptionId() uint64

func (*SetDeadLetterEventOffsetRequest) ProtoMessage 

func (*SetDeadLetterEventOffsetRequest) ProtoMessage()

func (*SetDeadLetterEventOffsetRequest) ProtoReflect 

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

func (*SetDeadLetterEventOffsetRequest) Reset 

func (x *SetDeadLetterEventOffsetRequest) Reset()

func (*SetDeadLetterEventOffsetRequest) String 

func (x *SetDeadLetterEventOffsetRequest) String() string

type SnowflakeControllerClient 

type SnowflakeControllerClient interface {
	GetClusterStartTime(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*timestamppb.Timestamp, error)
	RegisterNode(ctx context.Context, in *wrapperspb.UInt32Value, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UnregisterNode(ctx context.Context, in *wrapperspb.UInt32Value, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SnowflakeControllerClient is the client API for SnowflakeController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSnowflakeControllerClient 

func NewSnowflakeControllerClient(cc grpc.ClientConnInterface) SnowflakeControllerClient

type SnowflakeControllerServer 

type SnowflakeControllerServer interface {
	GetClusterStartTime(context.Context, *emptypb.Empty) (*timestamppb.Timestamp, error)
	RegisterNode(context.Context, *wrapperspb.UInt32Value) (*emptypb.Empty, error)
	UnregisterNode(context.Context, *wrapperspb.UInt32Value) (*emptypb.Empty, error)
}

SnowflakeControllerServer is the server API for SnowflakeController service. All implementations should embed UnimplementedSnowflakeControllerServer for forward compatibility

type SubscriptionRequest 

type SubscriptionRequest struct {
	Source           string                   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Types            []string                 `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	Config           *meta.SubscriptionConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	Filters          []*meta.Filter           `protobuf:"bytes,4,rep,name=filters,proto3" json:"filters,omitempty"`
	Sink             string                   `protobuf:"bytes,5,opt,name=sink,proto3" json:"sink,omitempty"`
	SinkCredential   *meta.SinkCredential     `protobuf:"bytes,6,opt,name=sink_credential,json=sinkCredential,proto3" json:"sink_credential,omitempty"`
	Protocol         meta.Protocol            `protobuf:"varint,7,opt,name=protocol,proto3,enum=vanus.core.meta.Protocol" json:"protocol,omitempty"`
	ProtocolSettings *meta.ProtocolSetting    `protobuf:"bytes,8,opt,name=protocol_settings,json=protocolSettings,proto3" json:"protocol_settings,omitempty"`
	Transformer      *meta.Transformer        `protobuf:"bytes,10,opt,name=transformer,proto3" json:"transformer,omitempty"`
	Name             string                   `protobuf:"bytes,11,opt,name=name,proto3" json:"name,omitempty"`
	Description      string                   `protobuf:"bytes,12,opt,name=description,proto3" json:"description,omitempty"`
	Disable          bool                     `protobuf:"varint,13,opt,name=disable,proto3" json:"disable,omitempty"`
	EventbusId       uint64                   `protobuf:"varint,14,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	NamespaceId      uint64                   `protobuf:"varint,15,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionRequest) GetConfig 

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

func (*SubscriptionRequest) GetDescription 

func (x *SubscriptionRequest) GetDescription() string

func (*SubscriptionRequest) GetDisable 

func (x *SubscriptionRequest) GetDisable() bool

func (*SubscriptionRequest) GetEventbusId 

func (x *SubscriptionRequest) GetEventbusId() uint64

func (*SubscriptionRequest) GetFilters 

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

func (*SubscriptionRequest) GetName 

func (x *SubscriptionRequest) GetName() string

func (*SubscriptionRequest) GetNamespaceId 

func (x *SubscriptionRequest) GetNamespaceId() uint64

func (*SubscriptionRequest) GetProtocol 

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

func (*SubscriptionRequest) GetProtocolSettings 

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

func (*SubscriptionRequest) GetSink 

func (x *SubscriptionRequest) GetSink() string

func (*SubscriptionRequest) GetSinkCredential 

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

func (*SubscriptionRequest) GetSource 

func (x *SubscriptionRequest) GetSource() string

func (*SubscriptionRequest) GetTransformer 

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

func (*SubscriptionRequest) GetTypes 

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

func (*SubscriptionRequest) ProtoMessage 

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) ProtoReflect 

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

func (*SubscriptionRequest) Reset 

func (x *SubscriptionRequest) Reset()

func (*SubscriptionRequest) String 

func (x *SubscriptionRequest) String() string

type TriggerControllerClient 

type TriggerControllerClient interface {
	CreateSubscription(ctx context.Context, in *CreateSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)
	UpdateSubscription(ctx context.Context, in *UpdateSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)
	DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DisableSubscription(ctx context.Context, in *DisableSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ResumeSubscription(ctx context.Context, in *ResumeSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)
	ListSubscription(ctx context.Context, in *ListSubscriptionRequest, opts ...grpc.CallOption) (*ListSubscriptionResponse, error)
	TriggerWorkerHeartbeat(ctx context.Context, opts ...grpc.CallOption) (TriggerController_TriggerWorkerHeartbeatClient, error)
	RegisterTriggerWorker(ctx context.Context, in *RegisterTriggerWorkerRequest, opts ...grpc.CallOption) (*RegisterTriggerWorkerResponse, error)
	UnregisterTriggerWorker(ctx context.Context, in *UnregisterTriggerWorkerRequest, opts ...grpc.CallOption) (*UnregisterTriggerWorkerResponse, error)
	ResetOffsetToTimestamp(ctx context.Context, in *ResetOffsetToTimestampRequest, opts ...grpc.CallOption) (*ResetOffsetToTimestampResponse, error)
	CommitOffset(ctx context.Context, in *CommitOffsetRequest, opts ...grpc.CallOption) (*CommitOffsetResponse, error)
	SetDeadLetterEventOffset(ctx context.Context, in *SetDeadLetterEventOffsetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetDeadLetterEventOffset(ctx context.Context, in *GetDeadLetterEventOffsetRequest, opts ...grpc.CallOption) (*GetDeadLetterEventOffsetResponse, error)
}

TriggerControllerClient is the client API for TriggerController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTriggerControllerClient 

func NewTriggerControllerClient(cc grpc.ClientConnInterface) TriggerControllerClient

type TriggerControllerServer 

type TriggerControllerServer interface {
	CreateSubscription(context.Context, *CreateSubscriptionRequest) (*meta.Subscription, error)
	UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*meta.Subscription, error)
	DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*emptypb.Empty, error)
	DisableSubscription(context.Context, *DisableSubscriptionRequest) (*emptypb.Empty, error)
	ResumeSubscription(context.Context, *ResumeSubscriptionRequest) (*emptypb.Empty, error)
	GetSubscription(context.Context, *GetSubscriptionRequest) (*meta.Subscription, error)
	ListSubscription(context.Context, *ListSubscriptionRequest) (*ListSubscriptionResponse, error)
	TriggerWorkerHeartbeat(TriggerController_TriggerWorkerHeartbeatServer) error
	RegisterTriggerWorker(context.Context, *RegisterTriggerWorkerRequest) (*RegisterTriggerWorkerResponse, error)
	UnregisterTriggerWorker(context.Context, *UnregisterTriggerWorkerRequest) (*UnregisterTriggerWorkerResponse, error)
	ResetOffsetToTimestamp(context.Context, *ResetOffsetToTimestampRequest) (*ResetOffsetToTimestampResponse, error)
	CommitOffset(context.Context, *CommitOffsetRequest) (*CommitOffsetResponse, error)
	SetDeadLetterEventOffset(context.Context, *SetDeadLetterEventOffsetRequest) (*emptypb.Empty, error)
	GetDeadLetterEventOffset(context.Context, *GetDeadLetterEventOffsetRequest) (*GetDeadLetterEventOffsetResponse, error)
}

TriggerControllerServer is the server API for TriggerController service. All implementations should embed UnimplementedTriggerControllerServer for forward compatibility

type TriggerController_TriggerWorkerHeartbeatClient 

type TriggerController_TriggerWorkerHeartbeatClient interface {
	Send(*TriggerWorkerHeartbeatRequest) error
	CloseAndRecv() (*TriggerWorkerHeartbeatResponse, error)
	grpc.ClientStream
}

type TriggerController_TriggerWorkerHeartbeatServer 

type TriggerController_TriggerWorkerHeartbeatServer interface {
	SendAndClose(*TriggerWorkerHeartbeatResponse) error
	Recv() (*TriggerWorkerHeartbeatRequest, error)
	grpc.ServerStream
}

type TriggerWorkerHeartbeatRequest 

type TriggerWorkerHeartbeatRequest struct {
	Address          string                   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Started          bool                     `protobuf:"varint,2,opt,name=started,proto3" json:"started,omitempty"`
	SubscriptionInfo []*meta.SubscriptionInfo `protobuf:"bytes,3,rep,name=subscription_info,json=subscriptionInfo,proto3" json:"subscription_info,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerWorkerHeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use TriggerWorkerHeartbeatRequest.ProtoReflect.Descriptor instead.

func (*TriggerWorkerHeartbeatRequest) GetAddress 

func (x *TriggerWorkerHeartbeatRequest) GetAddress() string

func (*TriggerWorkerHeartbeatRequest) GetStarted 

func (x *TriggerWorkerHeartbeatRequest) GetStarted() bool

func (*TriggerWorkerHeartbeatRequest) GetSubscriptionInfo 

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

func (*TriggerWorkerHeartbeatRequest) ProtoMessage 

func (*TriggerWorkerHeartbeatRequest) ProtoMessage()

func (*TriggerWorkerHeartbeatRequest) ProtoReflect 

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

func (*TriggerWorkerHeartbeatRequest) Reset 

func (x *TriggerWorkerHeartbeatRequest) Reset()

func (*TriggerWorkerHeartbeatRequest) String 

func (x *TriggerWorkerHeartbeatRequest) String() string

type TriggerWorkerHeartbeatResponse 

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

func (*TriggerWorkerHeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use TriggerWorkerHeartbeatResponse.ProtoReflect.Descriptor instead.

func (*TriggerWorkerHeartbeatResponse) ProtoMessage 

func (*TriggerWorkerHeartbeatResponse) ProtoMessage()

func (*TriggerWorkerHeartbeatResponse) ProtoReflect 

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

func (*TriggerWorkerHeartbeatResponse) Reset 

func (x *TriggerWorkerHeartbeatResponse) Reset()

func (*TriggerWorkerHeartbeatResponse) String 

func (x *TriggerWorkerHeartbeatResponse) String() string

type UnimplementedAuthControllerServer 

type UnimplementedAuthControllerServer struct {
}

UnimplementedAuthControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedAuthControllerServer) CreateToken 

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

func (UnimplementedAuthControllerServer) CreateUser 

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

func (UnimplementedAuthControllerServer) DeleteToken 

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

func (UnimplementedAuthControllerServer) DeleteUser 

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

func (UnimplementedAuthControllerServer) GetResourceRole 

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

func (UnimplementedAuthControllerServer) GetToken 

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

func (UnimplementedAuthControllerServer) GetUser 

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

func (UnimplementedAuthControllerServer) GetUserByToken 

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

func (UnimplementedAuthControllerServer) GetUserRole 

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

func (UnimplementedAuthControllerServer) GetUserToken 

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

func (UnimplementedAuthControllerServer) GrantRole 

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

func (UnimplementedAuthControllerServer) ListToken 

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

func (UnimplementedAuthControllerServer) ListUser 

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

func (UnimplementedAuthControllerServer) RevokeRole 

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

type UnimplementedEventbusControllerServer 

type UnimplementedEventbusControllerServer struct {
}

UnimplementedEventbusControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedEventbusControllerServer) CreateEventbus 

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

func (UnimplementedEventbusControllerServer) CreateSystemEventbus 

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

func (UnimplementedEventbusControllerServer) DeleteEventbus 

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

func (UnimplementedEventbusControllerServer) GetEventbus 

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

func (UnimplementedEventbusControllerServer) GetEventbusWithHumanFriendly 

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

func (UnimplementedEventbusControllerServer) ListEventbus 

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

func (UnimplementedEventbusControllerServer) UpdateEventbus 

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

type UnimplementedEventlogControllerServer 

type UnimplementedEventlogControllerServer struct {
}

UnimplementedEventlogControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedEventlogControllerServer) GetAppendableSegment 

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

func (UnimplementedEventlogControllerServer) ListSegment 

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

type UnimplementedNamespaceControllerServer 

type UnimplementedNamespaceControllerServer struct {
}

UnimplementedNamespaceControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedNamespaceControllerServer) CreateNamespace 

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

func (UnimplementedNamespaceControllerServer) DeleteNamespace 

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

func (UnimplementedNamespaceControllerServer) GetNamespace 

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

func (UnimplementedNamespaceControllerServer) GetNamespaceWithHumanFriendly 

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

func (UnimplementedNamespaceControllerServer) ListNamespace 

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

type UnimplementedPingServerServer 

type UnimplementedPingServerServer struct {
}

UnimplementedPingServerServer should be embedded to have forward compatible implementations.

func (UnimplementedPingServerServer) Ping 

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

type UnimplementedSegmentControllerServer 

type UnimplementedSegmentControllerServer struct {
}

UnimplementedSegmentControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedSegmentControllerServer) QuerySegmentRouteInfo 

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

func (UnimplementedSegmentControllerServer) RegisterSegmentServer 

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

func (UnimplementedSegmentControllerServer) ReportSegmentBlockIsFull 

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

func (UnimplementedSegmentControllerServer) ReportSegmentLeader 

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

func (UnimplementedSegmentControllerServer) SegmentHeartbeat 

func (UnimplementedSegmentControllerServer) SegmentHeartbeat(SegmentController_SegmentHeartbeatServer) error

func (UnimplementedSegmentControllerServer) UnregisterSegmentServer 

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

type UnimplementedSnowflakeControllerServer 

type UnimplementedSnowflakeControllerServer struct {
}

UnimplementedSnowflakeControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedSnowflakeControllerServer) GetClusterStartTime 

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

func (UnimplementedSnowflakeControllerServer) RegisterNode 

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

func (UnimplementedSnowflakeControllerServer) UnregisterNode 

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

type UnimplementedTriggerControllerServer 

type UnimplementedTriggerControllerServer struct {
}

UnimplementedTriggerControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedTriggerControllerServer) CommitOffset 

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

func (UnimplementedTriggerControllerServer) CreateSubscription 

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

func (UnimplementedTriggerControllerServer) DeleteSubscription 

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

func (UnimplementedTriggerControllerServer) DisableSubscription 

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

func (UnimplementedTriggerControllerServer) GetDeadLetterEventOffset 

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

func (UnimplementedTriggerControllerServer) GetSubscription 

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

func (UnimplementedTriggerControllerServer) ListSubscription 

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

func (UnimplementedTriggerControllerServer) RegisterTriggerWorker 

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

func (UnimplementedTriggerControllerServer) ResetOffsetToTimestamp 

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

func (UnimplementedTriggerControllerServer) ResumeSubscription 

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

func (UnimplementedTriggerControllerServer) SetDeadLetterEventOffset 

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

func (UnimplementedTriggerControllerServer) TriggerWorkerHeartbeat 

func (UnimplementedTriggerControllerServer) TriggerWorkerHeartbeat(TriggerController_TriggerWorkerHeartbeatServer) error

func (UnimplementedTriggerControllerServer) UnregisterTriggerWorker 

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

func (UnimplementedTriggerControllerServer) UpdateSubscription 

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

type UnregisterSegmentServerRequest 

type UnregisterSegmentServerRequest struct {
	Address  string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	VolumeId uint64 `protobuf:"varint,3,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterSegmentServerRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterSegmentServerRequest.ProtoReflect.Descriptor instead.

func (*UnregisterSegmentServerRequest) GetAddress 

func (x *UnregisterSegmentServerRequest) GetAddress() string

func (*UnregisterSegmentServerRequest) GetVolumeId 

func (x *UnregisterSegmentServerRequest) GetVolumeId() uint64

func (*UnregisterSegmentServerRequest) ProtoMessage 

func (*UnregisterSegmentServerRequest) ProtoMessage()

func (*UnregisterSegmentServerRequest) ProtoReflect 

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

func (*UnregisterSegmentServerRequest) Reset 

func (x *UnregisterSegmentServerRequest) Reset()

func (*UnregisterSegmentServerRequest) String 

func (x *UnregisterSegmentServerRequest) String() string

type UnregisterSegmentServerResponse 

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

func (*UnregisterSegmentServerResponse) Descriptor deprecated 

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

Deprecated: Use UnregisterSegmentServerResponse.ProtoReflect.Descriptor instead.

func (*UnregisterSegmentServerResponse) ProtoMessage 

func (*UnregisterSegmentServerResponse) ProtoMessage()

func (*UnregisterSegmentServerResponse) ProtoReflect 

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

func (*UnregisterSegmentServerResponse) Reset 

func (x *UnregisterSegmentServerResponse) Reset()

func (*UnregisterSegmentServerResponse) String 

func (x *UnregisterSegmentServerResponse) String() string

type UnregisterTriggerWorkerRequest 

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

func (*UnregisterTriggerWorkerRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterTriggerWorkerRequest.ProtoReflect.Descriptor instead.

func (*UnregisterTriggerWorkerRequest) GetAddress 

func (x *UnregisterTriggerWorkerRequest) GetAddress() string

func (*UnregisterTriggerWorkerRequest) ProtoMessage 

func (*UnregisterTriggerWorkerRequest) ProtoMessage()

func (*UnregisterTriggerWorkerRequest) ProtoReflect 

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

func (*UnregisterTriggerWorkerRequest) Reset 

func (x *UnregisterTriggerWorkerRequest) Reset()

func (*UnregisterTriggerWorkerRequest) String 

func (x *UnregisterTriggerWorkerRequest) String() string

type UnregisterTriggerWorkerResponse 

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

func (*UnregisterTriggerWorkerResponse) Descriptor deprecated 

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

Deprecated: Use UnregisterTriggerWorkerResponse.ProtoReflect.Descriptor instead.

func (*UnregisterTriggerWorkerResponse) ProtoMessage 

func (*UnregisterTriggerWorkerResponse) ProtoMessage()

func (*UnregisterTriggerWorkerResponse) ProtoReflect 

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

func (*UnregisterTriggerWorkerResponse) Reset 

func (x *UnregisterTriggerWorkerResponse) Reset()

func (*UnregisterTriggerWorkerResponse) String 

func (x *UnregisterTriggerWorkerResponse) String() string

type UnsafeAuthControllerServer 

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

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

type UnsafeEventbusControllerServer 

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

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

type UnsafeEventlogControllerServer 

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

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

type UnsafeNamespaceControllerServer 

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

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

type UnsafePingServerServer 

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

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

type UnsafeSegmentControllerServer 

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

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

type UnsafeSnowflakeControllerServer 

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

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

type UnsafeTriggerControllerServer 

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

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

type UpdateEventbusRequest 

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

func (*UpdateEventbusRequest) Descriptor deprecated 

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

Deprecated: Use UpdateEventbusRequest.ProtoReflect.Descriptor instead.

func (*UpdateEventbusRequest) ProtoMessage 

func (*UpdateEventbusRequest) ProtoMessage()

func (*UpdateEventbusRequest) ProtoReflect 

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

func (*UpdateEventbusRequest) Reset 

func (x *UpdateEventbusRequest) Reset()

func (*UpdateEventbusRequest) String 

func (x *UpdateEventbusRequest) String() string

type UpdateSubscriptionRequest 

type UpdateSubscriptionRequest struct {
	Id           uint64               `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Subscription *SubscriptionRequest `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*UpdateSubscriptionRequest) GetId 

func (x *UpdateSubscriptionRequest) GetId() uint64

func (*UpdateSubscriptionRequest) GetSubscription 

func (x *UpdateSubscriptionRequest) GetSubscription() *SubscriptionRequest

func (*UpdateSubscriptionRequest) ProtoMessage 

func (*UpdateSubscriptionRequest) ProtoMessage()

func (*UpdateSubscriptionRequest) ProtoReflect 

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

func (*UpdateSubscriptionRequest) Reset 

func (x *UpdateSubscriptionRequest) Reset()

func (*UpdateSubscriptionRequest) String 

func (x *UpdateSubscriptionRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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