controller

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Sep 7, 2023 License: Apache-2.0 Imports: 14 Imported by: 3

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: "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: "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: "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_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: "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: "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: "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: "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: "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 added in v0.8.0

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 added in v0.8.0

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 added in v0.8.0

func NewAuthControllerClient(cc grpc.ClientConnInterface) AuthControllerClient

type AuthControllerServer added in v0.8.0

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 added in v0.9.0

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 added in v0.9.0

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 added in v0.9.0

func (x *CreateSubscriptionRequest) GetId() uint64

func (*CreateSubscriptionRequest) GetSubscription

func (x *CreateSubscriptionRequest) GetSubscription() *SubscriptionRequest

func (*CreateSubscriptionRequest) ProtoMessage

func (*CreateSubscriptionRequest) ProtoMessage()

func (*CreateSubscriptionRequest) ProtoReflect

func (*CreateSubscriptionRequest) Reset

func (x *CreateSubscriptionRequest) Reset()

func (*CreateSubscriptionRequest) String

func (x *CreateSubscriptionRequest) String() string

type CreateTokenRequest added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use CreateTokenRequest.ProtoReflect.Descriptor instead.

func (*CreateTokenRequest) GetDescription added in v0.8.0

func (x *CreateTokenRequest) GetDescription() string

func (*CreateTokenRequest) GetUserIdentifier added in v0.8.0

func (x *CreateTokenRequest) GetUserIdentifier() string

func (*CreateTokenRequest) ProtoMessage added in v0.8.0

func (*CreateTokenRequest) ProtoMessage()

func (*CreateTokenRequest) ProtoReflect added in v0.8.0

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

func (*CreateTokenRequest) Reset added in v0.8.0

func (x *CreateTokenRequest) Reset()

func (*CreateTokenRequest) String added in v0.8.0

func (x *CreateTokenRequest) String() string

type CreateUserRequest added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.

func (*CreateUserRequest) GetDescription added in v0.8.0

func (x *CreateUserRequest) GetDescription() string

func (*CreateUserRequest) GetIdentifier added in v0.8.0

func (x *CreateUserRequest) GetIdentifier() string

func (*CreateUserRequest) ProtoMessage added in v0.8.0

func (*CreateUserRequest) ProtoMessage()

func (*CreateUserRequest) ProtoReflect added in v0.8.0

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

func (*CreateUserRequest) Reset added in v0.8.0

func (x *CreateUserRequest) Reset()

func (*CreateUserRequest) String added in v0.8.0

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 (*DeleteSubscriptionRequest) Reset

func (x *DeleteSubscriptionRequest) Reset()

func (*DeleteSubscriptionRequest) String

func (x *DeleteSubscriptionRequest) String() string

type DeleteTokenRequest added in v0.8.0

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

func (*DeleteTokenRequest) Descriptor deprecated added in v0.8.0

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

Deprecated: Use DeleteTokenRequest.ProtoReflect.Descriptor instead.

func (*DeleteTokenRequest) GetId added in v0.8.0

func (x *DeleteTokenRequest) GetId() uint64

func (*DeleteTokenRequest) ProtoMessage added in v0.8.0

func (*DeleteTokenRequest) ProtoMessage()

func (*DeleteTokenRequest) ProtoReflect added in v0.8.0

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

func (*DeleteTokenRequest) Reset added in v0.8.0

func (x *DeleteTokenRequest) Reset()

func (*DeleteTokenRequest) String added in v0.8.0

func (x *DeleteTokenRequest) String() string

type DeleteUserResponse added in v0.8.0

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

func (*DeleteUserResponse) Descriptor deprecated added in v0.8.0

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

Deprecated: Use DeleteUserResponse.ProtoReflect.Descriptor instead.

func (*DeleteUserResponse) GetIdentifier added in v0.8.0

func (x *DeleteUserResponse) GetIdentifier() string

func (*DeleteUserResponse) ProtoMessage added in v0.8.0

func (*DeleteUserResponse) ProtoMessage()

func (*DeleteUserResponse) ProtoReflect added in v0.8.0

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

func (*DeleteUserResponse) Reset added in v0.8.0

func (x *DeleteUserResponse) Reset()

func (*DeleteUserResponse) String added in v0.8.0

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 added in v0.8.0

func (x *DisableSubscriptionRequest) GetDeclaratively() bool

func (*DisableSubscriptionRequest) GetId

func (*DisableSubscriptionRequest) ProtoMessage

