manager

package
v2.0.1-alpha.4 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2021 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
var File_pkg_rpc_manager_manager_proto protoreflect.FileDescriptor

Functions

func RegisterManagerServer 

func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)

Types

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"`
	CdnClusterId uint64      `protobuf:"varint,9,opt,name=cdn_cluster_id,json=cdnClusterId,proto3" json:"cdn_cluster_id,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) Descriptor() ([]byte, []int)

Deprecated: Use CDN.ProtoReflect.Descriptor instead.

func (*CDN) GetCdnCluster 

func (x *CDN) GetCdnCluster() *CDNCluster

func (*CDN) GetCdnClusterId 

func (x *CDN) GetCdnClusterId() uint64

func (*CDN) GetDownloadPort 

func (x *CDN) GetDownloadPort() int32

func (*CDN) GetHostName 

func (x *CDN) GetHostName() string

func (*CDN) GetId 

func (x *CDN) GetId() uint64

func (*CDN) GetIdc 

func (x *CDN) GetIdc() string

func (*CDN) GetIp 

func (x *CDN) GetIp() string

func (*CDN) GetLocation 

func (x *CDN) GetLocation() string

func (*CDN) GetPort 

func (x *CDN) GetPort() int32

func (*CDN) GetStatus 

func (x *CDN) GetStatus() string

func (*CDN) ProtoMessage 

func (*CDN) ProtoMessage()

func (*CDN) ProtoReflect 

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

func (*CDN) Reset 

func (x *CDN) Reset()

func (*CDN) String 

func (x *CDN) String() string

func (*CDN) Validate 

func (m *CDN) Validate() error

Validate checks the field values on CDN with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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"`
	CdnClusterId uint64     `protobuf:"varint,3,opt,name=cdn_cluster_id,json=cdnClusterId,proto3" json:"cdn_cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCDNRequest) Descriptor deprecated 

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

Deprecated: Use GetCDNRequest.ProtoReflect.Descriptor instead.

func (*GetCDNRequest) GetCdnClusterId 

func (x *GetCDNRequest) GetCdnClusterId() uint64

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"`
	SchedulerClusterId uint64     `protobuf:"varint,3,opt,name=scheduler_cluster_id,json=schedulerClusterId,proto3" json:"scheduler_cluster_id,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) GetSchedulerClusterId 

func (x *GetSchedulerRequest) GetSchedulerClusterId() uint64

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"`
	ClusterId  uint64     `protobuf:"varint,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*KeepAliveRequest) Descriptor deprecated 

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

Deprecated: Use KeepAliveRequest.ProtoReflect.Descriptor instead.

func (*KeepAliveRequest) GetClusterId 

func (x *KeepAliveRequest) GetClusterId() uint64

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)
	// 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)
	// 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)
	// Get Scheduler and Scheduler cluster configuration
	GetScheduler(context.Context, *GetSchedulerRequest) (*Scheduler, error)
	// Update scheduler configuration
	UpdateScheduler(context.Context, *UpdateSchedulerRequest) (*Scheduler, 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"`
	SchedulerClusterId uint64            `protobuf:"varint,10,opt,name=scheduler_cluster_id,json=schedulerClusterId,proto3" json:"scheduler_cluster_id,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) Descriptor() ([]byte, []int)

Deprecated: Use Scheduler.ProtoReflect.Descriptor instead.

func (*Scheduler) GetCdns 

func (x *Scheduler) GetCdns() []*CDN

func (*Scheduler) GetHostName 

func (x *Scheduler) GetHostName() string

func (*Scheduler) GetId 

func (x *Scheduler) GetId() uint64

func (*Scheduler) GetIdc 

func (x *Scheduler) GetIdc() string

func (*Scheduler) GetIp 

func (x *Scheduler) GetIp() string

func (*Scheduler) GetLocation 

func (x *Scheduler) GetLocation() string

func (*Scheduler) GetNetConfig 

func (x *Scheduler) GetNetConfig() []byte

func (*Scheduler) GetPort 

func (x *Scheduler) GetPort() int32

func (*Scheduler) GetSchedulerCluster 

func (x *Scheduler) GetSchedulerCluster() *SchedulerCluster

func (*Scheduler) GetSchedulerClusterId 

func (x *Scheduler) GetSchedulerClusterId() uint64

func (*Scheduler) GetStatus 

func (x *Scheduler) GetStatus() string

func (*Scheduler) GetVips 

func (x *Scheduler) GetVips() string

func (*Scheduler) ProtoMessage 

func (*Scheduler) ProtoMessage()

func (*Scheduler) ProtoReflect 

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

func (*Scheduler) Reset 

func (x *Scheduler) Reset()

func (*Scheduler) String 

func (x *Scheduler) String() string

func (*Scheduler) Validate 

func (m *Scheduler) Validate() error

Validate checks the field values on Scheduler with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) 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"`
	CdnClusterId uint64     `protobuf:"varint,8,opt,name=cdn_cluster_id,json=cdnClusterId,proto3" json:"cdn_cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCDNRequest) Descriptor deprecated 

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

Deprecated: Use UpdateCDNRequest.ProtoReflect.Descriptor instead.

func (*UpdateCDNRequest) GetCdnClusterId 

func (x *UpdateCDNRequest) GetCdnClusterId() uint64

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"`
	SchedulerClusterId uint64     `protobuf:"varint,3,opt,name=scheduler_cluster_id,json=schedulerClusterId,proto3" json:"scheduler_cluster_id,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) GetSchedulerClusterId 

func (x *UpdateSchedulerRequest) GetSchedulerClusterId() uint64

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.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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