manager

package
v2.0.5-beta.2 Latest Latest
Warning

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

Go to latest
Published: Jul 21, 2022 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: "PEER_SOURCE",
		2: "SEED_PEER_SOURCE",
	}
	SourceType_value = map[string]int32{
		"SCHEDULER_SOURCE": 0,
		"PEER_SOURCE":      1,
		"SEED_PEER_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.Server, srv ManagerServer)

Types

type Bucket added in v2.0.4

type Bucket struct {

	// Bucket name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Bucket represents config of bucket.

func (*Bucket) Descriptor deprecated added in v2.0.4

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

Deprecated: Use Bucket.ProtoReflect.Descriptor instead.

func (*Bucket) GetName added in v2.0.4

func (x *Bucket) GetName() string

func (*Bucket) ProtoMessage added in v2.0.4

func (*Bucket) ProtoMessage()

func (*Bucket) ProtoReflect added in v2.0.4

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

func (*Bucket) Reset added in v2.0.4

func (x *Bucket) Reset()

func (*Bucket) String added in v2.0.4

func (x *Bucket) String() string

func (*Bucket) Validate added in v2.0.4

func (m *Bucket) Validate() error

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

type BucketValidationError added in v2.0.4

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

BucketValidationError is the validation error returned by Bucket.Validate if the designated constraints aren't met.

func (BucketValidationError) Cause added in v2.0.4

func (e BucketValidationError) Cause() error

Cause function returns cause value.

func (BucketValidationError) Error added in v2.0.4

func (e BucketValidationError) Error() string

Error satisfies the builtin error interface

func (BucketValidationError) ErrorName added in v2.0.4

func (e BucketValidationError) ErrorName() string

ErrorName returns error name.

func (BucketValidationError) Field added in v2.0.4

func (e BucketValidationError) Field() string

Field function returns field value.

func (BucketValidationError) Key added in v2.0.4

func (e BucketValidationError) Key() bool

Key function returns key value.

func (BucketValidationError) Reason added in v2.0.4

func (e BucketValidationError) Reason() string

Reason function returns reason value.

type GetObjectStorageRequest added in v2.0.4

type GetObjectStorageRequest struct {

	// Request source type.
	SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"`
	// Source service hostname.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// Source service ip.
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

GetObjectStorageRequest represents request of GetObjectStorage.

func (*GetObjectStorageRequest) Descriptor deprecated added in v2.0.4

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

Deprecated: Use GetObjectStorageRequest.ProtoReflect.Descriptor instead.

func (*GetObjectStorageRequest) GetHostName added in v2.0.4

func (x *GetObjectStorageRequest) GetHostName() string

func (*GetObjectStorageRequest) GetIp added in v2.0.4

func (x *GetObjectStorageRequest) GetIp() string

func (*GetObjectStorageRequest) GetSourceType added in v2.0.4

func (x *GetObjectStorageRequest) GetSourceType() SourceType

func (*GetObjectStorageRequest) ProtoMessage added in v2.0.4

func (*GetObjectStorageRequest) ProtoMessage()

func (*GetObjectStorageRequest) ProtoReflect added in v2.0.4

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

func (*GetObjectStorageRequest) Reset added in v2.0.4

func (x *GetObjectStorageRequest) Reset()

func (*GetObjectStorageRequest) String added in v2.0.4

func (x *GetObjectStorageRequest) String() string

func (*GetObjectStorageRequest) Validate added in v2.0.4

func (m *GetObjectStorageRequest) Validate() error

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

type GetObjectStorageRequestValidationError added in v2.0.4

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

GetObjectStorageRequestValidationError is the validation error returned by GetObjectStorageRequest.Validate if the designated constraints aren't met.

func (GetObjectStorageRequestValidationError) Cause added in v2.0.4

Cause function returns cause value.

func (GetObjectStorageRequestValidationError) Error added in v2.0.4

Error satisfies the builtin error interface

func (GetObjectStorageRequestValidationError) ErrorName added in v2.0.4

ErrorName returns error name.

func (GetObjectStorageRequestValidationError) Field added in v2.0.4

Field function returns field value.

func (GetObjectStorageRequestValidationError) Key added in v2.0.4

Key function returns key value.

func (GetObjectStorageRequestValidationError) Reason added in v2.0.4

Reason function returns reason value.

type GetSchedulerRequest

type GetSchedulerRequest struct {

	// Request source type.
	SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"`
	// Scheduler hostname.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// ID of the cluster to which the scheduler belongs.
	SchedulerClusterId uint64 `protobuf:"varint,3,opt,name=scheduler_cluster_id,json=schedulerClusterId,proto3" json:"scheduler_cluster_id,omitempty"`
	// contains filtered or unexported fields
}

GetSchedulerRequest represents request of GetScheduler.

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

Cause function returns cause value.

func (GetSchedulerRequestValidationError) Error

Error satisfies the builtin error interface

func (GetSchedulerRequestValidationError) ErrorName

ErrorName returns error name.

func (GetSchedulerRequestValidationError) Field

Field function returns field value.

func (GetSchedulerRequestValidationError) Key

Key function returns key value.

func (GetSchedulerRequestValidationError) Reason

Reason function returns reason value.

type GetSeedPeerRequest added in v2.0.3

type GetSeedPeerRequest struct {

	// Request source type.
	SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"`
	// Seed peer host_name.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// ID of the cluster to which the seed peer belongs.
	SeedPeerClusterId uint64 `protobuf:"varint,3,opt,name=seed_peer_cluster_id,json=seedPeerClusterId,proto3" json:"seed_peer_cluster_id,omitempty"`
	// contains filtered or unexported fields
}

GetSeedPeerRequest represents request of GetSeedPeer.

func (*GetSeedPeerRequest) Descriptor deprecated added in v2.0.3

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

Deprecated: Use GetSeedPeerRequest.ProtoReflect.Descriptor instead.

func (*GetSeedPeerRequest) GetHostName added in v2.0.3

func (x *GetSeedPeerRequest) GetHostName() string

func (*GetSeedPeerRequest) GetSeedPeerClusterId added in v2.0.3

func (x *GetSeedPeerRequest) GetSeedPeerClusterId() uint64

func (*GetSeedPeerRequest) GetSourceType added in v2.0.3

func (x *GetSeedPeerRequest) GetSourceType() SourceType

func (*GetSeedPeerRequest) ProtoMessage added in v2.0.3

func (*GetSeedPeerRequest) ProtoMessage()

func (*GetSeedPeerRequest) ProtoReflect added in v2.0.3

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

func (*GetSeedPeerRequest) Reset added in v2.0.3

func (x *GetSeedPeerRequest) Reset()

func (*GetSeedPeerRequest) String added in v2.0.3

func (x *GetSeedPeerRequest) String() string

func (*GetSeedPeerRequest) Validate added in v2.0.3

func (m *GetSeedPeerRequest) Validate() error

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

type GetSeedPeerRequestValidationError added in v2.0.3

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

GetSeedPeerRequestValidationError is the validation error returned by GetSeedPeerRequest.Validate if the designated constraints aren't met.

func (GetSeedPeerRequestValidationError) Cause added in v2.0.3

Cause function returns cause value.

func (GetSeedPeerRequestValidationError) Error added in v2.0.3

Error satisfies the builtin error interface

func (GetSeedPeerRequestValidationError) ErrorName added in v2.0.3

ErrorName returns error name.

func (GetSeedPeerRequestValidationError) Field added in v2.0.3

Field function returns field value.

func (GetSeedPeerRequestValidationError) Key added in v2.0.3

Key function returns key value.

func (GetSeedPeerRequestValidationError) Reason added in v2.0.3

Reason function returns reason value.

type KeepAliveRequest

type KeepAliveRequest struct {

	// Request source type.
	SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"`
	// Source service hostname.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// ID of the cluster to which the source service belongs.
	ClusterId uint64 `protobuf:"varint,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

KeepAliveRequest represents request of KeepAlive.

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

Cause function returns cause value.

func (KeepAliveRequestValidationError) Error

Error satisfies the builtin error interface

func (KeepAliveRequestValidationError) ErrorName

ErrorName returns error name.

func (KeepAliveRequestValidationError) Field

Field function returns field value.

func (KeepAliveRequestValidationError) Key

Key function returns key value.

func (KeepAliveRequestValidationError) Reason

Reason function returns reason value.

type ListBucketsRequest added in v2.0.4

type ListBucketsRequest struct {

	// Request source type.
	SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"`
	// Source service hostname.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// Source service ip.
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

ListSchedulersRequest represents request of ListBuckets.

func (*ListBucketsRequest) Descriptor deprecated added in v2.0.4

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

Deprecated: Use ListBucketsRequest.ProtoReflect.Descriptor instead.

func (*ListBucketsRequest) GetHostName added in v2.0.4

func (x *ListBucketsRequest) GetHostName() string

func (*ListBucketsRequest) GetIp added in v2.0.4

func (x *ListBucketsRequest) GetIp() string

func (*ListBucketsRequest) GetSourceType added in v2.0.4

func (x *ListBucketsRequest) GetSourceType() SourceType

func (*ListBucketsRequest) ProtoMessage added in v2.0.4

func (*ListBucketsRequest) ProtoMessage()

func (*ListBucketsRequest) ProtoReflect added in v2.0.4

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

func (*ListBucketsRequest) Reset added in v2.0.4

func (x *ListBucketsRequest) Reset()

func (*ListBucketsRequest) String added in v2.0.4

func (x *ListBucketsRequest) String() string

func (*ListBucketsRequest) Validate added in v2.0.4

func (m *ListBucketsRequest) Validate() error

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

type ListBucketsRequestValidationError added in v2.0.4

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

ListBucketsRequestValidationError is the validation error returned by ListBucketsRequest.Validate if the designated constraints aren't met.

func (ListBucketsRequestValidationError) Cause added in v2.0.4

Cause function returns cause value.

func (ListBucketsRequestValidationError) Error added in v2.0.4

Error satisfies the builtin error interface

func (ListBucketsRequestValidationError) ErrorName added in v2.0.4

ErrorName returns error name.

func (ListBucketsRequestValidationError) Field added in v2.0.4

Field function returns field value.

func (ListBucketsRequestValidationError) Key added in v2.0.4

Key function returns key value.

func (ListBucketsRequestValidationError) Reason added in v2.0.4

Reason function returns reason value.

type ListBucketsResponse added in v2.0.4

type ListBucketsResponse struct {

	// Bucket configs.
	Buckets []*Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	// contains filtered or unexported fields
}

ListBucketsResponse represents response of ListBuckets.

func (*ListBucketsResponse) Descriptor deprecated added in v2.0.4

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

Deprecated: Use ListBucketsResponse.ProtoReflect.Descriptor instead.

func (*ListBucketsResponse) GetBuckets added in v2.0.4

func (x *ListBucketsResponse) GetBuckets() []*Bucket

func (*ListBucketsResponse) ProtoMessage added in v2.0.4

func (*ListBucketsResponse) ProtoMessage()

func (*ListBucketsResponse) ProtoReflect added in v2.0.4

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

func (*ListBucketsResponse) Reset added in v2.0.4

func (x *ListBucketsResponse) Reset()

func (*ListBucketsResponse) String added in v2.0.4

func (x *ListBucketsResponse) String() string

func (*ListBucketsResponse) Validate added in v2.0.4

func (m *ListBucketsResponse) Validate() error

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

type ListBucketsResponseValidationError added in v2.0.4

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

ListBucketsResponseValidationError is the validation error returned by ListBucketsResponse.Validate if the designated constraints aren't met.

func (ListBucketsResponseValidationError) Cause added in v2.0.4

Cause function returns cause value.

func (ListBucketsResponseValidationError) Error added in v2.0.4

Error satisfies the builtin error interface

func (ListBucketsResponseValidationError) ErrorName added in v2.0.4

ErrorName returns error name.

func (ListBucketsResponseValidationError) Field added in v2.0.4

Field function returns field value.

func (ListBucketsResponseValidationError) Key added in v2.0.4

Key function returns key value.

func (ListBucketsResponseValidationError) Reason added in v2.0.4

Reason function returns reason value.

type ListSchedulersRequest

type ListSchedulersRequest struct {

	// Request source type.
	SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"`
	// Source service hostname.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// Source service ip.
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// Source service host information.
	HostInfo map[string]string `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

ListSchedulersRequest represents request of ListSchedulers.

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

Cause function returns cause value.

func (ListSchedulersRequestValidationError) Error

Error satisfies the builtin error interface

func (ListSchedulersRequestValidationError) ErrorName

ErrorName returns error name.

func (ListSchedulersRequestValidationError) Field

Field function returns field value.

func (ListSchedulersRequestValidationError) Key

Key function returns key value.

func (ListSchedulersRequestValidationError) Reason

Reason function returns reason value.

type ListSchedulersResponse

type ListSchedulersResponse struct {

	// Schedulers to which the source service belongs.
	Schedulers []*Scheduler `protobuf:"bytes,1,rep,name=schedulers,proto3" json:"schedulers,omitempty"`
	// contains filtered or unexported fields
}

ListSchedulersResponse represents response of ListSchedulers.

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

Cause function returns cause value.

func (ListSchedulersResponseValidationError) Error

Error satisfies the builtin error interface

func (ListSchedulersResponseValidationError) ErrorName

ErrorName returns error name.

func (ListSchedulersResponseValidationError) Field

Field function returns field value.

func (ListSchedulersResponseValidationError) Key

Key function returns key value.

func (ListSchedulersResponseValidationError) Reason

Reason function returns reason value.

type ManagerClient

type ManagerClient interface {
	// Get SeedPeer and SeedPeer cluster configuration.
	GetSeedPeer(ctx context.Context, in *GetSeedPeerRequest, opts ...grpc.CallOption) (*SeedPeer, error)
	// Update SeedPeer configuration.
	UpdateSeedPeer(ctx context.Context, in *UpdateSeedPeerRequest, opts ...grpc.CallOption) (*SeedPeer, 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)
	// Get ObjectStorage configuration.
	GetObjectStorage(ctx context.Context, in *GetObjectStorageRequest, opts ...grpc.CallOption) (*ObjectStorage, error)
	// List buckets configuration.
	ListBuckets(ctx context.Context, in *ListBucketsRequest, opts ...grpc.CallOption) (*ListBucketsResponse, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewManagerClient

func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient

type ManagerServer

type ManagerServer interface {
	// Get SeedPeer and SeedPeer cluster configuration.
	GetSeedPeer(context.Context, *GetSeedPeerRequest) (*SeedPeer, error)
	// Update SeedPeer configuration.
	UpdateSeedPeer(context.Context, *UpdateSeedPeerRequest) (*SeedPeer, 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)
	// Get ObjectStorage configuration.
	GetObjectStorage(context.Context, *GetObjectStorageRequest) (*ObjectStorage, error)
	// List buckets configuration.
	ListBuckets(context.Context, *ListBucketsRequest) (*ListBucketsResponse, error)
	// KeepAlive with manager.
	KeepAlive(Manager_KeepAliveServer) error
}

ManagerServer is the server API for Manager service.

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 ObjectStorage added in v2.0.4

type ObjectStorage struct {

	// Object storage name of type.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Storage region.
	Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	// Datacenter endpoint.
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Access key id.
	AccessKey string `protobuf:"bytes,4,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	// Access key secret.
	SecretKey string `protobuf:"bytes,5,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	// contains filtered or unexported fields
}

ObjectStorage represents config of object storage.

func (*ObjectStorage) Descriptor deprecated added in v2.0.4

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

Deprecated: Use ObjectStorage.ProtoReflect.Descriptor instead.

func (*ObjectStorage) GetAccessKey added in v2.0.4

func (x *ObjectStorage) GetAccessKey() string

func (*ObjectStorage) GetEndpoint added in v2.0.4

func (x *ObjectStorage) GetEndpoint() string

func (*ObjectStorage) GetName added in v2.0.4

func (x *ObjectStorage) GetName() string

func (*ObjectStorage) GetRegion added in v2.0.4

func (x *ObjectStorage) GetRegion() string

func (*ObjectStorage) GetSecretKey added in v2.0.4

func (x *ObjectStorage) GetSecretKey() string

func (*ObjectStorage) ProtoMessage added in v2.0.4

func (*ObjectStorage) ProtoMessage()

func (*ObjectStorage) ProtoReflect added in v2.0.4

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

func (*ObjectStorage) Reset added in v2.0.4

func (x *ObjectStorage) Reset()

func (*ObjectStorage) String added in v2.0.4

func (x *ObjectStorage) String() string

func (*ObjectStorage) Validate added in v2.0.4

func (m *ObjectStorage) Validate() error

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

type ObjectStorageValidationError added in v2.0.4

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

ObjectStorageValidationError is the validation error returned by ObjectStorage.Validate if the designated constraints aren't met.

func (ObjectStorageValidationError) Cause added in v2.0.4

Cause function returns cause value.

func (ObjectStorageValidationError) Error added in v2.0.4

Error satisfies the builtin error interface

func (ObjectStorageValidationError) ErrorName added in v2.0.4

func (e ObjectStorageValidationError) ErrorName() string

ErrorName returns error name.

func (ObjectStorageValidationError) Field added in v2.0.4

Field function returns field value.

func (ObjectStorageValidationError) Key added in v2.0.4

Key function returns key value.

func (ObjectStorageValidationError) Reason added in v2.0.4

Reason function returns reason value.

type Scheduler

type Scheduler struct {

	// Scheduler id.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Scheduler hostname.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// Deprecated: Do not use.
	Vips string `protobuf:"bytes,3,opt,name=vips,proto3" json:"vips,omitempty"`
	// Scheduler idc.
	Idc string `protobuf:"bytes,4,opt,name=idc,proto3" json:"idc,omitempty"`
	// Scheduler location.
	Location string `protobuf:"bytes,5,opt,name=location,proto3" json:"location,omitempty"`
	// Deprecated: Use net_topology instead.
	NetConfig []byte `protobuf:"bytes,6,opt,name=net_config,json=netConfig,proto3" json:"net_config,omitempty"`
	// Scheduler ip.
	Ip string `protobuf:"bytes,7,opt,name=ip,proto3" json:"ip,omitempty"`
	// Scheduler grpc port.
	Port int32 `protobuf:"varint,8,opt,name=port,proto3" json:"port,omitempty"`
	// Scheduler state.
	State string `protobuf:"bytes,9,opt,name=state,proto3" json:"state,omitempty"`
	// ID of the cluster to which the scheduler belongs.
	SchedulerClusterId uint64 `protobuf:"varint,10,opt,name=scheduler_cluster_id,json=schedulerClusterId,proto3" json:"scheduler_cluster_id,omitempty"`
	// Cluster to which the scheduler belongs.
	SchedulerCluster *SchedulerCluster `protobuf:"bytes,11,opt,name=scheduler_cluster,json=schedulerCluster,proto3" json:"scheduler_cluster,omitempty"`
	// Seed peers to which the scheduler belongs.
	SeedPeers []*SeedPeer `protobuf:"bytes,13,rep,name=seed_peers,json=seedPeers,proto3" json:"seed_peers,omitempty"`
	// Scheduler network topology.
	NetTopology string `protobuf:"bytes,14,opt,name=net_topology,json=netTopology,proto3" json:"net_topology,omitempty"`
	// contains filtered or unexported fields
}

SeedPeerCluster represents scheduler for network.

func (*Scheduler) Descriptor deprecated

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

Deprecated: Use Scheduler.ProtoReflect.Descriptor instead.

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) GetNetTopology added in v2.0.3

func (x *Scheduler) GetNetTopology() string

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) GetSeedPeers added in v2.0.3

func (x *Scheduler) GetSeedPeers() []*SeedPeer

func (*Scheduler) GetState added in v2.0.1

func (x *Scheduler) GetState() 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 {

	// Cluster id.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster biography.
	Bio string `protobuf:"bytes,3,opt,name=bio,proto3" json:"bio,omitempty"`
	// Cluster config.
	Config []byte `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// Cluster client config.
	ClientConfig []byte `protobuf:"bytes,5,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"`
	// Cluster scopes.
	Scopes []byte `protobuf:"bytes,6,opt,name=scopes,proto3" json:"scopes,omitempty"`
	// Security group to which the scheduler cluster belongs.
	SecurityGroup *SecurityGroup `protobuf:"bytes,7,opt,name=security_group,json=securityGroup,proto3" json:"security_group,omitempty"`
	// contains filtered or unexported fields
}

SeedPeerCluster represents cluster of scheduler.

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) GetScopes added in v2.0.3

func (x *SchedulerCluster) GetScopes() []byte

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

Cause function returns cause value.

func (SchedulerClusterValidationError) Error

Error satisfies the builtin error interface

func (SchedulerClusterValidationError) ErrorName

ErrorName returns error name.

func (SchedulerClusterValidationError) Field

Field function returns field value.

func (SchedulerClusterValidationError) Key

Key function returns key value.

func (SchedulerClusterValidationError) Reason

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

Key function returns key value.

func (SchedulerValidationError) Reason

func (e SchedulerValidationError) Reason() string

Reason function returns reason value.

type SecurityGroup

type SecurityGroup struct {

	// Group id.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Group name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Group biography.
	Bio string `protobuf:"bytes,3,opt,name=bio,proto3" json:"bio,omitempty"`
	// Group domain.
	Domain string `protobuf:"bytes,4,opt,name=domain,proto3" json:"domain,omitempty"`
	// Group proxy domain.
	ProxyDomain string `protobuf:"bytes,5,opt,name=proxy_domain,json=proxyDomain,proto3" json:"proxy_domain,omitempty"`
	// contains filtered or unexported fields
}

SecurityGroup represents security group of cluster.

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

Cause function returns cause value.

func (SecurityGroupValidationError) Error

Error satisfies the builtin error interface

func (SecurityGroupValidationError) ErrorName

func (e SecurityGroupValidationError) ErrorName() string

ErrorName returns error name.

func (SecurityGroupValidationError) Field

Field function returns field value.

func (SecurityGroupValidationError) Key

Key function returns key value.

func (SecurityGroupValidationError) Reason

Reason function returns reason value.

type SeedPeer added in v2.0.3

type SeedPeer struct {

	// Seed peer id.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Seed peer hostname.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// Seed peer type.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// Seed peer idc.
	Idc string `protobuf:"bytes,5,opt,name=idc,proto3" json:"idc,omitempty"`
	// Seed peer network topology.
	NetTopology string `protobuf:"bytes,6,opt,name=net_topology,json=netTopology,proto3" json:"net_topology,omitempty"`
	// Seed peer location.
	Location string `protobuf:"bytes,7,opt,name=location,proto3" json:"location,omitempty"`
	// Seed peer ip.
	Ip string `protobuf:"bytes,8,opt,name=ip,proto3" json:"ip,omitempty"`
	// Seed peer grpc port.
	Port int32 `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"`
	// Seed peer download port.
	DownloadPort int32 `protobuf:"varint,10,opt,name=download_port,json=downloadPort,proto3" json:"download_port,omitempty"`
	// Seed peer state.
	State string `protobuf:"bytes,11,opt,name=state,proto3" json:"state,omitempty"`
	// ID of the cluster to which the seed peer belongs.
	SeedPeerClusterId uint64 `protobuf:"varint,12,opt,name=seed_peer_cluster_id,json=seedPeerClusterId,proto3" json:"seed_peer_cluster_id,omitempty"`
	// Cluster to which the seed peer belongs.
	SeedPeerCluster *SeedPeerCluster `protobuf:"bytes,13,opt,name=seed_peer_cluster,json=seedPeerCluster,proto3" json:"seed_peer_cluster,omitempty"`
	// Schedulers included in seed peer.
	Schedulers []*Scheduler `protobuf:"bytes,14,rep,name=schedulers,proto3" json:"schedulers,omitempty"`
	// Seed peer object storage port.
	ObjectStoragePort int32 `protobuf:"varint,15,opt,name=object_storage_port,json=objectStoragePort,proto3" json:"object_storage_port,omitempty"`
	// contains filtered or unexported fields
}

SeedPeer represents seed peer for network.

func (*SeedPeer) Descriptor deprecated added in v2.0.3

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

Deprecated: Use SeedPeer.ProtoReflect.Descriptor instead.

func (*SeedPeer) GetDownloadPort added in v2.0.3

func (x *SeedPeer) GetDownloadPort() int32

func (*SeedPeer) GetHostName added in v2.0.3

func (x *SeedPeer) GetHostName() string

func (*SeedPeer) GetId added in v2.0.3

func (x *SeedPeer) GetId() uint64

func (*SeedPeer) GetIdc added in v2.0.3

func (x *SeedPeer) GetIdc() string

func (*SeedPeer) GetIp added in v2.0.3

func (x *SeedPeer) GetIp() string

func (*SeedPeer) GetLocation added in v2.0.3

func (x *SeedPeer) GetLocation() string

func (*SeedPeer) GetNetTopology added in v2.0.3

func (x *SeedPeer) GetNetTopology() string

func (*SeedPeer) GetObjectStoragePort added in v2.0.4

func (x *SeedPeer) GetObjectStoragePort() int32

func (*SeedPeer) GetPort added in v2.0.3

func (x *SeedPeer) GetPort() int32

func (*SeedPeer) GetSchedulers added in v2.0.3

func (x *SeedPeer) GetSchedulers() []*Scheduler

func (*SeedPeer) GetSeedPeerCluster added in v2.0.3

func (x *SeedPeer) GetSeedPeerCluster() *SeedPeerCluster

func (*SeedPeer) GetSeedPeerClusterId added in v2.0.3

func (x *SeedPeer) GetSeedPeerClusterId() uint64

func (*SeedPeer) GetState added in v2.0.3

func (x *SeedPeer) GetState() string

func (*SeedPeer) GetType added in v2.0.3

func (x *SeedPeer) GetType() string

func (*SeedPeer) ProtoMessage added in v2.0.3

func (*SeedPeer) ProtoMessage()

func (*SeedPeer) ProtoReflect added in v2.0.3

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

func (*SeedPeer) Reset added in v2.0.3

func (x *SeedPeer) Reset()

func (*SeedPeer) String added in v2.0.3

func (x *SeedPeer) String() string

func (*SeedPeer) Validate added in v2.0.3

func (m *SeedPeer) Validate() error

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

type SeedPeerCluster added in v2.0.3

type SeedPeerCluster struct {

	// Cluster id.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster biography.
	Bio string `protobuf:"bytes,3,opt,name=bio,proto3" json:"bio,omitempty"`
	// Cluster configuration.
	Config []byte `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// Cluster scopes.
	Scopes []byte `protobuf:"bytes,5,opt,name=scopes,proto3" json:"scopes,omitempty"`
	// Security group to which the seed peer cluster belongs.
	SecurityGroup *SecurityGroup `protobuf:"bytes,6,opt,name=security_group,json=securityGroup,proto3" json:"security_group,omitempty"`
	// contains filtered or unexported fields
}

SeedPeerCluster represents cluster of seed peer.

func (*SeedPeerCluster) Descriptor deprecated added in v2.0.3

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

Deprecated: Use SeedPeerCluster.ProtoReflect.Descriptor instead.

func (*SeedPeerCluster) GetBio added in v2.0.3

func (x *SeedPeerCluster) GetBio() string

func (*SeedPeerCluster) GetConfig added in v2.0.3

func (x *SeedPeerCluster) GetConfig() []byte

func (*SeedPeerCluster) GetId added in v2.0.3

func (x *SeedPeerCluster) GetId() uint64

func (*SeedPeerCluster) GetName added in v2.0.3

func (x *SeedPeerCluster) GetName() string

func (*SeedPeerCluster) GetScopes added in v2.0.3

func (x *SeedPeerCluster) GetScopes() []byte

func (*SeedPeerCluster) GetSecurityGroup added in v2.0.3

func (x *SeedPeerCluster) GetSecurityGroup() *SecurityGroup

func (*SeedPeerCluster) ProtoMessage added in v2.0.3

func (*SeedPeerCluster) ProtoMessage()

func (*SeedPeerCluster) ProtoReflect added in v2.0.3

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

func (*SeedPeerCluster) Reset added in v2.0.3

func (x *SeedPeerCluster) Reset()

func (*SeedPeerCluster) String added in v2.0.3

func (x *SeedPeerCluster) String() string

func (*SeedPeerCluster) Validate added in v2.0.3

func (m *SeedPeerCluster) Validate() error

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

type SeedPeerClusterValidationError added in v2.0.3

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

SeedPeerClusterValidationError is the validation error returned by SeedPeerCluster.Validate if the designated constraints aren't met.

func (SeedPeerClusterValidationError) Cause added in v2.0.3

Cause function returns cause value.

func (SeedPeerClusterValidationError) Error added in v2.0.3

Error satisfies the builtin error interface

func (SeedPeerClusterValidationError) ErrorName added in v2.0.3

func (e SeedPeerClusterValidationError) ErrorName() string

ErrorName returns error name.

func (SeedPeerClusterValidationError) Field added in v2.0.3

Field function returns field value.

func (SeedPeerClusterValidationError) Key added in v2.0.3

Key function returns key value.

func (SeedPeerClusterValidationError) Reason added in v2.0.3

Reason function returns reason value.

type SeedPeerValidationError added in v2.0.3

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

SeedPeerValidationError is the validation error returned by SeedPeer.Validate if the designated constraints aren't met.

func (SeedPeerValidationError) Cause added in v2.0.3

func (e SeedPeerValidationError) Cause() error

Cause function returns cause value.

func (SeedPeerValidationError) Error added in v2.0.3

func (e SeedPeerValidationError) Error() string

Error satisfies the builtin error interface

func (SeedPeerValidationError) ErrorName added in v2.0.3

func (e SeedPeerValidationError) ErrorName() string

ErrorName returns error name.

func (SeedPeerValidationError) Field added in v2.0.3

func (e SeedPeerValidationError) Field() string

Field function returns field value.

func (SeedPeerValidationError) Key added in v2.0.3

func (e SeedPeerValidationError) Key() bool

Key function returns key value.

func (SeedPeerValidationError) Reason added in v2.0.3

func (e SeedPeerValidationError) Reason() string

Reason function returns reason value.

type SourceType

type SourceType int32

Request source type.

const (
	// Scheduler service.
	SourceType_SCHEDULER_SOURCE SourceType = 0
	// Peer service.
	SourceType_PEER_SOURCE SourceType = 1
	// SeedPeer service.
	SourceType_SEED_PEER_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

type UnimplementedManagerServer

type UnimplementedManagerServer struct {
}

UnimplementedManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedManagerServer) GetObjectStorage added in v2.0.4

func (*UnimplementedManagerServer) GetScheduler

func (*UnimplementedManagerServer) GetSeedPeer added in v2.0.3

func (*UnimplementedManagerServer) KeepAlive

func (*UnimplementedManagerServer) ListBuckets added in v2.0.4

func (*UnimplementedManagerServer) ListSchedulers

func (*UnimplementedManagerServer) UpdateScheduler

func (*UnimplementedManagerServer) UpdateSeedPeer added in v2.0.3

type UpdateSchedulerRequest

type UpdateSchedulerRequest struct {

	// Request source type.
	SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"`
	// Scheduler hostname.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// ID of the cluster to which the scheduler belongs.
	SchedulerClusterId uint64 `protobuf:"varint,3,opt,name=scheduler_cluster_id,json=schedulerClusterId,proto3" json:"scheduler_cluster_id,omitempty"`
	// Deprecated: Do not use.
	Vips string `protobuf:"bytes,4,opt,name=vips,proto3" json:"vips,omitempty"`
	// Scheduler idc.
	Idc string `protobuf:"bytes,5,opt,name=idc,proto3" json:"idc,omitempty"`
	// Scheduler location.
	Location string `protobuf:"bytes,6,opt,name=location,proto3" json:"location,omitempty"`
	// Deprecated: Use net_topology instead.
	NetConfig []byte `protobuf:"bytes,7,opt,name=net_config,json=netConfig,proto3" json:"net_config,omitempty"`
	// Scheduler ip.
	Ip string `protobuf:"bytes,8,opt,name=ip,proto3" json:"ip,omitempty"`
	// Scheduler port.
	Port int32 `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"`
	// Scheduler network topology.
	NetTopology string `protobuf:"bytes,10,opt,name=net_topology,json=netTopology,proto3" json:"net_topology,omitempty"`
	// contains filtered or unexported fields
}

UpdateSchedulerRequest represents request of UpdateScheduler.

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) GetNetTopology added in v2.0.3

func (x *UpdateSchedulerRequest) GetNetTopology() string

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

Cause function returns cause value.

func (UpdateSchedulerRequestValidationError) Error

Error satisfies the builtin error interface

func (UpdateSchedulerRequestValidationError) ErrorName

ErrorName returns error name.

func (UpdateSchedulerRequestValidationError) Field

Field function returns field value.

func (UpdateSchedulerRequestValidationError) Key

Key function returns key value.

func (UpdateSchedulerRequestValidationError) Reason

Reason function returns reason value.

type UpdateSeedPeerRequest added in v2.0.3

type UpdateSeedPeerRequest struct {

	// Request source type.
	SourceType SourceType `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=manager.SourceType" json:"source_type,omitempty"`
	// Seed peer hostname.
	HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// Seed peer type.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// Seed peer idc.
	Idc string `protobuf:"bytes,5,opt,name=idc,proto3" json:"idc,omitempty"`
	// Seed peer network topology.
	NetTopology string `protobuf:"bytes,6,opt,name=net_topology,json=netTopology,proto3" json:"net_topology,omitempty"`
	// Seed peer location.
	Location string `protobuf:"bytes,7,opt,name=location,proto3" json:"location,omitempty"`
	// Seed peer ip.
	Ip string `protobuf:"bytes,8,opt,name=ip,proto3" json:"ip,omitempty"`
	// Seed peer port.
	Port int32 `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"`
	// Seed peer download port.
	DownloadPort int32 `protobuf:"varint,10,opt,name=download_port,json=downloadPort,proto3" json:"download_port,omitempty"`
	// ID of the cluster to which the seed peer belongs.
	SeedPeerClusterId uint64 `protobuf:"varint,11,opt,name=seed_peer_cluster_id,json=seedPeerClusterId,proto3" json:"seed_peer_cluster_id,omitempty"`
	// Seed peer object storage port.
	ObjectStoragePort int32 `protobuf:"varint,12,opt,name=object_storage_port,json=objectStoragePort,proto3" json:"object_storage_port,omitempty"`
	// contains filtered or unexported fields
}

UpdateSeedPeerRequest represents request of UpdateSeedPeer.

func (*UpdateSeedPeerRequest) Descriptor deprecated added in v2.0.3

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

Deprecated: Use UpdateSeedPeerRequest.ProtoReflect.Descriptor instead.

func (*UpdateSeedPeerRequest) GetDownloadPort added in v2.0.3

func (x *UpdateSeedPeerRequest) GetDownloadPort() int32

func (*UpdateSeedPeerRequest) GetHostName added in v2.0.3

func (x *UpdateSeedPeerRequest) GetHostName() string

func (*UpdateSeedPeerRequest) GetIdc added in v2.0.3

func (x *UpdateSeedPeerRequest) GetIdc() string

func (*UpdateSeedPeerRequest) GetIp added in v2.0.3

func (x *UpdateSeedPeerRequest) GetIp() string

func (*UpdateSeedPeerRequest) GetLocation added in v2.0.3

func (x *UpdateSeedPeerRequest) GetLocation() string

func (*UpdateSeedPeerRequest) GetNetTopology added in v2.0.3

func (x *UpdateSeedPeerRequest) GetNetTopology() string

func (*UpdateSeedPeerRequest) GetObjectStoragePort added in v2.0.4

func (x *UpdateSeedPeerRequest) GetObjectStoragePort() int32

func (*UpdateSeedPeerRequest) GetPort added in v2.0.3

func (x *UpdateSeedPeerRequest) GetPort() int32

func (*UpdateSeedPeerRequest) GetSeedPeerClusterId added in v2.0.3

func (x *UpdateSeedPeerRequest) GetSeedPeerClusterId() uint64

func (*UpdateSeedPeerRequest) GetSourceType added in v2.0.3

func (x *UpdateSeedPeerRequest) GetSourceType() SourceType

func (*UpdateSeedPeerRequest) GetType added in v2.0.3

func (x *UpdateSeedPeerRequest) GetType() string

func (*UpdateSeedPeerRequest) ProtoMessage added in v2.0.3

func (*UpdateSeedPeerRequest) ProtoMessage()

func (*UpdateSeedPeerRequest) ProtoReflect added in v2.0.3

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

func (*UpdateSeedPeerRequest) Reset added in v2.0.3

func (x *UpdateSeedPeerRequest) Reset()

func (*UpdateSeedPeerRequest) String added in v2.0.3

func (x *UpdateSeedPeerRequest) String() string

func (*UpdateSeedPeerRequest) Validate added in v2.0.3

func (m *UpdateSeedPeerRequest) Validate() error

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

type UpdateSeedPeerRequestValidationError added in v2.0.3

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

UpdateSeedPeerRequestValidationError is the validation error returned by UpdateSeedPeerRequest.Validate if the designated constraints aren't met.

func (UpdateSeedPeerRequestValidationError) Cause added in v2.0.3

Cause function returns cause value.

func (UpdateSeedPeerRequestValidationError) Error added in v2.0.3

Error satisfies the builtin error interface

func (UpdateSeedPeerRequestValidationError) ErrorName added in v2.0.3

ErrorName returns error name.

func (UpdateSeedPeerRequestValidationError) Field added in v2.0.3

Field function returns field value.

func (UpdateSeedPeerRequestValidationError) Key added in v2.0.3

Key function returns key value.

func (UpdateSeedPeerRequestValidationError) Reason added in v2.0.3

Reason function returns reason value.

Directories

Path Synopsis
mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

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