func (*DisableSubscriptionRequest) ProtoMessage()

func (*DisableSubscriptionRequest) ProtoReflect

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.

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.

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 (*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 (*GetAppendableSegmentResponse) Reset

func (x *GetAppendableSegmentResponse) Reset()

func (*GetAppendableSegmentResponse) 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 (*GetDeadLetterEventOffsetRequest) Reset

func (*GetDeadLetterEventOffsetRequest) 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 (*GetDeadLetterEventOffsetResponse) ProtoMessage

func (*GetDeadLetterEventOffsetResponse) ProtoMessage()

func (*GetDeadLetterEventOffsetResponse) ProtoReflect

func (*GetDeadLetterEventOffsetResponse) Reset

func (*GetDeadLetterEventOffsetResponse) 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 (*GetEventbusWithHumanFriendlyRequest) Reset

func (*GetEventbusWithHumanFriendlyRequest) 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 added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use GetResourceRoleRequest.ProtoReflect.Descriptor instead.

func (*GetResourceRoleRequest) GetId added in v0.8.0

func (x *GetResourceRoleRequest) GetId() uint64

func (*GetResourceRoleRequest) GetKind added in v0.8.0

func (x *GetResourceRoleRequest) GetKind() string

func (*GetResourceRoleRequest) ProtoMessage added in v0.8.0

func (*GetResourceRoleRequest) ProtoMessage()

func (*GetResourceRoleRequest) ProtoReflect added in v0.8.0

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

func (*GetResourceRoleRequest) Reset added in v0.8.0

func (x *GetResourceRoleRequest) Reset()

func (*GetResourceRoleRequest) String added in v0.8.0

func (x *GetResourceRoleRequest) String() string

type GetResourceRoleResponse added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use GetResourceRoleResponse.ProtoReflect.Descriptor instead.

func (*GetResourceRoleResponse) GetResourceRole added in v0.8.0

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

func (*GetResourceRoleResponse) ProtoMessage added in v0.8.0

func (*GetResourceRoleResponse) ProtoMessage()

func (*GetResourceRoleResponse) ProtoReflect added in v0.8.0

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

func (*GetResourceRoleResponse) Reset added in v0.8.0

func (x *GetResourceRoleResponse) Reset()

func (*GetResourceRoleResponse) String added in v0.8.0

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 added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use GetTokenResponse.ProtoReflect.Descriptor instead.

func (*GetTokenResponse) GetToken added in v0.8.0

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

func (*GetTokenResponse) ProtoMessage added in v0.8.0

func (*GetTokenResponse) ProtoMessage()

func (*GetTokenResponse) ProtoReflect added in v0.8.0

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

func (*GetTokenResponse) Reset added in v0.8.0

func (x *GetTokenResponse) Reset()

func (*GetTokenResponse) String added in v0.8.0

func (x *GetTokenResponse) String() string

type GetUserRoleRequest added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use GetUserRoleRequest.ProtoReflect.Descriptor instead.

func (*GetUserRoleRequest) GetUserIdentifier added in v0.8.0

func (x *GetUserRoleRequest) GetUserIdentifier() string

func (*GetUserRoleRequest) ProtoMessage added in v0.8.0

func (*GetUserRoleRequest) ProtoMessage()

func (*GetUserRoleRequest) ProtoReflect added in v0.8.0

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

func (*GetUserRoleRequest) Reset added in v0.8.0

func (x *GetUserRoleRequest) Reset()

func (*GetUserRoleRequest) String added in v0.8.0

func (x *GetUserRoleRequest) String() string

type GetUserRoleResponse added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use GetUserRoleResponse.ProtoReflect.Descriptor instead.

func (*GetUserRoleResponse) GetUserRole added in v0.8.0

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

func (*GetUserRoleResponse) ProtoMessage added in v0.8.0

func (*GetUserRoleResponse) ProtoMessage()

func (*GetUserRoleResponse) ProtoReflect added in v0.8.0

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

func (*GetUserRoleResponse) Reset added in v0.8.0

func (x *GetUserRoleResponse) Reset()

func (*GetUserRoleResponse) String added in v0.8.0

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 added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use ListTokenResponse.ProtoReflect.Descriptor instead.

func (*ListTokenResponse) GetToken added in v0.8.0

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

func (*ListTokenResponse) ProtoMessage added in v0.8.0

func (*ListTokenResponse) ProtoMessage()

func (*ListTokenResponse) ProtoReflect added in v0.8.0

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

func (*ListTokenResponse) Reset added in v0.8.0

func (x *ListTokenResponse) Reset()

func (*ListTokenResponse) String added in v0.8.0

func (x *ListTokenResponse) String() string

type ListUserResponse added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use ListUserResponse.ProtoReflect.Descriptor instead.

func (*ListUserResponse) GetUsers added in v0.8.0

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

func (*ListUserResponse) ProtoMessage added in v0.8.0

func (*ListUserResponse) ProtoMessage()

func (*ListUserResponse) ProtoReflect added in v0.8.0

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

func (*ListUserResponse) Reset added in v0.8.0

func (x *ListUserResponse) Reset()

func (*ListUserResponse) String added in v0.8.0

func (x *ListUserResponse) String() string

type MockAuthControllerClient added in v0.8.0

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

MockAuthControllerClient is a mock of AuthControllerClient interface.

func NewMockAuthControllerClient added in v0.8.0

func NewMockAuthControllerClient(ctrl *gomock.Controller) *MockAuthControllerClient

NewMockAuthControllerClient creates a new mock instance.

func (*MockAuthControllerClient) CreateToken added in v0.8.0

CreateToken mocks base method.

func (*MockAuthControllerClient) CreateUser added in v0.8.0

CreateUser mocks base method.

func (*MockAuthControllerClient) DeleteToken added in v0.8.0

DeleteToken mocks base method.

func (*MockAuthControllerClient) DeleteUser added in v0.8.0

DeleteUser mocks base method.

func (*MockAuthControllerClient) EXPECT added in v0.8.0

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

func (*MockAuthControllerClient) GetResourceRole added in v0.8.0

GetResourceRole mocks base method.

func (*MockAuthControllerClient) GetToken added in v0.8.0

GetToken mocks base method.

func (*MockAuthControllerClient) GetUser added in v0.8.0

GetUser mocks base method.

func (*MockAuthControllerClient) GetUserByToken added in v0.8.0

GetUserByToken mocks base method.

func (*MockAuthControllerClient) GetUserRole added in v0.8.0

GetUserRole mocks base method.

func (*MockAuthControllerClient) GetUserToken added in v0.8.0

GetUserToken mocks base method.

func (*MockAuthControllerClient) GrantRole added in v0.8.0

GrantRole mocks base method.

func (*MockAuthControllerClient) ListToken added in v0.8.0

ListToken mocks base method.

func (*MockAuthControllerClient) ListUser added in v0.8.0

ListUser mocks base method.

func (*MockAuthControllerClient) RevokeRole added in v0.8.0

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

RevokeRole mocks base method.

type MockAuthControllerClientMockRecorder added in v0.8.0

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

MockAuthControllerClientMockRecorder is the mock recorder for MockAuthControllerClient.

func (*MockAuthControllerClientMockRecorder) CreateToken added in v0.8.0

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

CreateToken indicates an expected call of CreateToken.

func (*MockAuthControllerClientMockRecorder) CreateUser added in v0.8.0

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

CreateUser indicates an expected call of CreateUser.

func (*MockAuthControllerClientMockRecorder) DeleteToken added in v0.8.0

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

DeleteToken indicates an expected call of DeleteToken.

func (*MockAuthControllerClientMockRecorder) DeleteUser added in v0.8.0

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

DeleteUser indicates an expected call of DeleteUser.

func (*MockAuthControllerClientMockRecorder) GetResourceRole added in v0.8.0

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

GetResourceRole indicates an expected call of GetResourceRole.

func (*MockAuthControllerClientMockRecorder) GetToken added in v0.8.0

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

GetToken indicates an expected call of GetToken.

func (*MockAuthControllerClientMockRecorder) GetUser added in v0.8.0

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

GetUser indicates an expected call of GetUser.

func (*MockAuthControllerClientMockRecorder) GetUserByToken added in v0.8.0

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

GetUserByToken indicates an expected call of GetUserByToken.

func (*MockAuthControllerClientMockRecorder) GetUserRole added in v0.8.0

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

GetUserRole indicates an expected call of GetUserRole.

func (*MockAuthControllerClientMockRecorder) GetUserToken added in v0.8.0

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

GetUserToken indicates an expected call of GetUserToken.

func (*MockAuthControllerClientMockRecorder) GrantRole added in v0.8.0

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

GrantRole indicates an expected call of GrantRole.

func (*MockAuthControllerClientMockRecorder) ListToken added in v0.8.0

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

ListToken indicates an expected call of ListToken.

func (*MockAuthControllerClientMockRecorder) ListUser added in v0.8.0

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

ListUser indicates an expected call of ListUser.

func (*MockAuthControllerClientMockRecorder) RevokeRole added in v0.8.0

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

RevokeRole indicates an expected call of RevokeRole.

type MockAuthControllerServer added in v0.8.0

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

MockAuthControllerServer is a mock of AuthControllerServer interface.

func NewMockAuthControllerServer added in v0.8.0

func NewMockAuthControllerServer(ctrl *gomock.Controller) *MockAuthControllerServer

NewMockAuthControllerServer creates a new mock instance.

func (*MockAuthControllerServer) CreateToken added in v0.8.0

CreateToken mocks base method.

func (*MockAuthControllerServer) CreateUser added in v0.8.0

CreateUser mocks base method.

func (*MockAuthControllerServer) DeleteToken added in v0.8.0

DeleteToken mocks base method.

func (*MockAuthControllerServer) DeleteUser added in v0.8.0

DeleteUser mocks base method.

func (*MockAuthControllerServer) EXPECT added in v0.8.0

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

func (*MockAuthControllerServer) GetResourceRole added in v0.8.0

GetResourceRole mocks base method.

func (*MockAuthControllerServer) GetToken added in v0.8.0

GetToken mocks base method.

func (*MockAuthControllerServer) GetUser added in v0.8.0

GetUser mocks base method.

func (*MockAuthControllerServer) GetUserByToken added in v0.8.0

GetUserByToken mocks base method.

func (*MockAuthControllerServer) GetUserRole added in v0.8.0

GetUserRole mocks base method.

func (*MockAuthControllerServer) GetUserToken added in v0.8.0

GetUserToken mocks base method.

func (*MockAuthControllerServer) GrantRole added in v0.8.0

GrantRole mocks base method.

func (*MockAuthControllerServer) ListToken added in v0.8.0

ListToken mocks base method.

func (*MockAuthControllerServer) ListUser added in v0.8.0

ListUser mocks base method.

func (*MockAuthControllerServer) RevokeRole added in v0.8.0

RevokeRole mocks base method.

type MockAuthControllerServerMockRecorder added in v0.8.0

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

MockAuthControllerServerMockRecorder is the mock recorder for MockAuthControllerServer.

func (*MockAuthControllerServerMockRecorder) CreateToken added in v0.8.0

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

CreateToken indicates an expected call of CreateToken.

func (*MockAuthControllerServerMockRecorder) CreateUser added in v0.8.0

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

CreateUser indicates an expected call of CreateUser.

func (*MockAuthControllerServerMockRecorder) DeleteToken added in v0.8.0

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

DeleteToken indicates an expected call of DeleteToken.

func (*MockAuthControllerServerMockRecorder) DeleteUser added in v0.8.0

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

DeleteUser indicates an expected call of DeleteUser.

func (*MockAuthControllerServerMockRecorder) GetResourceRole added in v0.8.0

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

GetResourceRole indicates an expected call of GetResourceRole.

func (*MockAuthControllerServerMockRecorder) GetToken added in v0.8.0

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

GetToken indicates an expected call of GetToken.

func (*MockAuthControllerServerMockRecorder) GetUser added in v0.8.0

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

GetUser indicates an expected call of GetUser.

func (*MockAuthControllerServerMockRecorder) GetUserByToken added in v0.8.0

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

GetUserByToken indicates an expected call of GetUserByToken.

func (*MockAuthControllerServerMockRecorder) GetUserRole added in v0.8.0

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

GetUserRole indicates an expected call of GetUserRole.

func (*MockAuthControllerServerMockRecorder) GetUserToken added in v0.8.0

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

GetUserToken indicates an expected call of GetUserToken.

func (*MockAuthControllerServerMockRecorder) GrantRole added in v0.8.0

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

GrantRole indicates an expected call of GrantRole.

func (*MockAuthControllerServerMockRecorder) ListToken added in v0.8.0

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

ListToken indicates an expected call of ListToken.

func (*MockAuthControllerServerMockRecorder) ListUser added in v0.8.0

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

ListUser indicates an expected call of ListUser.

func (*MockAuthControllerServerMockRecorder) RevokeRole added in v0.8.0

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

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

DeleteEventbus mocks base method.

func (*MockEventbusControllerClient) EXPECT

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

func (*MockEventbusControllerClient) GetEventbus

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

ListEventbus mocks base method.

func (*MockEventbusControllerClient) UpdateEventbus

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

CreateEventbus mocks base method.

func (*MockEventbusControllerServer) CreateSystemEventbus

CreateSystemEventbus mocks base method.

func (*MockEventbusControllerServer) DeleteEventbus

DeleteEventbus mocks base method.

func (*MockEventbusControllerServer) EXPECT

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

func (*MockEventbusControllerServer) GetEventbus

GetEventbus mocks base method.

func (*MockEventbusControllerServer) GetEventbusWithHumanFriendly

GetEventbusWithHumanFriendly mocks base method.

func (*MockEventbusControllerServer) ListEventbus

ListEventbus mocks base method.

func (*MockEventbusControllerServer) UpdateEventbus

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

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

func (*MockEventlogControllerClient) GetAppendableSegment

GetAppendableSegment mocks base method.

func (*MockEventlogControllerClient) ListSegment

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

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

func (*MockEventlogControllerServer) GetAppendableSegment

GetAppendableSegment mocks base method.

func (*MockEventlogControllerServer) ListSegment

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

CreateNamespace mocks base method.

func (*MockNamespaceControllerClient) DeleteNamespace

DeleteNamespace mocks base method.

func (*MockNamespaceControllerClient) EXPECT

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

func (*MockNamespaceControllerClient) GetNamespace

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

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

CreateNamespace mocks base method.

func (*MockNamespaceControllerServer) DeleteNamespace

DeleteNamespace mocks base method.

func (*MockNamespaceControllerServer) EXPECT

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

func (*MockNamespaceControllerServer) GetNamespace

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

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

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

func (*MockPingServerClient) Ping

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

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

func (*MockPingServerServer) Ping

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

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

func (*MockSegmentControllerClient) QuerySegmentRouteInfo

QuerySegmentRouteInfo mocks base method.

func (*MockSegmentControllerClient) RegisterSegmentServer

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

ReportSegmentLeader mocks base method.

func (*MockSegmentControllerClient) SegmentHeartbeat

SegmentHeartbeat mocks base method.

func (*MockSegmentControllerClient) UnregisterSegmentServer

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

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

func (*MockSegmentControllerServer) QuerySegmentRouteInfo

QuerySegmentRouteInfo mocks base method.

func (*MockSegmentControllerServer) RegisterSegmentServer

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

ReportSegmentLeader mocks base method.

func (*MockSegmentControllerServer) SegmentHeartbeat

SegmentHeartbeat mocks base method.

func (*MockSegmentControllerServer) UnregisterSegmentServer

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

CloseAndRecv mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) CloseSend

