Documentation ¶
Index ¶
- Variables
- func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)
- type AddCDNToCDNClusterRequest
- func (*AddCDNToCDNClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddCDNToCDNClusterRequest) GetCdnClusterId() uint64
- func (x *AddCDNToCDNClusterRequest) GetCdnId() uint64
- func (x *AddCDNToCDNClusterRequest) GetSourceType() SourceType
- func (*AddCDNToCDNClusterRequest) ProtoMessage()
- func (x *AddCDNToCDNClusterRequest) ProtoReflect() protoreflect.Message
- func (x *AddCDNToCDNClusterRequest) Reset()
- func (x *AddCDNToCDNClusterRequest) String() string
- func (m *AddCDNToCDNClusterRequest) Validate() error
- type AddCDNToCDNClusterRequestValidationError
- func (e AddCDNToCDNClusterRequestValidationError) Cause() error
- func (e AddCDNToCDNClusterRequestValidationError) Error() string
- func (e AddCDNToCDNClusterRequestValidationError) ErrorName() string
- func (e AddCDNToCDNClusterRequestValidationError) Field() string
- func (e AddCDNToCDNClusterRequestValidationError) Key() bool
- func (e AddCDNToCDNClusterRequestValidationError) Reason() string
- type AddSchedulerClusterToSchedulerClusterRequest
- func (*AddSchedulerClusterToSchedulerClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddSchedulerClusterToSchedulerClusterRequest) GetSchedulerClusterId() uint64
- func (x *AddSchedulerClusterToSchedulerClusterRequest) GetSchedulerId() uint64
- func (x *AddSchedulerClusterToSchedulerClusterRequest) GetSourceType() SourceType
- func (*AddSchedulerClusterToSchedulerClusterRequest) ProtoMessage()
- func (x *AddSchedulerClusterToSchedulerClusterRequest) ProtoReflect() protoreflect.Message
- func (x *AddSchedulerClusterToSchedulerClusterRequest) Reset()
- func (x *AddSchedulerClusterToSchedulerClusterRequest) String() string
- func (m *AddSchedulerClusterToSchedulerClusterRequest) Validate() error
- type AddSchedulerClusterToSchedulerClusterRequestValidationError
- func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Cause() error
- func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Error() string
- func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) ErrorName() string
- func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Field() string
- func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Key() bool
- func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Reason() string
- type CDN
- func (*CDN) Descriptor() ([]byte, []int)deprecated
- func (x *CDN) GetCdnCluster() *CDNCluster
- func (x *CDN) GetDownloadPort() int32
- func (x *CDN) GetHostName() string
- func (x *CDN) GetId() uint64
- func (x *CDN) GetIdc() string
- func (x *CDN) GetIp() string
- func (x *CDN) GetLocation() string
- func (x *CDN) GetPort() int32
- func (x *CDN) GetStatus() string
- func (*CDN) ProtoMessage()
- func (x *CDN) ProtoReflect() protoreflect.Message
- func (x *CDN) Reset()
- func (x *CDN) String() string
- func (m *CDN) Validate() error
- type CDNCluster
- func (*CDNCluster) Descriptor() ([]byte, []int)deprecated
- func (x *CDNCluster) GetBio() string
- func (x *CDNCluster) GetConfig() []byte
- func (x *CDNCluster) GetId() uint64
- func (x *CDNCluster) GetName() string
- func (x *CDNCluster) GetSecurityGroup() *SecurityGroup
- func (*CDNCluster) ProtoMessage()
- func (x *CDNCluster) ProtoReflect() protoreflect.Message
- func (x *CDNCluster) Reset()
- func (x *CDNCluster) String() string
- func (m *CDNCluster) Validate() error
- type CDNClusterValidationError
- type CDNValidationError
- type GetCDNRequest
- func (*GetCDNRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetCDNRequest) GetHostName() string
- func (x *GetCDNRequest) GetSourceType() SourceType
- func (*GetCDNRequest) ProtoMessage()
- func (x *GetCDNRequest) ProtoReflect() protoreflect.Message
- func (x *GetCDNRequest) Reset()
- func (x *GetCDNRequest) String() string
- func (m *GetCDNRequest) Validate() error
- type GetCDNRequestValidationError
- func (e GetCDNRequestValidationError) Cause() error
- func (e GetCDNRequestValidationError) Error() string
- func (e GetCDNRequestValidationError) ErrorName() string
- func (e GetCDNRequestValidationError) Field() string
- func (e GetCDNRequestValidationError) Key() bool
- func (e GetCDNRequestValidationError) Reason() string
- type GetSchedulerRequest
- func (*GetSchedulerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchedulerRequest) GetHostName() string
- func (x *GetSchedulerRequest) GetSourceType() SourceType
- func (*GetSchedulerRequest) ProtoMessage()
- func (x *GetSchedulerRequest) ProtoReflect() protoreflect.Message
- func (x *GetSchedulerRequest) Reset()
- func (x *GetSchedulerRequest) String() string
- func (m *GetSchedulerRequest) Validate() error
- type GetSchedulerRequestValidationError
- func (e GetSchedulerRequestValidationError) Cause() error
- func (e GetSchedulerRequestValidationError) Error() string
- func (e GetSchedulerRequestValidationError) ErrorName() string
- func (e GetSchedulerRequestValidationError) Field() string
- func (e GetSchedulerRequestValidationError) Key() bool
- func (e GetSchedulerRequestValidationError) Reason() string
- type KeepAliveRequest
- func (*KeepAliveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeepAliveRequest) GetHostName() string
- func (x *KeepAliveRequest) GetSourceType() SourceType
- func (*KeepAliveRequest) ProtoMessage()
- func (x *KeepAliveRequest) ProtoReflect() protoreflect.Message
- func (x *KeepAliveRequest) Reset()
- func (x *KeepAliveRequest) String() string
- func (m *KeepAliveRequest) Validate() error
- type KeepAliveRequestValidationError
- func (e KeepAliveRequestValidationError) Cause() error
- func (e KeepAliveRequestValidationError) Error() string
- func (e KeepAliveRequestValidationError) ErrorName() string
- func (e KeepAliveRequestValidationError) Field() string
- func (e KeepAliveRequestValidationError) Key() bool
- func (e KeepAliveRequestValidationError) Reason() string
- type ListSchedulersRequest
- func (*ListSchedulersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSchedulersRequest) GetHostInfo() map[string]string
- func (x *ListSchedulersRequest) GetHostName() string
- func (x *ListSchedulersRequest) GetIp() string
- func (x *ListSchedulersRequest) GetSourceType() SourceType
- func (*ListSchedulersRequest) ProtoMessage()
- func (x *ListSchedulersRequest) ProtoReflect() protoreflect.Message
- func (x *ListSchedulersRequest) Reset()
- func (x *ListSchedulersRequest) String() string
- func (m *ListSchedulersRequest) Validate() error
- type ListSchedulersRequestValidationError
- func (e ListSchedulersRequestValidationError) Cause() error
- func (e ListSchedulersRequestValidationError) Error() string
- func (e ListSchedulersRequestValidationError) ErrorName() string
- func (e ListSchedulersRequestValidationError) Field() string
- func (e ListSchedulersRequestValidationError) Key() bool
- func (e ListSchedulersRequestValidationError) Reason() string
- type ListSchedulersResponse
- func (*ListSchedulersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSchedulersResponse) GetSchedulers() []*Scheduler
- func (*ListSchedulersResponse) ProtoMessage()
- func (x *ListSchedulersResponse) ProtoReflect() protoreflect.Message
- func (x *ListSchedulersResponse) Reset()
- func (x *ListSchedulersResponse) String() string
- func (m *ListSchedulersResponse) Validate() error
- type ListSchedulersResponseValidationError
- func (e ListSchedulersResponseValidationError) Cause() error
- func (e ListSchedulersResponseValidationError) Error() string
- func (e ListSchedulersResponseValidationError) ErrorName() string
- func (e ListSchedulersResponseValidationError) Field() string
- func (e ListSchedulersResponseValidationError) Key() bool
- func (e ListSchedulersResponseValidationError) Reason() string
- type ManagerClient
- type ManagerServer
- type Manager_KeepAliveClient
- type Manager_KeepAliveServer
- type Scheduler
- func (*Scheduler) Descriptor() ([]byte, []int)deprecated
- func (x *Scheduler) GetCdns() []*CDN
- func (x *Scheduler) GetHostName() string
- func (x *Scheduler) GetId() uint64
- func (x *Scheduler) GetIdc() string
- func (x *Scheduler) GetIp() string
- func (x *Scheduler) GetLocation() string
- func (x *Scheduler) GetNetConfig() []byte
- func (x *Scheduler) GetPort() int32
- func (x *Scheduler) GetSchedulerCluster() *SchedulerCluster
- func (x *Scheduler) GetStatus() string
- func (x *Scheduler) GetVips() string
- func (*Scheduler) ProtoMessage()
- func (x *Scheduler) ProtoReflect() protoreflect.Message
- func (x *Scheduler) Reset()
- func (x *Scheduler) String() string
- func (m *Scheduler) Validate() error
- type SchedulerCluster
- func (*SchedulerCluster) Descriptor() ([]byte, []int)deprecated
- func (x *SchedulerCluster) GetBio() string
- func (x *SchedulerCluster) GetClientConfig() []byte
- func (x *SchedulerCluster) GetConfig() []byte
- func (x *SchedulerCluster) GetId() uint64
- func (x *SchedulerCluster) GetName() string
- func (x *SchedulerCluster) GetSecurityGroup() *SecurityGroup
- func (*SchedulerCluster) ProtoMessage()
- func (x *SchedulerCluster) ProtoReflect() protoreflect.Message
- func (x *SchedulerCluster) Reset()
- func (x *SchedulerCluster) String() string
- func (m *SchedulerCluster) Validate() error
- type SchedulerClusterValidationError
- func (e SchedulerClusterValidationError) Cause() error
- func (e SchedulerClusterValidationError) Error() string
- func (e SchedulerClusterValidationError) ErrorName() string
- func (e SchedulerClusterValidationError) Field() string
- func (e SchedulerClusterValidationError) Key() bool
- func (e SchedulerClusterValidationError) Reason() string
- type SchedulerValidationError
- type SecurityGroup
- func (*SecurityGroup) Descriptor() ([]byte, []int)deprecated
- func (x *SecurityGroup) GetBio() string
- func (x *SecurityGroup) GetDomain() string
- func (x *SecurityGroup) GetId() uint64
- func (x *SecurityGroup) GetName() string
- func (x *SecurityGroup) GetProxyDomain() string
- func (*SecurityGroup) ProtoMessage()
- func (x *SecurityGroup) ProtoReflect() protoreflect.Message
- func (x *SecurityGroup) Reset()
- func (x *SecurityGroup) String() string
- func (m *SecurityGroup) Validate() error
- type SecurityGroupValidationError
- func (e SecurityGroupValidationError) Cause() error
- func (e SecurityGroupValidationError) Error() string
- func (e SecurityGroupValidationError) ErrorName() string
- func (e SecurityGroupValidationError) Field() string
- func (e SecurityGroupValidationError) Key() bool
- func (e SecurityGroupValidationError) Reason() string
- type SourceType
- type UnimplementedManagerServer
- func (UnimplementedManagerServer) AddCDNToCDNCluster(context.Context, *AddCDNToCDNClusterRequest) (*emptypb.Empty, error)
- func (UnimplementedManagerServer) AddSchedulerClusterToSchedulerCluster(context.Context, *AddSchedulerClusterToSchedulerClusterRequest) (*emptypb.Empty, error)
- func (UnimplementedManagerServer) GetCDN(context.Context, *GetCDNRequest) (*CDN, error)
- func (UnimplementedManagerServer) GetScheduler(context.Context, *GetSchedulerRequest) (*Scheduler, error)
- func (UnimplementedManagerServer) KeepAlive(Manager_KeepAliveServer) error
- func (UnimplementedManagerServer) ListSchedulers(context.Context, *ListSchedulersRequest) (*ListSchedulersResponse, error)
- func (UnimplementedManagerServer) UpdateCDN(context.Context, *UpdateCDNRequest) (*CDN, error)
- func (UnimplementedManagerServer) UpdateScheduler(context.Context, *UpdateSchedulerRequest) (*Scheduler, error)
- type UnsafeManagerServer
- type UpdateCDNRequest
- func (*UpdateCDNRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateCDNRequest) GetDownloadPort() int32
- func (x *UpdateCDNRequest) GetHostName() string
- func (x *UpdateCDNRequest) GetIdc() string
- func (x *UpdateCDNRequest) GetIp() string
- func (x *UpdateCDNRequest) GetLocation() string
- func (x *UpdateCDNRequest) GetPort() int32
- func (x *UpdateCDNRequest) GetSourceType() SourceType
- func (*UpdateCDNRequest) ProtoMessage()
- func (x *UpdateCDNRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateCDNRequest) Reset()
- func (x *UpdateCDNRequest) String() string
- func (m *UpdateCDNRequest) Validate() error
- type UpdateCDNRequestValidationError
- func (e UpdateCDNRequestValidationError) Cause() error
- func (e UpdateCDNRequestValidationError) Error() string
- func (e UpdateCDNRequestValidationError) ErrorName() string
- func (e UpdateCDNRequestValidationError) Field() string
- func (e UpdateCDNRequestValidationError) Key() bool
- func (e UpdateCDNRequestValidationError) Reason() string
- type UpdateSchedulerRequest
- func (*UpdateSchedulerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSchedulerRequest) GetHostName() string
- func (x *UpdateSchedulerRequest) GetIdc() string
- func (x *UpdateSchedulerRequest) GetIp() string
- func (x *UpdateSchedulerRequest) GetLocation() string
- func (x *UpdateSchedulerRequest) GetNetConfig() []byte
- func (x *UpdateSchedulerRequest) GetPort() int32
- func (x *UpdateSchedulerRequest) GetSourceType() SourceType
- func (x *UpdateSchedulerRequest) GetVips() string
- func (*UpdateSchedulerRequest) ProtoMessage()
- func (x *UpdateSchedulerRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateSchedulerRequest) Reset()
- func (x *UpdateSchedulerRequest) String() string
- func (m *UpdateSchedulerRequest) Validate() error
- type UpdateSchedulerRequestValidationError
- func (e UpdateSchedulerRequestValidationError) Cause() error
- func (e UpdateSchedulerRequestValidationError) Error() string
- func (e UpdateSchedulerRequestValidationError) ErrorName() string
- func (e UpdateSchedulerRequestValidationError) Field() string
- func (e UpdateSchedulerRequestValidationError) Key() bool
- func (e UpdateSchedulerRequestValidationError) Reason() string
Constants ¶
This section is empty.
Variables ¶
var ( SourceType_name = map[int32]string{ 0: "SCHEDULER_SOURCE", 1: "CLIENT_SOURCE", 2: "CDN_SOURCE", } SourceType_value = map[string]int32{ "SCHEDULER_SOURCE": 0, "CLIENT_SOURCE": 1, "CDN_SOURCE": 2, } )
Enum value maps for SourceType.
var File_pkg_rpc_manager_manager_proto protoreflect.FileDescriptor
var Manager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "manager.Manager", HandlerType: (*ManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetCDN", Handler: _Manager_GetCDN_Handler, }, { MethodName: "UpdateCDN", Handler: _Manager_UpdateCDN_Handler, }, { MethodName: "AddCDNToCDNCluster", Handler: _Manager_AddCDNToCDNCluster_Handler, }, { MethodName: "GetScheduler", Handler: _Manager_GetScheduler_Handler, }, { MethodName: "UpdateScheduler", Handler: _Manager_UpdateScheduler_Handler, }, { MethodName: "AddSchedulerClusterToSchedulerCluster", Handler: _Manager_AddSchedulerClusterToSchedulerCluster_Handler, }, { MethodName: "ListSchedulers", Handler: _Manager_ListSchedulers_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "KeepAlive", Handler: _Manager_KeepAlive_Handler, ClientStreams: true, }, }, Metadata: "pkg/rpc/manager/manager.proto", }
Manager_ServiceDesc is the grpc.ServiceDesc for Manager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterManagerServer ¶
func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)
Types ¶
type AddCDNToCDNClusterRequest ¶
type AddCDNToCDNClusterRequest struct { SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"` CdnId uint64 `protobuf:"varint,2,opt,name=cdn_id,json=cdnId,proto3" json:"cdn_id,omitempty"` CdnClusterId uint64 `protobuf:"varint,3,opt,name=cdn_cluster_id,json=cdnClusterId,proto3" json:"cdn_cluster_id,omitempty"` // contains filtered or unexported fields }
func (*AddCDNToCDNClusterRequest) Descriptor
deprecated
func (*AddCDNToCDNClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddCDNToCDNClusterRequest.ProtoReflect.Descriptor instead.
func (*AddCDNToCDNClusterRequest) GetCdnClusterId ¶
func (x *AddCDNToCDNClusterRequest) GetCdnClusterId() uint64
func (*AddCDNToCDNClusterRequest) GetCdnId ¶
func (x *AddCDNToCDNClusterRequest) GetCdnId() uint64
func (*AddCDNToCDNClusterRequest) GetSourceType ¶
func (x *AddCDNToCDNClusterRequest) GetSourceType() SourceType
func (*AddCDNToCDNClusterRequest) ProtoMessage ¶
func (*AddCDNToCDNClusterRequest) ProtoMessage()
func (*AddCDNToCDNClusterRequest) ProtoReflect ¶
func (x *AddCDNToCDNClusterRequest) ProtoReflect() protoreflect.Message
func (*AddCDNToCDNClusterRequest) Reset ¶
func (x *AddCDNToCDNClusterRequest) Reset()
func (*AddCDNToCDNClusterRequest) String ¶
func (x *AddCDNToCDNClusterRequest) String() string
func (*AddCDNToCDNClusterRequest) Validate ¶
func (m *AddCDNToCDNClusterRequest) Validate() error
Validate checks the field values on AddCDNToCDNClusterRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type AddCDNToCDNClusterRequestValidationError ¶
type AddCDNToCDNClusterRequestValidationError struct {
// contains filtered or unexported fields
}
AddCDNToCDNClusterRequestValidationError is the validation error returned by AddCDNToCDNClusterRequest.Validate if the designated constraints aren't met.
func (AddCDNToCDNClusterRequestValidationError) Cause ¶
func (e AddCDNToCDNClusterRequestValidationError) Cause() error
Cause function returns cause value.
func (AddCDNToCDNClusterRequestValidationError) Error ¶
func (e AddCDNToCDNClusterRequestValidationError) Error() string
Error satisfies the builtin error interface
func (AddCDNToCDNClusterRequestValidationError) ErrorName ¶
func (e AddCDNToCDNClusterRequestValidationError) ErrorName() string
ErrorName returns error name.
func (AddCDNToCDNClusterRequestValidationError) Field ¶
func (e AddCDNToCDNClusterRequestValidationError) Field() string
Field function returns field value.
func (AddCDNToCDNClusterRequestValidationError) Key ¶
func (e AddCDNToCDNClusterRequestValidationError) Key() bool
Key function returns key value.
func (AddCDNToCDNClusterRequestValidationError) Reason ¶
func (e AddCDNToCDNClusterRequestValidationError) Reason() string
Reason function returns reason value.
type AddSchedulerClusterToSchedulerClusterRequest ¶
type AddSchedulerClusterToSchedulerClusterRequest struct { SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"` SchedulerId uint64 `protobuf:"varint,2,opt,name=scheduler_id,json=schedulerId,proto3" json:"scheduler_id,omitempty"` SchedulerClusterId uint64 `protobuf:"varint,3,opt,name=scheduler_cluster_id,json=schedulerClusterId,proto3" json:"scheduler_cluster_id,omitempty"` // contains filtered or unexported fields }
func (*AddSchedulerClusterToSchedulerClusterRequest) Descriptor
deprecated
func (*AddSchedulerClusterToSchedulerClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddSchedulerClusterToSchedulerClusterRequest.ProtoReflect.Descriptor instead.
func (*AddSchedulerClusterToSchedulerClusterRequest) GetSchedulerClusterId ¶
func (x *AddSchedulerClusterToSchedulerClusterRequest) GetSchedulerClusterId() uint64
func (*AddSchedulerClusterToSchedulerClusterRequest) GetSchedulerId ¶
func (x *AddSchedulerClusterToSchedulerClusterRequest) GetSchedulerId() uint64
func (*AddSchedulerClusterToSchedulerClusterRequest) GetSourceType ¶
func (x *AddSchedulerClusterToSchedulerClusterRequest) GetSourceType() SourceType
func (*AddSchedulerClusterToSchedulerClusterRequest) ProtoMessage ¶
func (*AddSchedulerClusterToSchedulerClusterRequest) ProtoMessage()
func (*AddSchedulerClusterToSchedulerClusterRequest) ProtoReflect ¶
func (x *AddSchedulerClusterToSchedulerClusterRequest) ProtoReflect() protoreflect.Message
func (*AddSchedulerClusterToSchedulerClusterRequest) Reset ¶
func (x *AddSchedulerClusterToSchedulerClusterRequest) Reset()
func (*AddSchedulerClusterToSchedulerClusterRequest) String ¶
func (x *AddSchedulerClusterToSchedulerClusterRequest) String() string
func (*AddSchedulerClusterToSchedulerClusterRequest) Validate ¶
func (m *AddSchedulerClusterToSchedulerClusterRequest) Validate() error
Validate checks the field values on AddSchedulerClusterToSchedulerClusterRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type AddSchedulerClusterToSchedulerClusterRequestValidationError ¶
type AddSchedulerClusterToSchedulerClusterRequestValidationError struct {
// contains filtered or unexported fields
}
AddSchedulerClusterToSchedulerClusterRequestValidationError is the validation error returned by AddSchedulerClusterToSchedulerClusterRequest.Validate if the designated constraints aren't met.
func (AddSchedulerClusterToSchedulerClusterRequestValidationError) Cause ¶
func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Cause() error
Cause function returns cause value.
func (AddSchedulerClusterToSchedulerClusterRequestValidationError) Error ¶
func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Error() string
Error satisfies the builtin error interface
func (AddSchedulerClusterToSchedulerClusterRequestValidationError) ErrorName ¶
func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) ErrorName() string
ErrorName returns error name.
func (AddSchedulerClusterToSchedulerClusterRequestValidationError) Field ¶
func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Field() string
Field function returns field value.
func (AddSchedulerClusterToSchedulerClusterRequestValidationError) Key ¶
func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Key() bool
Key function returns key value.
func (AddSchedulerClusterToSchedulerClusterRequestValidationError) Reason ¶
func (e AddSchedulerClusterToSchedulerClusterRequestValidationError) Reason() string
Reason function returns reason value.
type CDN ¶
type CDN struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` Idc string `protobuf:"bytes,3,opt,name=idc,proto3" json:"idc,omitempty"` Location string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"` Ip string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"` Port int32 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"` DownloadPort int32 `protobuf:"varint,7,opt,name=download_port,json=downloadPort,proto3" json:"download_port,omitempty"` Status string `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"` CdnCluster *CDNCluster `protobuf:"bytes,10,opt,name=cdn_cluster,json=cdnCluster,proto3" json:"cdn_cluster,omitempty"` // contains filtered or unexported fields }
func (*CDN) Descriptor
deprecated
func (*CDN) GetCdnCluster ¶
func (x *CDN) GetCdnCluster() *CDNCluster
func (*CDN) GetDownloadPort ¶
func (*CDN) GetHostName ¶
func (*CDN) GetLocation ¶
func (*CDN) ProtoMessage ¶
func (*CDN) ProtoMessage()
func (*CDN) ProtoReflect ¶
func (x *CDN) ProtoReflect() protoreflect.Message
type CDNCluster ¶
type CDNCluster struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Bio string `protobuf:"bytes,3,opt,name=bio,proto3" json:"bio,omitempty"` Config []byte `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` SecurityGroup *SecurityGroup `protobuf:"bytes,6,opt,name=security_group,json=securityGroup,proto3" json:"security_group,omitempty"` // contains filtered or unexported fields }
func (*CDNCluster) Descriptor
deprecated
func (*CDNCluster) Descriptor() ([]byte, []int)
Deprecated: Use CDNCluster.ProtoReflect.Descriptor instead.
func (*CDNCluster) GetBio ¶
func (x *CDNCluster) GetBio() string
func (*CDNCluster) GetConfig ¶
func (x *CDNCluster) GetConfig() []byte
func (*CDNCluster) GetId ¶
func (x *CDNCluster) GetId() uint64
func (*CDNCluster) GetName ¶
func (x *CDNCluster) GetName() string
func (*CDNCluster) GetSecurityGroup ¶
func (x *CDNCluster) GetSecurityGroup() *SecurityGroup
func (*CDNCluster) ProtoMessage ¶
func (*CDNCluster) ProtoMessage()
func (*CDNCluster) ProtoReflect ¶
func (x *CDNCluster) ProtoReflect() protoreflect.Message
func (*CDNCluster) Reset ¶
func (x *CDNCluster) Reset()
func (*CDNCluster) String ¶
func (x *CDNCluster) String() string
func (*CDNCluster) Validate ¶
func (m *CDNCluster) Validate() error
Validate checks the field values on CDNCluster with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type CDNClusterValidationError ¶
type CDNClusterValidationError struct {
// contains filtered or unexported fields
}
CDNClusterValidationError is the validation error returned by CDNCluster.Validate if the designated constraints aren't met.
func (CDNClusterValidationError) Cause ¶
func (e CDNClusterValidationError) Cause() error
Cause function returns cause value.
func (CDNClusterValidationError) Error ¶
func (e CDNClusterValidationError) Error() string
Error satisfies the builtin error interface
func (CDNClusterValidationError) ErrorName ¶
func (e CDNClusterValidationError) ErrorName() string
ErrorName returns error name.
func (CDNClusterValidationError) Field ¶
func (e CDNClusterValidationError) Field() string
Field function returns field value.
func (CDNClusterValidationError) Key ¶
func (e CDNClusterValidationError) Key() bool
Key function returns key value.
func (CDNClusterValidationError) Reason ¶
func (e CDNClusterValidationError) Reason() string
Reason function returns reason value.
type CDNValidationError ¶
type CDNValidationError struct {
// contains filtered or unexported fields
}
CDNValidationError is the validation error returned by CDN.Validate if the designated constraints aren't met.
func (CDNValidationError) Cause ¶
func (e CDNValidationError) Cause() error
Cause function returns cause value.
func (CDNValidationError) Error ¶
func (e CDNValidationError) Error() string
Error satisfies the builtin error interface
func (CDNValidationError) ErrorName ¶
func (e CDNValidationError) ErrorName() string
ErrorName returns error name.
func (CDNValidationError) Field ¶
func (e CDNValidationError) Field() string
Field function returns field value.
func (CDNValidationError) Key ¶
func (e CDNValidationError) Key() bool
Key function returns key value.
func (CDNValidationError) Reason ¶
func (e CDNValidationError) Reason() string
Reason function returns reason value.
type GetCDNRequest ¶
type GetCDNRequest struct { SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"` HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` // contains filtered or unexported fields }
func (*GetCDNRequest) Descriptor
deprecated
func (*GetCDNRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCDNRequest.ProtoReflect.Descriptor instead.
func (*GetCDNRequest) GetHostName ¶
func (x *GetCDNRequest) GetHostName() string
func (*GetCDNRequest) GetSourceType ¶
func (x *GetCDNRequest) GetSourceType() SourceType
func (*GetCDNRequest) ProtoMessage ¶
func (*GetCDNRequest) ProtoMessage()
func (*GetCDNRequest) ProtoReflect ¶
func (x *GetCDNRequest) ProtoReflect() protoreflect.Message
func (*GetCDNRequest) Reset ¶
func (x *GetCDNRequest) Reset()
func (*GetCDNRequest) String ¶
func (x *GetCDNRequest) String() string
func (*GetCDNRequest) Validate ¶
func (m *GetCDNRequest) Validate() error
Validate checks the field values on GetCDNRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type GetCDNRequestValidationError ¶
type GetCDNRequestValidationError struct {
// contains filtered or unexported fields
}
GetCDNRequestValidationError is the validation error returned by GetCDNRequest.Validate if the designated constraints aren't met.
func (GetCDNRequestValidationError) Cause ¶
func (e GetCDNRequestValidationError) Cause() error
Cause function returns cause value.
func (GetCDNRequestValidationError) Error ¶
func (e GetCDNRequestValidationError) Error() string
Error satisfies the builtin error interface
func (GetCDNRequestValidationError) ErrorName ¶
func (e GetCDNRequestValidationError) ErrorName() string
ErrorName returns error name.
func (GetCDNRequestValidationError) Field ¶
func (e GetCDNRequestValidationError) Field() string
Field function returns field value.
func (GetCDNRequestValidationError) Key ¶
func (e GetCDNRequestValidationError) Key() bool
Key function returns key value.
func (GetCDNRequestValidationError) Reason ¶
func (e GetCDNRequestValidationError) Reason() string
Reason function returns reason value.
type GetSchedulerRequest ¶
type GetSchedulerRequest struct { SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"` HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` // contains filtered or unexported fields }
func (*GetSchedulerRequest) Descriptor
deprecated
func (*GetSchedulerRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchedulerRequest.ProtoReflect.Descriptor instead.
func (*GetSchedulerRequest) GetHostName ¶
func (x *GetSchedulerRequest) GetHostName() string
func (*GetSchedulerRequest) GetSourceType ¶
func (x *GetSchedulerRequest) GetSourceType() SourceType
func (*GetSchedulerRequest) ProtoMessage ¶
func (*GetSchedulerRequest) ProtoMessage()
func (*GetSchedulerRequest) ProtoReflect ¶
func (x *GetSchedulerRequest) ProtoReflect() protoreflect.Message
func (*GetSchedulerRequest) Reset ¶
func (x *GetSchedulerRequest) Reset()
func (*GetSchedulerRequest) String ¶
func (x *GetSchedulerRequest) String() string
func (*GetSchedulerRequest) Validate ¶
func (m *GetSchedulerRequest) Validate() error
Validate checks the field values on GetSchedulerRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type GetSchedulerRequestValidationError ¶
type GetSchedulerRequestValidationError struct {
// contains filtered or unexported fields
}
GetSchedulerRequestValidationError is the validation error returned by GetSchedulerRequest.Validate if the designated constraints aren't met.
func (GetSchedulerRequestValidationError) Cause ¶
func (e GetSchedulerRequestValidationError) Cause() error
Cause function returns cause value.
func (GetSchedulerRequestValidationError) Error ¶
func (e GetSchedulerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (GetSchedulerRequestValidationError) ErrorName ¶
func (e GetSchedulerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (GetSchedulerRequestValidationError) Field ¶
func (e GetSchedulerRequestValidationError) Field() string
Field function returns field value.
func (GetSchedulerRequestValidationError) Key ¶
func (e GetSchedulerRequestValidationError) Key() bool
Key function returns key value.
func (GetSchedulerRequestValidationError) Reason ¶
func (e GetSchedulerRequestValidationError) Reason() string
Reason function returns reason value.
type KeepAliveRequest ¶
type KeepAliveRequest struct { SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"` HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` // contains filtered or unexported fields }
func (*KeepAliveRequest) Descriptor
deprecated
func (*KeepAliveRequest) Descriptor() ([]byte, []int)
Deprecated: Use KeepAliveRequest.ProtoReflect.Descriptor instead.
func (*KeepAliveRequest) GetHostName ¶
func (x *KeepAliveRequest) GetHostName() string
func (*KeepAliveRequest) GetSourceType ¶
func (x *KeepAliveRequest) GetSourceType() SourceType
func (*KeepAliveRequest) ProtoMessage ¶
func (*KeepAliveRequest) ProtoMessage()
func (*KeepAliveRequest) ProtoReflect ¶
func (x *KeepAliveRequest) ProtoReflect() protoreflect.Message
func (*KeepAliveRequest) Reset ¶
func (x *KeepAliveRequest) Reset()
func (*KeepAliveRequest) String ¶
func (x *KeepAliveRequest) String() string
func (*KeepAliveRequest) Validate ¶
func (m *KeepAliveRequest) Validate() error
Validate checks the field values on KeepAliveRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type KeepAliveRequestValidationError ¶
type KeepAliveRequestValidationError struct {
// contains filtered or unexported fields
}
KeepAliveRequestValidationError is the validation error returned by KeepAliveRequest.Validate if the designated constraints aren't met.
func (KeepAliveRequestValidationError) Cause ¶
func (e KeepAliveRequestValidationError) Cause() error
Cause function returns cause value.
func (KeepAliveRequestValidationError) Error ¶
func (e KeepAliveRequestValidationError) Error() string
Error satisfies the builtin error interface
func (KeepAliveRequestValidationError) ErrorName ¶
func (e KeepAliveRequestValidationError) ErrorName() string
ErrorName returns error name.
func (KeepAliveRequestValidationError) Field ¶
func (e KeepAliveRequestValidationError) Field() string
Field function returns field value.
func (KeepAliveRequestValidationError) Key ¶
func (e KeepAliveRequestValidationError) Key() bool
Key function returns key value.
func (KeepAliveRequestValidationError) Reason ¶
func (e KeepAliveRequestValidationError) Reason() string
Reason function returns reason value.
type ListSchedulersRequest ¶
type ListSchedulersRequest struct { SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"` HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"` HostInfo map[string]string `` /* 173-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ListSchedulersRequest) Descriptor
deprecated
func (*ListSchedulersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSchedulersRequest.ProtoReflect.Descriptor instead.
func (*ListSchedulersRequest) GetHostInfo ¶
func (x *ListSchedulersRequest) GetHostInfo() map[string]string
func (*ListSchedulersRequest) GetHostName ¶
func (x *ListSchedulersRequest) GetHostName() string
func (*ListSchedulersRequest) GetIp ¶
func (x *ListSchedulersRequest) GetIp() string
func (*ListSchedulersRequest) GetSourceType ¶
func (x *ListSchedulersRequest) GetSourceType() SourceType
func (*ListSchedulersRequest) ProtoMessage ¶
func (*ListSchedulersRequest) ProtoMessage()
func (*ListSchedulersRequest) ProtoReflect ¶
func (x *ListSchedulersRequest) ProtoReflect() protoreflect.Message
func (*ListSchedulersRequest) Reset ¶
func (x *ListSchedulersRequest) Reset()
func (*ListSchedulersRequest) String ¶
func (x *ListSchedulersRequest) String() string
func (*ListSchedulersRequest) Validate ¶
func (m *ListSchedulersRequest) Validate() error
Validate checks the field values on ListSchedulersRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type ListSchedulersRequestValidationError ¶
type ListSchedulersRequestValidationError struct {
// contains filtered or unexported fields
}
ListSchedulersRequestValidationError is the validation error returned by ListSchedulersRequest.Validate if the designated constraints aren't met.
func (ListSchedulersRequestValidationError) Cause ¶
func (e ListSchedulersRequestValidationError) Cause() error
Cause function returns cause value.
func (ListSchedulersRequestValidationError) Error ¶
func (e ListSchedulersRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ListSchedulersRequestValidationError) ErrorName ¶
func (e ListSchedulersRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ListSchedulersRequestValidationError) Field ¶
func (e ListSchedulersRequestValidationError) Field() string
Field function returns field value.
func (ListSchedulersRequestValidationError) Key ¶
func (e ListSchedulersRequestValidationError) Key() bool
Key function returns key value.
func (ListSchedulersRequestValidationError) Reason ¶
func (e ListSchedulersRequestValidationError) Reason() string
Reason function returns reason value.
type ListSchedulersResponse ¶
type ListSchedulersResponse struct { Schedulers []*Scheduler `protobuf:"bytes,1,rep,name=schedulers,proto3" json:"schedulers,omitempty"` // contains filtered or unexported fields }
func (*ListSchedulersResponse) Descriptor
deprecated
func (*ListSchedulersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSchedulersResponse.ProtoReflect.Descriptor instead.
func (*ListSchedulersResponse) GetSchedulers ¶
func (x *ListSchedulersResponse) GetSchedulers() []*Scheduler
func (*ListSchedulersResponse) ProtoMessage ¶
func (*ListSchedulersResponse) ProtoMessage()
func (*ListSchedulersResponse) ProtoReflect ¶
func (x *ListSchedulersResponse) ProtoReflect() protoreflect.Message
func (*ListSchedulersResponse) Reset ¶
func (x *ListSchedulersResponse) Reset()
func (*ListSchedulersResponse) String ¶
func (x *ListSchedulersResponse) String() string
func (*ListSchedulersResponse) Validate ¶
func (m *ListSchedulersResponse) Validate() error
Validate checks the field values on ListSchedulersResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type ListSchedulersResponseValidationError ¶
type ListSchedulersResponseValidationError struct {
// contains filtered or unexported fields
}
ListSchedulersResponseValidationError is the validation error returned by ListSchedulersResponse.Validate if the designated constraints aren't met.
func (ListSchedulersResponseValidationError) Cause ¶
func (e ListSchedulersResponseValidationError) Cause() error
Cause function returns cause value.
func (ListSchedulersResponseValidationError) Error ¶
func (e ListSchedulersResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ListSchedulersResponseValidationError) ErrorName ¶
func (e ListSchedulersResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ListSchedulersResponseValidationError) Field ¶
func (e ListSchedulersResponseValidationError) Field() string
Field function returns field value.
func (ListSchedulersResponseValidationError) Key ¶
func (e ListSchedulersResponseValidationError) Key() bool
Key function returns key value.
func (ListSchedulersResponseValidationError) Reason ¶
func (e ListSchedulersResponseValidationError) Reason() string
Reason function returns reason value.
type ManagerClient ¶
type ManagerClient interface { // Get CDN and CDN cluster configuration GetCDN(ctx context.Context, in *GetCDNRequest, opts ...grpc.CallOption) (*CDN, error) // Update CDN configuration UpdateCDN(ctx context.Context, in *UpdateCDNRequest, opts ...grpc.CallOption) (*CDN, error) // AddCDNToCDNCluster add cdn to cdn cluster AddCDNToCDNCluster(ctx context.Context, in *AddCDNToCDNClusterRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get Scheduler and Scheduler cluster configuration GetScheduler(ctx context.Context, in *GetSchedulerRequest, opts ...grpc.CallOption) (*Scheduler, error) // Update scheduler configuration UpdateScheduler(ctx context.Context, in *UpdateSchedulerRequest, opts ...grpc.CallOption) (*Scheduler, error) // AddSchedulerClusterToSchedulerCluster add scheduler to scheduler cluster AddSchedulerClusterToSchedulerCluster(ctx context.Context, in *AddSchedulerClusterToSchedulerClusterRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // List acitve schedulers configuration ListSchedulers(ctx context.Context, in *ListSchedulersRequest, opts ...grpc.CallOption) (*ListSchedulersResponse, error) // KeepAlive with manager KeepAlive(ctx context.Context, opts ...grpc.CallOption) (Manager_KeepAliveClient, error) }
ManagerClient is the client API for Manager 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 NewManagerClient ¶
func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient
type ManagerServer ¶
type ManagerServer interface { // Get CDN and CDN cluster configuration GetCDN(context.Context, *GetCDNRequest) (*CDN, error) // Update CDN configuration UpdateCDN(context.Context, *UpdateCDNRequest) (*CDN, error) // AddCDNToCDNCluster add cdn to cdn cluster AddCDNToCDNCluster(context.Context, *AddCDNToCDNClusterRequest) (*emptypb.Empty, error) // Get Scheduler and Scheduler cluster configuration GetScheduler(context.Context, *GetSchedulerRequest) (*Scheduler, error) // Update scheduler configuration UpdateScheduler(context.Context, *UpdateSchedulerRequest) (*Scheduler, error) // AddSchedulerClusterToSchedulerCluster add scheduler to scheduler cluster AddSchedulerClusterToSchedulerCluster(context.Context, *AddSchedulerClusterToSchedulerClusterRequest) (*emptypb.Empty, error) // List acitve schedulers configuration ListSchedulers(context.Context, *ListSchedulersRequest) (*ListSchedulersResponse, error) // KeepAlive with manager KeepAlive(Manager_KeepAliveServer) error // contains filtered or unexported methods }
ManagerServer is the server API for Manager service. All implementations must embed UnimplementedManagerServer for forward compatibility
type Manager_KeepAliveClient ¶
type Manager_KeepAliveClient interface { Send(*KeepAliveRequest) error CloseAndRecv() (*emptypb.Empty, error) grpc.ClientStream }
type Manager_KeepAliveServer ¶
type Manager_KeepAliveServer interface { SendAndClose(*emptypb.Empty) error Recv() (*KeepAliveRequest, error) grpc.ServerStream }
type Scheduler ¶
type Scheduler struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` Vips string `protobuf:"bytes,3,opt,name=vips,proto3" json:"vips,omitempty"` Idc string `protobuf:"bytes,4,opt,name=idc,proto3" json:"idc,omitempty"` Location string `protobuf:"bytes,5,opt,name=location,proto3" json:"location,omitempty"` NetConfig []byte `protobuf:"bytes,6,opt,name=net_config,json=netConfig,proto3" json:"net_config,omitempty"` Ip string `protobuf:"bytes,7,opt,name=ip,proto3" json:"ip,omitempty"` Port int32 `protobuf:"varint,8,opt,name=port,proto3" json:"port,omitempty"` Status string `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"` SchedulerCluster *SchedulerCluster `protobuf:"bytes,11,opt,name=scheduler_cluster,json=schedulerCluster,proto3" json:"scheduler_cluster,omitempty"` Cdns []*CDN `protobuf:"bytes,12,rep,name=cdns,proto3" json:"cdns,omitempty"` // contains filtered or unexported fields }
func (*Scheduler) Descriptor
deprecated
func (*Scheduler) GetHostName ¶
func (*Scheduler) GetLocation ¶
func (*Scheduler) GetNetConfig ¶
func (*Scheduler) GetSchedulerCluster ¶
func (x *Scheduler) GetSchedulerCluster() *SchedulerCluster
func (*Scheduler) ProtoMessage ¶
func (*Scheduler) ProtoMessage()
func (*Scheduler) ProtoReflect ¶
func (x *Scheduler) ProtoReflect() protoreflect.Message
type SchedulerCluster ¶
type SchedulerCluster struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Bio string `protobuf:"bytes,3,opt,name=bio,proto3" json:"bio,omitempty"` Config []byte `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` ClientConfig []byte `protobuf:"bytes,5,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"` SecurityGroup *SecurityGroup `protobuf:"bytes,7,opt,name=security_group,json=securityGroup,proto3" json:"security_group,omitempty"` // contains filtered or unexported fields }
func (*SchedulerCluster) Descriptor
deprecated
func (*SchedulerCluster) Descriptor() ([]byte, []int)
Deprecated: Use SchedulerCluster.ProtoReflect.Descriptor instead.
func (*SchedulerCluster) GetBio ¶
func (x *SchedulerCluster) GetBio() string
func (*SchedulerCluster) GetClientConfig ¶
func (x *SchedulerCluster) GetClientConfig() []byte
func (*SchedulerCluster) GetConfig ¶
func (x *SchedulerCluster) GetConfig() []byte
func (*SchedulerCluster) GetId ¶
func (x *SchedulerCluster) GetId() uint64
func (*SchedulerCluster) GetName ¶
func (x *SchedulerCluster) GetName() string
func (*SchedulerCluster) GetSecurityGroup ¶
func (x *SchedulerCluster) GetSecurityGroup() *SecurityGroup
func (*SchedulerCluster) ProtoMessage ¶
func (*SchedulerCluster) ProtoMessage()
func (*SchedulerCluster) ProtoReflect ¶
func (x *SchedulerCluster) ProtoReflect() protoreflect.Message
func (*SchedulerCluster) Reset ¶
func (x *SchedulerCluster) Reset()
func (*SchedulerCluster) String ¶
func (x *SchedulerCluster) String() string
func (*SchedulerCluster) Validate ¶
func (m *SchedulerCluster) Validate() error
Validate checks the field values on SchedulerCluster with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type SchedulerClusterValidationError ¶
type SchedulerClusterValidationError struct {
// contains filtered or unexported fields
}
SchedulerClusterValidationError is the validation error returned by SchedulerCluster.Validate if the designated constraints aren't met.
func (SchedulerClusterValidationError) Cause ¶
func (e SchedulerClusterValidationError) Cause() error
Cause function returns cause value.
func (SchedulerClusterValidationError) Error ¶
func (e SchedulerClusterValidationError) Error() string
Error satisfies the builtin error interface
func (SchedulerClusterValidationError) ErrorName ¶
func (e SchedulerClusterValidationError) ErrorName() string
ErrorName returns error name.
func (SchedulerClusterValidationError) Field ¶
func (e SchedulerClusterValidationError) Field() string
Field function returns field value.
func (SchedulerClusterValidationError) Key ¶
func (e SchedulerClusterValidationError) Key() bool
Key function returns key value.
func (SchedulerClusterValidationError) Reason ¶
func (e SchedulerClusterValidationError) Reason() string
Reason function returns reason value.
type SchedulerValidationError ¶
type SchedulerValidationError struct {
// contains filtered or unexported fields
}
SchedulerValidationError is the validation error returned by Scheduler.Validate if the designated constraints aren't met.
func (SchedulerValidationError) Cause ¶
func (e SchedulerValidationError) Cause() error
Cause function returns cause value.
func (SchedulerValidationError) Error ¶
func (e SchedulerValidationError) Error() string
Error satisfies the builtin error interface
func (SchedulerValidationError) ErrorName ¶
func (e SchedulerValidationError) ErrorName() string
ErrorName returns error name.
func (SchedulerValidationError) Field ¶
func (e SchedulerValidationError) Field() string
Field function returns field value.
func (SchedulerValidationError) Key ¶
func (e SchedulerValidationError) Key() bool
Key function returns key value.
func (SchedulerValidationError) Reason ¶
func (e SchedulerValidationError) Reason() string
Reason function returns reason value.
type SecurityGroup ¶
type SecurityGroup struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Bio string `protobuf:"bytes,3,opt,name=bio,proto3" json:"bio,omitempty"` Domain string `protobuf:"bytes,4,opt,name=domain,proto3" json:"domain,omitempty"` ProxyDomain string `protobuf:"bytes,5,opt,name=proxy_domain,json=proxyDomain,proto3" json:"proxy_domain,omitempty"` // contains filtered or unexported fields }
func (*SecurityGroup) Descriptor
deprecated
func (*SecurityGroup) Descriptor() ([]byte, []int)
Deprecated: Use SecurityGroup.ProtoReflect.Descriptor instead.
func (*SecurityGroup) GetBio ¶
func (x *SecurityGroup) GetBio() string
func (*SecurityGroup) GetDomain ¶
func (x *SecurityGroup) GetDomain() string
func (*SecurityGroup) GetId ¶
func (x *SecurityGroup) GetId() uint64
func (*SecurityGroup) GetName ¶
func (x *SecurityGroup) GetName() string
func (*SecurityGroup) GetProxyDomain ¶
func (x *SecurityGroup) GetProxyDomain() string
func (*SecurityGroup) ProtoMessage ¶
func (*SecurityGroup) ProtoMessage()
func (*SecurityGroup) ProtoReflect ¶
func (x *SecurityGroup) ProtoReflect() protoreflect.Message
func (*SecurityGroup) Reset ¶
func (x *SecurityGroup) Reset()
func (*SecurityGroup) String ¶
func (x *SecurityGroup) String() string
func (*SecurityGroup) Validate ¶
func (m *SecurityGroup) Validate() error
Validate checks the field values on SecurityGroup with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type SecurityGroupValidationError ¶
type SecurityGroupValidationError struct {
// contains filtered or unexported fields
}
SecurityGroupValidationError is the validation error returned by SecurityGroup.Validate if the designated constraints aren't met.
func (SecurityGroupValidationError) Cause ¶
func (e SecurityGroupValidationError) Cause() error
Cause function returns cause value.
func (SecurityGroupValidationError) Error ¶
func (e SecurityGroupValidationError) Error() string
Error satisfies the builtin error interface
func (SecurityGroupValidationError) ErrorName ¶
func (e SecurityGroupValidationError) ErrorName() string
ErrorName returns error name.
func (SecurityGroupValidationError) Field ¶
func (e SecurityGroupValidationError) Field() string
Field function returns field value.
func (SecurityGroupValidationError) Key ¶
func (e SecurityGroupValidationError) Key() bool
Key function returns key value.
func (SecurityGroupValidationError) Reason ¶
func (e SecurityGroupValidationError) Reason() string
Reason function returns reason value.
type SourceType ¶
type SourceType int32
const ( SourceType_SCHEDULER_SOURCE SourceType = 0 SourceType_CLIENT_SOURCE SourceType = 1 SourceType_CDN_SOURCE SourceType = 2 )
func (SourceType) Descriptor ¶
func (SourceType) Descriptor() protoreflect.EnumDescriptor
func (SourceType) Enum ¶
func (x SourceType) Enum() *SourceType
func (SourceType) EnumDescriptor
deprecated
func (SourceType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SourceType.Descriptor instead.
func (SourceType) Number ¶
func (x SourceType) Number() protoreflect.EnumNumber
func (SourceType) String ¶
func (x SourceType) String() string
func (SourceType) Type ¶
func (SourceType) Type() protoreflect.EnumType
type UnimplementedManagerServer ¶
type UnimplementedManagerServer struct { }
UnimplementedManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedManagerServer) AddCDNToCDNCluster ¶
func (UnimplementedManagerServer) AddCDNToCDNCluster(context.Context, *AddCDNToCDNClusterRequest) (*emptypb.Empty, error)
func (UnimplementedManagerServer) AddSchedulerClusterToSchedulerCluster ¶
func (UnimplementedManagerServer) AddSchedulerClusterToSchedulerCluster(context.Context, *AddSchedulerClusterToSchedulerClusterRequest) (*emptypb.Empty, error)
func (UnimplementedManagerServer) GetCDN ¶
func (UnimplementedManagerServer) GetCDN(context.Context, *GetCDNRequest) (*CDN, error)
func (UnimplementedManagerServer) GetScheduler ¶
func (UnimplementedManagerServer) GetScheduler(context.Context, *GetSchedulerRequest) (*Scheduler, error)
func (UnimplementedManagerServer) KeepAlive ¶
func (UnimplementedManagerServer) KeepAlive(Manager_KeepAliveServer) error
func (UnimplementedManagerServer) ListSchedulers ¶
func (UnimplementedManagerServer) ListSchedulers(context.Context, *ListSchedulersRequest) (*ListSchedulersResponse, error)
func (UnimplementedManagerServer) UpdateCDN ¶
func (UnimplementedManagerServer) UpdateCDN(context.Context, *UpdateCDNRequest) (*CDN, error)
func (UnimplementedManagerServer) UpdateScheduler ¶
func (UnimplementedManagerServer) UpdateScheduler(context.Context, *UpdateSchedulerRequest) (*Scheduler, error)
type UnsafeManagerServer ¶
type UnsafeManagerServer interface {
// contains filtered or unexported methods
}
UnsafeManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagerServer will result in compilation errors.
type UpdateCDNRequest ¶
type UpdateCDNRequest struct { SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"` HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` Idc string `protobuf:"bytes,3,opt,name=idc,proto3" json:"idc,omitempty"` Location string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"` Ip string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"` Port int32 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"` DownloadPort int32 `protobuf:"varint,7,opt,name=download_port,json=downloadPort,proto3" json:"download_port,omitempty"` // contains filtered or unexported fields }
func (*UpdateCDNRequest) Descriptor
deprecated
func (*UpdateCDNRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateCDNRequest.ProtoReflect.Descriptor instead.
func (*UpdateCDNRequest) GetDownloadPort ¶
func (x *UpdateCDNRequest) GetDownloadPort() int32
func (*UpdateCDNRequest) GetHostName ¶
func (x *UpdateCDNRequest) GetHostName() string
func (*UpdateCDNRequest) GetIdc ¶
func (x *UpdateCDNRequest) GetIdc() string
func (*UpdateCDNRequest) GetIp ¶
func (x *UpdateCDNRequest) GetIp() string
func (*UpdateCDNRequest) GetLocation ¶
func (x *UpdateCDNRequest) GetLocation() string
func (*UpdateCDNRequest) GetPort ¶
func (x *UpdateCDNRequest) GetPort() int32
func (*UpdateCDNRequest) GetSourceType ¶
func (x *UpdateCDNRequest) GetSourceType() SourceType
func (*UpdateCDNRequest) ProtoMessage ¶
func (*UpdateCDNRequest) ProtoMessage()
func (*UpdateCDNRequest) ProtoReflect ¶
func (x *UpdateCDNRequest) ProtoReflect() protoreflect.Message
func (*UpdateCDNRequest) Reset ¶
func (x *UpdateCDNRequest) Reset()
func (*UpdateCDNRequest) String ¶
func (x *UpdateCDNRequest) String() string
func (*UpdateCDNRequest) Validate ¶
func (m *UpdateCDNRequest) Validate() error
Validate checks the field values on UpdateCDNRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type UpdateCDNRequestValidationError ¶
type UpdateCDNRequestValidationError struct {
// contains filtered or unexported fields
}
UpdateCDNRequestValidationError is the validation error returned by UpdateCDNRequest.Validate if the designated constraints aren't met.
func (UpdateCDNRequestValidationError) Cause ¶
func (e UpdateCDNRequestValidationError) Cause() error
Cause function returns cause value.
func (UpdateCDNRequestValidationError) Error ¶
func (e UpdateCDNRequestValidationError) Error() string
Error satisfies the builtin error interface
func (UpdateCDNRequestValidationError) ErrorName ¶
func (e UpdateCDNRequestValidationError) ErrorName() string
ErrorName returns error name.
func (UpdateCDNRequestValidationError) Field ¶
func (e UpdateCDNRequestValidationError) Field() string
Field function returns field value.
func (UpdateCDNRequestValidationError) Key ¶
func (e UpdateCDNRequestValidationError) Key() bool
Key function returns key value.
func (UpdateCDNRequestValidationError) Reason ¶
func (e UpdateCDNRequestValidationError) Reason() string
Reason function returns reason value.
type UpdateSchedulerRequest ¶
type UpdateSchedulerRequest struct { SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"` HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` Vips string `protobuf:"bytes,4,opt,name=vips,proto3" json:"vips,omitempty"` Idc string `protobuf:"bytes,5,opt,name=idc,proto3" json:"idc,omitempty"` Location string `protobuf:"bytes,6,opt,name=location,proto3" json:"location,omitempty"` NetConfig []byte `protobuf:"bytes,7,opt,name=net_config,json=netConfig,proto3" json:"net_config,omitempty"` Ip string `protobuf:"bytes,8,opt,name=ip,proto3" json:"ip,omitempty"` Port int32 `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*UpdateSchedulerRequest) Descriptor
deprecated
func (*UpdateSchedulerRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSchedulerRequest.ProtoReflect.Descriptor instead.
func (*UpdateSchedulerRequest) GetHostName ¶
func (x *UpdateSchedulerRequest) GetHostName() string
func (*UpdateSchedulerRequest) GetIdc ¶
func (x *UpdateSchedulerRequest) GetIdc() string
func (*UpdateSchedulerRequest) GetIp ¶
func (x *UpdateSchedulerRequest) GetIp() string
func (*UpdateSchedulerRequest) GetLocation ¶
func (x *UpdateSchedulerRequest) GetLocation() string
func (*UpdateSchedulerRequest) GetNetConfig ¶
func (x *UpdateSchedulerRequest) GetNetConfig() []byte
func (*UpdateSchedulerRequest) GetPort ¶
func (x *UpdateSchedulerRequest) GetPort() int32
func (*UpdateSchedulerRequest) GetSourceType ¶
func (x *UpdateSchedulerRequest) GetSourceType() SourceType
func (*UpdateSchedulerRequest) GetVips ¶
func (x *UpdateSchedulerRequest) GetVips() string
func (*UpdateSchedulerRequest) ProtoMessage ¶
func (*UpdateSchedulerRequest) ProtoMessage()
func (*UpdateSchedulerRequest) ProtoReflect ¶
func (x *UpdateSchedulerRequest) ProtoReflect() protoreflect.Message
func (*UpdateSchedulerRequest) Reset ¶
func (x *UpdateSchedulerRequest) Reset()
func (*UpdateSchedulerRequest) String ¶
func (x *UpdateSchedulerRequest) String() string
func (*UpdateSchedulerRequest) Validate ¶
func (m *UpdateSchedulerRequest) Validate() error
Validate checks the field values on UpdateSchedulerRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type UpdateSchedulerRequestValidationError ¶
type UpdateSchedulerRequestValidationError struct {
// contains filtered or unexported fields
}
UpdateSchedulerRequestValidationError is the validation error returned by UpdateSchedulerRequest.Validate if the designated constraints aren't met.
func (UpdateSchedulerRequestValidationError) Cause ¶
func (e UpdateSchedulerRequestValidationError) Cause() error
Cause function returns cause value.
func (UpdateSchedulerRequestValidationError) Error ¶
func (e UpdateSchedulerRequestValidationError) Error() string
Error satisfies the builtin error interface
func (UpdateSchedulerRequestValidationError) ErrorName ¶
func (e UpdateSchedulerRequestValidationError) ErrorName() string
ErrorName returns error name.
func (UpdateSchedulerRequestValidationError) Field ¶
func (e UpdateSchedulerRequestValidationError) Field() string
Field function returns field value.
func (UpdateSchedulerRequestValidationError) Key ¶
func (e UpdateSchedulerRequestValidationError) Key() bool
Key function returns key value.
func (UpdateSchedulerRequestValidationError) Reason ¶
func (e UpdateSchedulerRequestValidationError) Reason() string
Reason function returns reason value.