CloseSend mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) Context

Context mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) EXPECT

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

func (*MockSegmentController_SegmentHeartbeatClient) Header

Header mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) RecvMsg

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

RecvMsg mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) Send

Send mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) SendMsg

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

SendMsg mocks base method.

func (*MockSegmentController_SegmentHeartbeatClient) Trailer

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

CloseAndRecv indicates an expected call of CloseAndRecv.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) CloseSend

CloseSend indicates an expected call of CloseSend.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) Context

Context indicates an expected call of Context.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) Header

Header indicates an expected call of Header.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) RecvMsg

RecvMsg indicates an expected call of RecvMsg.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) Send

Send indicates an expected call of Send.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) SendMsg

SendMsg indicates an expected call of SendMsg.

func (*MockSegmentController_SegmentHeartbeatClientMockRecorder) Trailer

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

Context mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) EXPECT

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

func (*MockSegmentController_SegmentHeartbeatServer) Recv

Recv mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) RecvMsg

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

RecvMsg mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SendAndClose

SendAndClose mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SendHeader

SendHeader mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SendMsg

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

SendMsg mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SetHeader

SetHeader mocks base method.

func (*MockSegmentController_SegmentHeartbeatServer) SetTrailer

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

Context indicates an expected call of Context.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) Recv

Recv indicates an expected call of Recv.

func (*MockSegmentController_SegmentHeartbeatServerMockRecorder) RecvMsg

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

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

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

RegisterNode mocks base method.

func (*MockSnowflakeControllerClient) UnregisterNode

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

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

func (*MockSnowflakeControllerServer) GetClusterStartTime

GetClusterStartTime mocks base method.

func (*MockSnowflakeControllerServer) RegisterNode

RegisterNode mocks base method.

func (*MockSnowflakeControllerServer) UnregisterNode

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

CommitOffset mocks base method.

func (*MockTriggerControllerClient) CreateSubscription

CreateSubscription mocks base method.

func (*MockTriggerControllerClient) DeleteSubscription

DeleteSubscription mocks base method.

func (*MockTriggerControllerClient) DisableSubscription

DisableSubscription mocks base method.

func (*MockTriggerControllerClient) EXPECT

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

func (*MockTriggerControllerClient) GetDeadLetterEventOffset

GetDeadLetterEventOffset mocks base method.

func (*MockTriggerControllerClient) GetSubscription

GetSubscription mocks base method.

func (*MockTriggerControllerClient) ListSubscription

ListSubscription mocks base method.

func (*MockTriggerControllerClient) RegisterTriggerWorker

RegisterTriggerWorker mocks base method.

func (*MockTriggerControllerClient) ResetOffsetToTimestamp

ResetOffsetToTimestamp mocks base method.

func (*MockTriggerControllerClient) ResumeSubscription

ResumeSubscription mocks base method.

func (*MockTriggerControllerClient) SetDeadLetterEventOffset

SetDeadLetterEventOffset mocks base method.

func (*MockTriggerControllerClient) TriggerWorkerHeartbeat

TriggerWorkerHeartbeat mocks base method.

func (*MockTriggerControllerClient) UnregisterTriggerWorker

UnregisterTriggerWorker mocks base method.

func (*MockTriggerControllerClient) UpdateSubscription

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

CommitOffset mocks base method.

func (*MockTriggerControllerServer) CreateSubscription

CreateSubscription mocks base method.

func (*MockTriggerControllerServer) DeleteSubscription

DeleteSubscription mocks base method.

func (*MockTriggerControllerServer) DisableSubscription

DisableSubscription mocks base method.

func (*MockTriggerControllerServer) EXPECT

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

func (*MockTriggerControllerServer) GetDeadLetterEventOffset

GetDeadLetterEventOffset mocks base method.

func (*MockTriggerControllerServer) GetSubscription

GetSubscription mocks base method.

func (*MockTriggerControllerServer) ListSubscription

ListSubscription mocks base method.

func (*MockTriggerControllerServer) RegisterTriggerWorker

RegisterTriggerWorker mocks base method.

func (*MockTriggerControllerServer) ResetOffsetToTimestamp

ResetOffsetToTimestamp mocks base method.

func (*MockTriggerControllerServer) ResumeSubscription

ResumeSubscription mocks base method.

func (*MockTriggerControllerServer) SetDeadLetterEventOffset

SetDeadLetterEventOffset mocks base method.

func (*MockTriggerControllerServer) TriggerWorkerHeartbeat

TriggerWorkerHeartbeat mocks base method.

func (*MockTriggerControllerServer) UnregisterTriggerWorker

UnregisterTriggerWorker mocks base method.

func (*MockTriggerControllerServer) UpdateSubscription

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

CloseAndRecv mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) CloseSend

CloseSend mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) Context

Context mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) EXPECT

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

func (*MockTriggerController_TriggerWorkerHeartbeatClient) Header

Header mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) RecvMsg

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

RecvMsg mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) Send

Send mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) SendMsg

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

SendMsg mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatClient) Trailer

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

CloseAndRecv indicates an expected call of CloseAndRecv.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) CloseSend

CloseSend indicates an expected call of CloseSend.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Context

Context indicates an expected call of Context.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Header

Header indicates an expected call of Header.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) RecvMsg

RecvMsg indicates an expected call of RecvMsg.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Send

Send indicates an expected call of Send.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) SendMsg

SendMsg indicates an expected call of SendMsg.

func (*MockTriggerController_TriggerWorkerHeartbeatClientMockRecorder) Trailer

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

Context mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) EXPECT

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

func (*MockTriggerController_TriggerWorkerHeartbeatServer) Recv

Recv mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) RecvMsg

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

RecvMsg mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SendAndClose

SendAndClose mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SendHeader

SendHeader mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SendMsg

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

SendMsg mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SetHeader

SetHeader mocks base method.

func (*MockTriggerController_TriggerWorkerHeartbeatServer) SetTrailer

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

Context indicates an expected call of Context.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) Recv

Recv indicates an expected call of Recv.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) RecvMsg

RecvMsg indicates an expected call of RecvMsg.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SendAndClose

SendAndClose indicates an expected call of SendAndClose.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SendHeader

SendHeader indicates an expected call of SendHeader.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SendMsg

SendMsg indicates an expected call of SendMsg.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SetHeader

SetHeader indicates an expected call of SetHeader.

func (*MockTriggerController_TriggerWorkerHeartbeatServerMockRecorder) SetTrailer

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.

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 (*QuerySegmentRouteInfoRequest) Reset

func (x *QuerySegmentRouteInfoRequest) Reset()

func (*QuerySegmentRouteInfoRequest) 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 (*QuerySegmentRouteInfoResponse) Reset

func (x *QuerySegmentRouteInfoResponse) Reset()

func (*QuerySegmentRouteInfoResponse) 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 (*RegisterSegmentServerRequest) Reset

func (x *RegisterSegmentServerRequest) Reset()

func (*RegisterSegmentServerRequest) 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 (*RegisterSegmentServerResponse) Reset

func (x *RegisterSegmentServerResponse) Reset()

func (*RegisterSegmentServerResponse) 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 (*RegisterTriggerWorkerRequest) Reset

func (x *RegisterTriggerWorkerRequest) Reset()

func (*RegisterTriggerWorkerRequest) 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 (*RegisterTriggerWorkerResponse) Reset

func (x *RegisterTriggerWorkerResponse) Reset()

func (*RegisterTriggerWorkerResponse) 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 (*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 (*ResetOffsetToTimestampRequest) Reset

func (x *ResetOffsetToTimestampRequest) Reset()

func (*ResetOffsetToTimestampRequest) 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 (*ResetOffsetToTimestampResponse) Reset

func (x *ResetOffsetToTimestampResponse) Reset()

func (*ResetOffsetToTimestampResponse) 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 (*ResumeSubscriptionRequest) Reset

func (x *ResumeSubscriptionRequest) Reset()

func (*ResumeSubscriptionRequest) String

func (x *ResumeSubscriptionRequest) String() string

type RoleRequest added in v0.8.0

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 added in v0.8.0

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

Deprecated: Use RoleRequest.ProtoReflect.Descriptor instead.

func (*RoleRequest) GetResourceId added in v0.8.0

func (x *RoleRequest) GetResourceId() uint64

func (*RoleRequest) GetResourceKind added in v0.8.0

func (x *RoleRequest) GetResourceKind() string

func (*RoleRequest) GetRoleId added in v0.8.0

func (x *RoleRequest) GetRoleId() string

func (*RoleRequest) GetRoleName added in v0.8.0

func (x *RoleRequest) GetRoleName() string

func (*RoleRequest) GetUserIdentifier added in v0.8.0

func (x *RoleRequest) GetUserIdentifier() string

func (*RoleRequest) ProtoMessage added in v0.8.0

func (*RoleRequest) ProtoMessage()

func (*RoleRequest) ProtoReflect added in v0.8.0

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

func (*RoleRequest) Reset added in v0.8.0

func (x *RoleRequest) Reset()

func (*RoleRequest) String added in v0.8.0

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.

type SegmentControllerServer

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 (*SetDeadLetterEventOffsetRequest) Reset

func (*SetDeadLetterEventOffsetRequest) 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.

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 (*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.

type TriggerControllerServer

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 (*TriggerWorkerHeartbeatRequest) Reset

func (x *TriggerWorkerHeartbeatRequest) Reset()

func (*TriggerWorkerHeartbeatRequest) 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 (*TriggerWorkerHeartbeatResponse) Reset

func (x *TriggerWorkerHeartbeatResponse) Reset()

func (*TriggerWorkerHeartbeatResponse) String

type UnimplementedAuthControllerServer added in v0.8.0

type UnimplementedAuthControllerServer struct {
}

UnimplementedAuthControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedAuthControllerServer) CreateToken added in v0.8.0

func (UnimplementedAuthControllerServer) CreateUser added in v0.8.0

func (UnimplementedAuthControllerServer) DeleteToken added in v0.8.0

func (UnimplementedAuthControllerServer) DeleteUser added in v0.8.0

func (UnimplementedAuthControllerServer) GetResourceRole added in v0.8.0

func (UnimplementedAuthControllerServer) GetToken added in v0.8.0

func (UnimplementedAuthControllerServer) GetUser added in v0.8.0

func (UnimplementedAuthControllerServer) GetUserByToken added in v0.8.0

func (UnimplementedAuthControllerServer) GetUserRole added in v0.8.0

func (UnimplementedAuthControllerServer) GetUserToken added in v0.8.0

func (UnimplementedAuthControllerServer) GrantRole added in v0.8.0

func (UnimplementedAuthControllerServer) ListToken added in v0.8.0

func (UnimplementedAuthControllerServer) ListUser added in v0.8.0

func (UnimplementedAuthControllerServer) RevokeRole added in v0.8.0

type UnimplementedEventbusControllerServer

type UnimplementedEventbusControllerServer struct {
}

UnimplementedEventbusControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedEventbusControllerServer) CreateEventbus

func (UnimplementedEventbusControllerServer) CreateSystemEventbus

func (UnimplementedEventbusControllerServer) DeleteEventbus

func (UnimplementedEventbusControllerServer) GetEventbus

func (UnimplementedEventbusControllerServer) GetEventbusWithHumanFriendly

func (UnimplementedEventbusControllerServer) ListEventbus

func (UnimplementedEventbusControllerServer) UpdateEventbus

type UnimplementedEventlogControllerServer

type UnimplementedEventlogControllerServer struct {
}

UnimplementedEventlogControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedEventlogControllerServer) GetAppendableSegment

func (UnimplementedEventlogControllerServer) ListSegment

type UnimplementedNamespaceControllerServer

type UnimplementedNamespaceControllerServer struct {
}

UnimplementedNamespaceControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedNamespaceControllerServer) CreateNamespace

func (UnimplementedNamespaceControllerServer) DeleteNamespace

func (UnimplementedNamespaceControllerServer) GetNamespace

func (UnimplementedNamespaceControllerServer) GetNamespaceWithHumanFriendly

func (UnimplementedNamespaceControllerServer) ListNamespace

type UnimplementedPingServerServer

type UnimplementedPingServerServer struct {
}

UnimplementedPingServerServer should be embedded to have forward compatible implementations.

func (UnimplementedPingServerServer) Ping

type UnimplementedSegmentControllerServer

type UnimplementedSegmentControllerServer struct {
}

UnimplementedSegmentControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedSegmentControllerServer) ReportSegmentBlockIsFull

func (UnimplementedSegmentControllerServer) ReportSegmentLeader

func (UnimplementedSegmentControllerServer) SegmentHeartbeat

type UnimplementedSnowflakeControllerServer

type UnimplementedSnowflakeControllerServer struct {
}

UnimplementedSnowflakeControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedSnowflakeControllerServer) GetClusterStartTime

func (UnimplementedSnowflakeControllerServer) RegisterNode

func (UnimplementedSnowflakeControllerServer) UnregisterNode

type UnimplementedTriggerControllerServer

type UnimplementedTriggerControllerServer struct {
}

UnimplementedTriggerControllerServer should be embedded to have forward compatible implementations.

func (UnimplementedTriggerControllerServer) CommitOffset

func (UnimplementedTriggerControllerServer) CreateSubscription

func (UnimplementedTriggerControllerServer) DeleteSubscription

func (UnimplementedTriggerControllerServer) DisableSubscription

func (UnimplementedTriggerControllerServer) GetSubscription

func (UnimplementedTriggerControllerServer) ListSubscription

func (UnimplementedTriggerControllerServer) ResumeSubscription

func (UnimplementedTriggerControllerServer) SetDeadLetterEventOffset

func (UnimplementedTriggerControllerServer) TriggerWorkerHeartbeat

func (UnimplementedTriggerControllerServer) UpdateSubscription

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 (*UnregisterSegmentServerRequest) Reset

func (x *UnregisterSegmentServerRequest) Reset()

func (*UnregisterSegmentServerRequest) 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 (*UnregisterSegmentServerResponse) Reset

func (*UnregisterSegmentServerResponse) 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 (*UnregisterTriggerWorkerRequest) Reset

func (x *UnregisterTriggerWorkerRequest) Reset()

func (*UnregisterTriggerWorkerRequest) 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 (*UnregisterTriggerWorkerResponse) Reset

func (*UnregisterTriggerWorkerResponse) String

type UnsafeAuthControllerServer added in v0.8.0

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 (*UpdateSubscriptionRequest) Reset

func (x *UpdateSubscriptionRequest) Reset()

func (*UpdateSubscriptionRequest) String

func (x *UpdateSubscriptionRequest) String() string

Jump to

Keyboard shortcuts

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