manager

package
v2.0.77 Latest Latest
Warning

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

 Go to latest Published: Jan 11, 2024 License: Apache-2.0 Imports: 23 Imported by: 17

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_apis_manager_v1_manager_proto protoreflect.FileDescriptor
View Source 
var Manager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "manager.Manager",
	HandlerType: (*ManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSeedPeer",
			Handler:    _Manager_GetSeedPeer_Handler,
		},
		{
			MethodName: "ListSeedPeers",
			Handler:    _Manager_ListSeedPeers_Handler,
		},
		{
			MethodName: "UpdateSeedPeer",
			Handler:    _Manager_UpdateSeedPeer_Handler,
		},
		{
			MethodName: "GetScheduler",
			Handler:    _Manager_GetScheduler_Handler,
		},
		{
			MethodName: "UpdateScheduler",
			Handler:    _Manager_UpdateScheduler_Handler,
		},
		{
			MethodName: "ListSchedulers",
			Handler:    _Manager_ListSchedulers_Handler,
		},
		{
			MethodName: "GetObjectStorage",
			Handler:    _Manager_GetObjectStorage_Handler,
		},
		{
			MethodName: "ListBuckets",
			Handler:    _Manager_ListBuckets_Handler,
		},
		{
			MethodName: "ListApplications",
			Handler:    _Manager_ListApplications_Handler,
		},
		{
			MethodName: "CreateModel",
			Handler:    _Manager_CreateModel_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "KeepAlive",
			Handler:       _Manager_KeepAlive_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/manager/v1/manager.proto",
}

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

Functions

func RegisterManagerServer 

func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)

Types

type Application 

type Application struct {

	// Application id.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Application name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Application url.
	Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// Application biography.
	Bio string `protobuf:"bytes,4,opt,name=bio,proto3" json:"bio,omitempty"`
	// Application priority.
	Priority *ApplicationPriority `protobuf:"bytes,5,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

Application represents config of application.

func (*Application) Descriptor deprecated 

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

Deprecated: Use Application.ProtoReflect.Descriptor instead.

func (*Application) GetBio 

func (x *Application) GetBio() string

func (*Application) GetId 

func (x *Application) GetId() uint64

func (*Application) GetName 

func (x *Application) GetName() string

func (*Application) GetPriority 

func (x *Application) GetPriority() *ApplicationPriority

func (*Application) GetUrl 

func (x *Application) GetUrl() string

func (*Application) ProtoMessage 

func (*Application) ProtoMessage()

func (*Application) ProtoReflect 

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

func (*Application) Reset 

func (x *Application) Reset()

func (*Application) String 

func (x *Application) String() string

func (*Application) Validate 

func (m *Application) Validate() error

Validate checks the field values on Application with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Application) ValidateAll 

func (m *Application) ValidateAll() error

ValidateAll checks the field values on Application with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApplicationMultiError, or nil if none found.

type ApplicationMultiError 

type ApplicationMultiError []error

ApplicationMultiError is an error wrapping multiple validation errors returned by Application.ValidateAll() if the designated constraints aren't met.

func (ApplicationMultiError) AllErrors 

func (m ApplicationMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApplicationMultiError) Error 

func (m ApplicationMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ApplicationPriority 

type ApplicationPriority struct {

	// Priority value.
	Value v1.Priority `protobuf:"varint,1,opt,name=value,proto3,enum=common.Priority" json:"value,omitempty"`
	// URL priority.
	Urls []*URLPriority `protobuf:"bytes,2,rep,name=urls,proto3" json:"urls,omitempty"`
	// contains filtered or unexported fields
}

ApplicationPriority represents config of application priority.

func (*ApplicationPriority) Descriptor deprecated 

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

Deprecated: Use ApplicationPriority.ProtoReflect.Descriptor instead.

func (*ApplicationPriority) GetUrls 

func (x *ApplicationPriority) GetUrls() []*URLPriority

func (*ApplicationPriority) GetValue 

func (x *ApplicationPriority) GetValue() v1.Priority

func (*ApplicationPriority) ProtoMessage 

func (*ApplicationPriority) ProtoMessage()

func (*ApplicationPriority) ProtoReflect 

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

func (*ApplicationPriority) Reset 

func (x *ApplicationPriority) Reset()

func (*ApplicationPriority) String 

func (x *ApplicationPriority) String() string

func (*ApplicationPriority) Validate 

func (m *ApplicationPriority) Validate() error

Validate checks the field values on ApplicationPriority with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApplicationPriority) ValidateAll 

func (m *ApplicationPriority) ValidateAll() error

ValidateAll checks the field values on ApplicationPriority with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApplicationPriorityMultiError, or nil if none found.

type ApplicationPriorityMultiError 

type ApplicationPriorityMultiError []error

ApplicationPriorityMultiError is an error wrapping multiple validation errors returned by ApplicationPriority.ValidateAll() if the designated constraints aren't met.

func (ApplicationPriorityMultiError) AllErrors 

func (m ApplicationPriorityMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApplicationPriorityMultiError) Error 

func (m ApplicationPriorityMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ApplicationPriorityValidationError 

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

ApplicationPriorityValidationError is the validation error returned by ApplicationPriority.Validate if the designated constraints aren't met.

func (ApplicationPriorityValidationError) Cause 

func (e ApplicationPriorityValidationError) Cause() error

Cause function returns cause value.

func (ApplicationPriorityValidationError) Error 

func (e ApplicationPriorityValidationError) Error() string

Error satisfies the builtin error interface

func (ApplicationPriorityValidationError) ErrorName 

func (e ApplicationPriorityValidationError) ErrorName() string

ErrorName returns error name.

func (ApplicationPriorityValidationError) Field 

func (e ApplicationPriorityValidationError) Field() string

Field function returns field value.

func (ApplicationPriorityValidationError) Key 

func (e ApplicationPriorityValidationError) Key() bool

Key function returns key value.

func (ApplicationPriorityValidationError) Reason 

func (e ApplicationPriorityValidationError) Reason() string

Reason function returns reason value.

type ApplicationValidationError 

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

ApplicationValidationError is the validation error returned by Application.Validate if the designated constraints aren't met.

func (ApplicationValidationError) Cause 

func (e ApplicationValidationError) Cause() error

Cause function returns cause value.

func (ApplicationValidationError) Error 

func (e ApplicationValidationError) Error() string

Error satisfies the builtin error interface

func (ApplicationValidationError) ErrorName 

func (e ApplicationValidationError) ErrorName() string

ErrorName returns error name.

func (ApplicationValidationError) Field 

func (e ApplicationValidationError) Field() string

Field function returns field value.

func (ApplicationValidationError) Key 

func (e ApplicationValidationError) Key() bool

Key function returns key value.

func (ApplicationValidationError) Reason 

func (e ApplicationValidationError) Reason() string

Reason function returns reason value.

type Bucket 

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 

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

Deprecated: Use Bucket.ProtoReflect.Descriptor instead.

func (*Bucket) GetName 

func (x *Bucket) GetName() string

func (*Bucket) ProtoMessage 

func (*Bucket) ProtoMessage()

func (*Bucket) ProtoReflect 

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

func (*Bucket) Reset 

func (x *Bucket) Reset()

func (*Bucket) String 

func (x *Bucket) String() string

func (*Bucket) Validate 

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, the first error encountered is returned, or nil if there are no violations.

func (*Bucket) ValidateAll 

func (m *Bucket) ValidateAll() error

ValidateAll checks the field values on Bucket with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in BucketMultiError, or nil if none found.

type BucketMultiError 

type BucketMultiError []error

BucketMultiError is an error wrapping multiple validation errors returned by Bucket.ValidateAll() if the designated constraints aren't met.

func (BucketMultiError) AllErrors 

func (m BucketMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BucketMultiError) Error 

func (m BucketMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type BucketValidationError 

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 

func (e BucketValidationError) Cause() error

Cause function returns cause value.

func (BucketValidationError) Error 

func (e BucketValidationError) Error() string

Error satisfies the builtin error interface

func (BucketValidationError) ErrorName 

func (e BucketValidationError) ErrorName() string

ErrorName returns error name.

func (BucketValidationError) Field 

func (e BucketValidationError) Field() string

Field function returns field value.

func (BucketValidationError) Key 

func (e BucketValidationError) Key() bool

Key function returns key value.

func (BucketValidationError) Reason 

func (e BucketValidationError) Reason() string

Reason function returns reason value.

type CreateGNNRequest 

type CreateGNNRequest struct {

	// Protocol buffer file of model.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Recall of the model.
	Recall float64 `protobuf:"fixed64,2,opt,name=recall,proto3" json:"recall,omitempty"`
	// Precision of the model.
	Precision float64 `protobuf:"fixed64,3,opt,name=precision,proto3" json:"precision,omitempty"`
	// F1-Score of the model.
	F1Score float64 `protobuf:"fixed64,4,opt,name=f1_score,json=f1Score,proto3" json:"f1_score,omitempty"`
	// contains filtered or unexported fields
}

CreateGNNRequest represents to create GNN model request of TrainRequest.

func (*CreateGNNRequest) Descriptor deprecated 

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

Deprecated: Use CreateGNNRequest.ProtoReflect.Descriptor instead.

func (*CreateGNNRequest) GetData 

func (x *CreateGNNRequest) GetData() []byte

func (*CreateGNNRequest) GetF1Score 

func (x *CreateGNNRequest) GetF1Score() float64

func (*CreateGNNRequest) GetPrecision 

func (x *CreateGNNRequest) GetPrecision() float64

func (*CreateGNNRequest) GetRecall 

func (x *CreateGNNRequest) GetRecall() float64

func (*CreateGNNRequest) ProtoMessage 

func (*CreateGNNRequest) ProtoMessage()

func (*CreateGNNRequest) ProtoReflect 

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

func (*CreateGNNRequest) Reset 

func (x *CreateGNNRequest) Reset()

func (*CreateGNNRequest) String 

func (x *CreateGNNRequest) String() string

func (*CreateGNNRequest) Validate 

func (m *CreateGNNRequest) Validate() error

Validate checks the field values on CreateGNNRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateGNNRequest) ValidateAll 

func (m *CreateGNNRequest) ValidateAll() error

ValidateAll checks the field values on CreateGNNRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateGNNRequestMultiError, or nil if none found.

type CreateGNNRequestMultiError 

type CreateGNNRequestMultiError []error

CreateGNNRequestMultiError is an error wrapping multiple validation errors returned by CreateGNNRequest.ValidateAll() if the designated constraints aren't met.

func (CreateGNNRequestMultiError) AllErrors 

func (m CreateGNNRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateGNNRequestMultiError) Error 

func (m CreateGNNRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateGNNRequestValidationError 

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

CreateGNNRequestValidationError is the validation error returned by CreateGNNRequest.Validate if the designated constraints aren't met.

func (CreateGNNRequestValidationError) Cause 

func (e CreateGNNRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateGNNRequestValidationError) Error 

func (e CreateGNNRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateGNNRequestValidationError) ErrorName 

func (e CreateGNNRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateGNNRequestValidationError) Field 

func (e CreateGNNRequestValidationError) Field() string

Field function returns field value.

func (CreateGNNRequestValidationError) Key 

func (e CreateGNNRequestValidationError) Key() bool

Key function returns key value.

func (CreateGNNRequestValidationError) Reason 

func (e CreateGNNRequestValidationError) Reason() string

Reason function returns reason value.

type CreateMLPRequest 

type CreateMLPRequest struct {

	// Protocol buffer file of model.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// MSE of the model.
	Mse float64 `protobuf:"fixed64,2,opt,name=mse,proto3" json:"mse,omitempty"`
	// MAE of the model.
	Mae float64 `protobuf:"fixed64,3,opt,name=mae,proto3" json:"mae,omitempty"`
	// contains filtered or unexported fields
}

CreateMLPRequest represents to create MLP model request of TrainRequest.

func (*CreateMLPRequest) Descriptor deprecated 

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

Deprecated: Use CreateMLPRequest.ProtoReflect.Descriptor instead.

func (*CreateMLPRequest) GetData 

func (x *CreateMLPRequest) GetData() []byte

func (*CreateMLPRequest) GetMae 

func (x *CreateMLPRequest) GetMae() float64

func (*CreateMLPRequest) GetMse 

func (x *CreateMLPRequest) GetMse() float64

func (*CreateMLPRequest) ProtoMessage 

func (*CreateMLPRequest) ProtoMessage()

func (*CreateMLPRequest) ProtoReflect 

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

func (*CreateMLPRequest) Reset 

func (x *CreateMLPRequest) Reset()

func (*CreateMLPRequest) String 

func (x *CreateMLPRequest) String() string

func (*CreateMLPRequest) Validate 

func (m *CreateMLPRequest) Validate() error

Validate checks the field values on CreateMLPRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateMLPRequest) ValidateAll 

func (m *CreateMLPRequest) ValidateAll() error

ValidateAll checks the field values on CreateMLPRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateMLPRequestMultiError, or nil if none found.

type CreateMLPRequestMultiError 

type CreateMLPRequestMultiError []error

CreateMLPRequestMultiError is an error wrapping multiple validation errors returned by CreateMLPRequest.ValidateAll() if the designated constraints aren't met.

func (CreateMLPRequestMultiError) AllErrors 

func (m CreateMLPRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateMLPRequestMultiError) Error 

func (m CreateMLPRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateMLPRequestValidationError 

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

CreateMLPRequestValidationError is the validation error returned by CreateMLPRequest.Validate if the designated constraints aren't met.

func (CreateMLPRequestValidationError) Cause 

func (e CreateMLPRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateMLPRequestValidationError) Error 

func (e CreateMLPRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateMLPRequestValidationError) ErrorName 

func (e CreateMLPRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateMLPRequestValidationError) Field 

func (e CreateMLPRequestValidationError) Field() string

Field function returns field value.

func (CreateMLPRequestValidationError) Key 

func (e CreateMLPRequestValidationError) Key() bool

Key function returns key value.

func (CreateMLPRequestValidationError) Reason 

func (e CreateMLPRequestValidationError) Reason() string

Reason function returns reason value.

type CreateModelRequest 

type CreateModelRequest struct {

	// Scheduler hostname.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Scheduler ip.
	Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	// Types that are assignable to Request:
	//
	//	*CreateModelRequest_CreateGnnRequest
	//	*CreateModelRequest_CreateMlpRequest
	Request isCreateModelRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

CreateModelRequest represents request of CreateModel.

func (*CreateModelRequest) Descriptor deprecated 

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

Deprecated: Use CreateModelRequest.ProtoReflect.Descriptor instead.

func (*CreateModelRequest) GetCreateGnnRequest 

func (x *CreateModelRequest) GetCreateGnnRequest() *CreateGNNRequest

func (*CreateModelRequest) GetCreateMlpRequest 

func (x *CreateModelRequest) GetCreateMlpRequest() *CreateMLPRequest

func (*CreateModelRequest) GetHostname 

func (x *CreateModelRequest) GetHostname() string

func (*CreateModelRequest) GetIp 

func (x *CreateModelRequest) GetIp() string

func (*CreateModelRequest) GetRequest 

func (m *CreateModelRequest) GetRequest() isCreateModelRequest_Request

func (*CreateModelRequest) ProtoMessage 

func (*CreateModelRequest) ProtoMessage()

func (*CreateModelRequest) ProtoReflect 

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

func (*CreateModelRequest) Reset 

func (x *CreateModelRequest) Reset()

func (*CreateModelRequest) String 

func (x *CreateModelRequest) String() string

func (*CreateModelRequest) Validate 

func (m *CreateModelRequest) Validate() error

Validate checks the field values on CreateModelRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateModelRequest) ValidateAll 

func (m *CreateModelRequest) ValidateAll() error

ValidateAll checks the field values on CreateModelRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateModelRequestMultiError, or nil if none found.

type CreateModelRequestMultiError 

type CreateModelRequestMultiError []error

CreateModelRequestMultiError is an error wrapping multiple validation errors returned by CreateModelRequest.ValidateAll() if the designated constraints aren't met.

func (CreateModelRequestMultiError) AllErrors 

func (m CreateModelRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateModelRequestMultiError) Error 

func (m CreateModelRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateModelRequestValidationError 

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

CreateModelRequestValidationError is the validation error returned by CreateModelRequest.Validate if the designated constraints aren't met.

func (CreateModelRequestValidationError) Cause 

func (e CreateModelRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateModelRequestValidationError) Error 

func (e CreateModelRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateModelRequestValidationError) ErrorName 

func (e CreateModelRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateModelRequestValidationError) Field 

func (e CreateModelRequestValidationError) Field() string

Field function returns field value.

func (CreateModelRequestValidationError) Key 

func (e CreateModelRequestValidationError) Key() bool

Key function returns key value.

func (CreateModelRequestValidationError) Reason 

func (e CreateModelRequestValidationError) Reason() string

Reason function returns reason value.

type CreateModelRequest_CreateGnnRequest 

type CreateModelRequest_CreateGnnRequest struct {
	CreateGnnRequest *CreateGNNRequest `protobuf:"bytes,3,opt,name=create_gnn_request,json=createGnnRequest,proto3,oneof"`
}

type CreateModelRequest_CreateMlpRequest 

type CreateModelRequest_CreateMlpRequest struct {
	CreateMlpRequest *CreateMLPRequest `protobuf:"bytes,4,opt,name=create_mlp_request,json=createMlpRequest,proto3,oneof"`
}

type GetObjectStorageRequest 

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=hostname,proto3" json:"hostname,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 

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

Deprecated: Use GetObjectStorageRequest.ProtoReflect.Descriptor instead.

func (*GetObjectStorageRequest) GetHostname 

func (x *GetObjectStorageRequest) GetHostname() string

func (*GetObjectStorageRequest) GetIp 

func (x *GetObjectStorageRequest) GetIp() string

func (*GetObjectStorageRequest) GetSourceType 

func (x *GetObjectStorageRequest) GetSourceType() SourceType

func (*GetObjectStorageRequest) ProtoMessage 

func (*GetObjectStorageRequest) ProtoMessage()

func (*GetObjectStorageRequest) ProtoReflect 

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

func (*GetObjectStorageRequest) Reset 

func (x *GetObjectStorageRequest) Reset()

func (*GetObjectStorageRequest) String 

func (x *GetObjectStorageRequest) String() string

func (*GetObjectStorageRequest) Validate 

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, the first error encountered is returned, or nil if there are no violations.

func (*GetObjectStorageRequest) ValidateAll 

func (m *GetObjectStorageRequest) ValidateAll() error

ValidateAll checks the field values on GetObjectStorageRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetObjectStorageRequestMultiError, or nil if none found.

type GetObjectStorageRequestMultiError 

type GetObjectStorageRequestMultiError []error

GetObjectStorageRequestMultiError is an error wrapping multiple validation errors returned by GetObjectStorageRequest.ValidateAll() if the designated constraints aren't met.

func (GetObjectStorageRequestMultiError) AllErrors 

func (m GetObjectStorageRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetObjectStorageRequestMultiError) Error 

func (m GetObjectStorageRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetObjectStorageRequestValidationError 

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 

func (e GetObjectStorageRequestValidationError) Cause() error

Cause function returns cause value.

func (GetObjectStorageRequestValidationError) Error 

func (e GetObjectStorageRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetObjectStorageRequestValidationError) ErrorName 

func (e GetObjectStorageRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetObjectStorageRequestValidationError) Field 

func (e GetObjectStorageRequestValidationError) Field() string

Field function returns field value.

func (GetObjectStorageRequestValidationError) Key 

func (e GetObjectStorageRequestValidationError) Key() bool

Key function returns key value.

func (GetObjectStorageRequestValidationError) Reason 

func (e GetObjectStorageRequestValidationError) Reason() string

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=hostname,proto3" json:"hostname,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"`
	// Scheduler ip.
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,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) GetIp 

func (x *GetSchedulerRequest) GetIp() 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, the first error encountered is returned, or nil if there are no violations.

func (*GetSchedulerRequest) ValidateAll 

func (m *GetSchedulerRequest) ValidateAll() error

ValidateAll checks the field values on GetSchedulerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetSchedulerRequestMultiError, or nil if none found.

type GetSchedulerRequestMultiError 

type GetSchedulerRequestMultiError []error

GetSchedulerRequestMultiError is an error wrapping multiple validation errors returned by GetSchedulerRequest.ValidateAll() if the designated constraints aren't met.

func (GetSchedulerRequestMultiError) AllErrors 

func (m GetSchedulerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetSchedulerRequestMultiError) Error 

func (m GetSchedulerRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

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 GetSeedPeerRequest 

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 hostname.
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,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"`
	// Seed peer ip.
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

GetSeedPeerRequest represents request of GetSeedPeer.

func (*GetSeedPeerRequest) Descriptor deprecated 

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

Deprecated: Use GetSeedPeerRequest.ProtoReflect.Descriptor instead.

func (*GetSeedPeerRequest) GetHostname 

func (x *GetSeedPeerRequest) GetHostname() string

func (*GetSeedPeerRequest) GetIp 

func (x *GetSeedPeerRequest) GetIp() string

func (*GetSeedPeerRequest) GetSeedPeerClusterId 

func (x *GetSeedPeerRequest) GetSeedPeerClusterId() uint64

func (*GetSeedPeerRequest) GetSourceType 

func (x *GetSeedPeerRequest) GetSourceType() SourceType

func (*GetSeedPeerRequest) ProtoMessage 

func (*GetSeedPeerRequest) ProtoMessage()

func (*GetSeedPeerRequest) ProtoReflect 

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

func (*GetSeedPeerRequest) Reset 

func (x *GetSeedPeerRequest) Reset()

func (*GetSeedPeerRequest) String 

func (x *GetSeedPeerRequest) String() string

func (*GetSeedPeerRequest) Validate 

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, the first error encountered is returned, or nil if there are no violations.

func (*GetSeedPeerRequest) ValidateAll 

func (m *GetSeedPeerRequest) ValidateAll() error

ValidateAll checks the field values on GetSeedPeerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetSeedPeerRequestMultiError, or nil if none found.

type GetSeedPeerRequestMultiError 

type GetSeedPeerRequestMultiError []error

GetSeedPeerRequestMultiError is an error wrapping multiple validation errors returned by GetSeedPeerRequest.ValidateAll() if the designated constraints aren't met.

func (GetSeedPeerRequestMultiError) AllErrors 

func (m GetSeedPeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetSeedPeerRequestMultiError) Error 

func (m GetSeedPeerRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetSeedPeerRequestValidationError 

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 

func (e GetSeedPeerRequestValidationError) Cause() error

Cause function returns cause value.

func (GetSeedPeerRequestValidationError) Error 

func (e GetSeedPeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetSeedPeerRequestValidationError) ErrorName 

func (e GetSeedPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetSeedPeerRequestValidationError) Field 

func (e GetSeedPeerRequestValidationError) Field() string

Field function returns field value.

func (GetSeedPeerRequestValidationError) Key 

func (e GetSeedPeerRequestValidationError) Key() bool

Key function returns key value.

func (GetSeedPeerRequestValidationError) Reason 

func (e GetSeedPeerRequestValidationError) Reason() string

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=hostname,proto3" json:"hostname,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"`
	// Source service ip.
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,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) GetIp 

func (x *KeepAliveRequest) GetIp() 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, the first error encountered is returned, or nil if there are no violations.

func (*KeepAliveRequest) ValidateAll 

func (m *KeepAliveRequest) ValidateAll() error

ValidateAll checks the field values on KeepAliveRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in KeepAliveRequestMultiError, or nil if none found.

type KeepAliveRequestMultiError 

type KeepAliveRequestMultiError []error

KeepAliveRequestMultiError is an error wrapping multiple validation errors returned by KeepAliveRequest.ValidateAll() if the designated constraints aren't met.

func (KeepAliveRequestMultiError) AllErrors 

func (m KeepAliveRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KeepAliveRequestMultiError) Error 

func (m KeepAliveRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

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 ListApplicationsRequest 

type ListApplicationsRequest 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=hostname,proto3" json:"hostname,omitempty"`
	// Source service ip.
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

ListApplicationsRequest represents request of ListApplications.

func (*ListApplicationsRequest) Descriptor deprecated 

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

Deprecated: Use ListApplicationsRequest.ProtoReflect.Descriptor instead.

func (*ListApplicationsRequest) GetHostname 

func (x *ListApplicationsRequest) GetHostname() string

func (*ListApplicationsRequest) GetIp 

func (x *ListApplicationsRequest) GetIp() string

func (*ListApplicationsRequest) GetSourceType 

func (x *ListApplicationsRequest) GetSourceType() SourceType

func (*ListApplicationsRequest) ProtoMessage 

func (*ListApplicationsRequest) ProtoMessage()

func (*ListApplicationsRequest) ProtoReflect 

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

func (*ListApplicationsRequest) Reset 

func (x *ListApplicationsRequest) Reset()

func (*ListApplicationsRequest) String 

func (x *ListApplicationsRequest) String() string

func (*ListApplicationsRequest) Validate 

func (m *ListApplicationsRequest) Validate() error

Validate checks the field values on ListApplicationsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListApplicationsRequest) ValidateAll 

func (m *ListApplicationsRequest) ValidateAll() error

ValidateAll checks the field values on ListApplicationsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListApplicationsRequestMultiError, or nil if none found.

type ListApplicationsRequestMultiError 

type ListApplicationsRequestMultiError []error

ListApplicationsRequestMultiError is an error wrapping multiple validation errors returned by ListApplicationsRequest.ValidateAll() if the designated constraints aren't met.

func (ListApplicationsRequestMultiError) AllErrors 

func (m ListApplicationsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListApplicationsRequestMultiError) Error 

func (m ListApplicationsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListApplicationsRequestValidationError 

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

ListApplicationsRequestValidationError is the validation error returned by ListApplicationsRequest.Validate if the designated constraints aren't met.

func (ListApplicationsRequestValidationError) Cause 

func (e ListApplicationsRequestValidationError) Cause() error

Cause function returns cause value.

func (ListApplicationsRequestValidationError) Error 

func (e ListApplicationsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListApplicationsRequestValidationError) ErrorName 

func (e ListApplicationsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListApplicationsRequestValidationError) Field 

func (e ListApplicationsRequestValidationError) Field() string

Field function returns field value.

func (ListApplicationsRequestValidationError) Key 

func (e ListApplicationsRequestValidationError) Key() bool

Key function returns key value.

func (ListApplicationsRequestValidationError) Reason 

func (e ListApplicationsRequestValidationError) Reason() string

Reason function returns reason value.

type ListApplicationsResponse 

type ListApplicationsResponse struct {

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

ListApplicationsResponse represents response of ListApplications.

func (*ListApplicationsResponse) Descriptor deprecated 

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

Deprecated: Use ListApplicationsResponse.ProtoReflect.Descriptor instead.

func (*ListApplicationsResponse) GetApplications 

func (x *ListApplicationsResponse) GetApplications() []*Application

func (*ListApplicationsResponse) ProtoMessage 

func (*ListApplicationsResponse) ProtoMessage()

func (*ListApplicationsResponse) ProtoReflect 

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

func (*ListApplicationsResponse) Reset 

func (x *ListApplicationsResponse) Reset()

func (*ListApplicationsResponse) String 

func (x *ListApplicationsResponse) String() string

func (*ListApplicationsResponse) Validate 

func (m *ListApplicationsResponse) Validate() error

Validate checks the field values on ListApplicationsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListApplicationsResponse) ValidateAll 

func (m *ListApplicationsResponse) ValidateAll() error

ValidateAll checks the field values on ListApplicationsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListApplicationsResponseMultiError, or nil if none found.

type ListApplicationsResponseMultiError 

type ListApplicationsResponseMultiError []error

ListApplicationsResponseMultiError is an error wrapping multiple validation errors returned by ListApplicationsResponse.ValidateAll() if the designated constraints aren't met.

func (ListApplicationsResponseMultiError) AllErrors 

func (m ListApplicationsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListApplicationsResponseMultiError) Error 

func (m ListApplicationsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListApplicationsResponseValidationError 

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

ListApplicationsResponseValidationError is the validation error returned by ListApplicationsResponse.Validate if the designated constraints aren't met.

func (ListApplicationsResponseValidationError) Cause 

func (e ListApplicationsResponseValidationError) Cause() error

Cause function returns cause value.

func (ListApplicationsResponseValidationError) Error 

func (e ListApplicationsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListApplicationsResponseValidationError) ErrorName 

func (e ListApplicationsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListApplicationsResponseValidationError) Field 

func (e ListApplicationsResponseValidationError) Field() string

Field function returns field value.

func (ListApplicationsResponseValidationError) Key 

func (e ListApplicationsResponseValidationError) Key() bool

Key function returns key value.

func (ListApplicationsResponseValidationError) Reason 

func (e ListApplicationsResponseValidationError) Reason() string

Reason function returns reason value.

type ListBucketsRequest 

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=hostname,proto3" json:"hostname,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 

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

Deprecated: Use ListBucketsRequest.ProtoReflect.Descriptor instead.

func (*ListBucketsRequest) GetHostname 

func (x *ListBucketsRequest) GetHostname() string

func (*ListBucketsRequest) GetIp 

func (x *ListBucketsRequest) GetIp() string

func (*ListBucketsRequest) GetSourceType 

func (x *ListBucketsRequest) GetSourceType() SourceType

func (*ListBucketsRequest) ProtoMessage 

func (*ListBucketsRequest) ProtoMessage()

func (*ListBucketsRequest) ProtoReflect 

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

func (*ListBucketsRequest) Reset 

func (x *ListBucketsRequest) Reset()

func (*ListBucketsRequest) String 

func (x *ListBucketsRequest) String() string

func (*ListBucketsRequest) Validate 

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, the first error encountered is returned, or nil if there are no violations.

func (*ListBucketsRequest) ValidateAll 

func (m *ListBucketsRequest) ValidateAll() error

ValidateAll checks the field values on ListBucketsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListBucketsRequestMultiError, or nil if none found.

type ListBucketsRequestMultiError 

type ListBucketsRequestMultiError []error

ListBucketsRequestMultiError is an error wrapping multiple validation errors returned by ListBucketsRequest.ValidateAll() if the designated constraints aren't met.

func (ListBucketsRequestMultiError) AllErrors 

func (m ListBucketsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListBucketsRequestMultiError) Error 

func (m ListBucketsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListBucketsRequestValidationError 

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 

func (e ListBucketsRequestValidationError) Cause() error

Cause function returns cause value.

func (ListBucketsRequestValidationError) Error 

func (e ListBucketsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListBucketsRequestValidationError) ErrorName 

func (e ListBucketsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListBucketsRequestValidationError) Field 

func (e ListBucketsRequestValidationError) Field() string

Field function returns field value.

func (ListBucketsRequestValidationError) Key 

func (e ListBucketsRequestValidationError) Key() bool

Key function returns key value.

func (ListBucketsRequestValidationError) Reason 

func (e ListBucketsRequestValidationError) Reason() string

Reason function returns reason value.

type ListBucketsResponse 

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 

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

Deprecated: Use ListBucketsResponse.ProtoReflect.Descriptor instead.

func (*ListBucketsResponse) GetBuckets 

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

func (*ListBucketsResponse) ProtoMessage 

func (*ListBucketsResponse) ProtoMessage()

func (*ListBucketsResponse) ProtoReflect 

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

func (*ListBucketsResponse) Reset 

func (x *ListBucketsResponse) Reset()

func (*ListBucketsResponse) String 

func (x *ListBucketsResponse) String() string

func (*ListBucketsResponse) Validate 

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, the first error encountered is returned, or nil if there are no violations.

func (*ListBucketsResponse) ValidateAll 

func (m *ListBucketsResponse) ValidateAll() error

ValidateAll checks the field values on ListBucketsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListBucketsResponseMultiError, or nil if none found.

type ListBucketsResponseMultiError 

type ListBucketsResponseMultiError []error

ListBucketsResponseMultiError is an error wrapping multiple validation errors returned by ListBucketsResponse.ValidateAll() if the designated constraints aren't met.

func (ListBucketsResponseMultiError) AllErrors 

func (m ListBucketsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListBucketsResponseMultiError) Error 

func (m ListBucketsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListBucketsResponseValidationError 

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 

func (e ListBucketsResponseValidationError) Cause() error

Cause function returns cause value.

func (ListBucketsResponseValidationError) Error 

func (e ListBucketsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListBucketsResponseValidationError) ErrorName 

func (e ListBucketsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListBucketsResponseValidationError) Field 

func (e ListBucketsResponseValidationError) Field() string

Field function returns field value.

func (ListBucketsResponseValidationError) Key 

func (e ListBucketsResponseValidationError) Key() bool

Key function returns key value.

func (ListBucketsResponseValidationError) Reason 

func (e ListBucketsResponseValidationError) Reason() string

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=hostname,proto3" json:"hostname,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 */
	// Dfdaemon version.
	Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	// Dfdaemon commit.
	Commit string `protobuf:"bytes,7,opt,name=commit,proto3" json:"commit,omitempty"`
	// 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) GetCommit 

func (x *ListSchedulersRequest) GetCommit() string

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) GetVersion 

func (x *ListSchedulersRequest) GetVersion() string

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, the first error encountered is returned, or nil if there are no violations.

func (*ListSchedulersRequest) ValidateAll 

func (m *ListSchedulersRequest) ValidateAll() error

ValidateAll checks the field values on ListSchedulersRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListSchedulersRequestMultiError, or nil if none found.

type ListSchedulersRequestMultiError 

type ListSchedulersRequestMultiError []error

ListSchedulersRequestMultiError is an error wrapping multiple validation errors returned by ListSchedulersRequest.ValidateAll() if the designated constraints aren't met.

func (ListSchedulersRequestMultiError) AllErrors 

func (m ListSchedulersRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListSchedulersRequestMultiError) Error 

func (m ListSchedulersRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

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 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, the first error encountered is returned, or nil if there are no violations.

func (*ListSchedulersResponse) ValidateAll 

func (m *ListSchedulersResponse) ValidateAll() error

ValidateAll checks the field values on ListSchedulersResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListSchedulersResponseMultiError, or nil if none found.

type ListSchedulersResponseMultiError 

type ListSchedulersResponseMultiError []error

ListSchedulersResponseMultiError is an error wrapping multiple validation errors returned by ListSchedulersResponse.ValidateAll() if the designated constraints aren't met.

func (ListSchedulersResponseMultiError) AllErrors 

func (m ListSchedulersResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListSchedulersResponseMultiError) Error 

func (m ListSchedulersResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

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 ListSeedPeersRequest added in v2.0.43 

type ListSeedPeersRequest 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=hostname,proto3" json:"hostname,omitempty"`
	// Source service ip.
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// Dfdaemon version.
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// Dfdaemon commit.
	Commit string `protobuf:"bytes,5,opt,name=commit,proto3" json:"commit,omitempty"`
	// contains filtered or unexported fields
}

ListSeedPeersRequest represents request of ListSeedPeers.

func (*ListSeedPeersRequest) Descriptor deprecated added in v2.0.43 

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

Deprecated: Use ListSeedPeersRequest.ProtoReflect.Descriptor instead.

func (*ListSeedPeersRequest) GetCommit added in v2.0.43 

func (x *ListSeedPeersRequest) GetCommit() string

func (*ListSeedPeersRequest) GetHostname added in v2.0.43 

func (x *ListSeedPeersRequest) GetHostname() string

func (*ListSeedPeersRequest) GetIp added in v2.0.43 

func (x *ListSeedPeersRequest) GetIp() string

func (*ListSeedPeersRequest) GetSourceType added in v2.0.43 

func (x *ListSeedPeersRequest) GetSourceType() SourceType

func (*ListSeedPeersRequest) GetVersion added in v2.0.43 

func (x *ListSeedPeersRequest) GetVersion() string

func (*ListSeedPeersRequest) ProtoMessage added in v2.0.43 

func (*ListSeedPeersRequest) ProtoMessage()

func (*ListSeedPeersRequest) ProtoReflect added in v2.0.43 

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

func (*ListSeedPeersRequest) Reset added in v2.0.43 

func (x *ListSeedPeersRequest) Reset()

func (*ListSeedPeersRequest) String added in v2.0.43 

func (x *ListSeedPeersRequest) String() string

func (*ListSeedPeersRequest) Validate added in v2.0.43 

func (m *ListSeedPeersRequest) Validate() error

Validate checks the field values on ListSeedPeersRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListSeedPeersRequest) ValidateAll added in v2.0.43 

func (m *ListSeedPeersRequest) ValidateAll() error

ValidateAll checks the field values on ListSeedPeersRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListSeedPeersRequestMultiError, or nil if none found.

type ListSeedPeersRequestMultiError added in v2.0.43 

type ListSeedPeersRequestMultiError []error

ListSeedPeersRequestMultiError is an error wrapping multiple validation errors returned by ListSeedPeersRequest.ValidateAll() if the designated constraints aren't met.

func (ListSeedPeersRequestMultiError) AllErrors added in v2.0.43 

func (m ListSeedPeersRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListSeedPeersRequestMultiError) Error added in v2.0.43 

func (m ListSeedPeersRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListSeedPeersRequestValidationError added in v2.0.43 

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

ListSeedPeersRequestValidationError is the validation error returned by ListSeedPeersRequest.Validate if the designated constraints aren't met.

func (ListSeedPeersRequestValidationError) Cause added in v2.0.43 

func (e ListSeedPeersRequestValidationError) Cause() error

Cause function returns cause value.

func (ListSeedPeersRequestValidationError) Error added in v2.0.43 

func (e ListSeedPeersRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListSeedPeersRequestValidationError) ErrorName added in v2.0.43 

func (e ListSeedPeersRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListSeedPeersRequestValidationError) Field added in v2.0.43 

func (e ListSeedPeersRequestValidationError) Field() string

Field function returns field value.

func (ListSeedPeersRequestValidationError) Key added in v2.0.43 

func (e ListSeedPeersRequestValidationError) Key() bool

Key function returns key value.

func (ListSeedPeersRequestValidationError) Reason added in v2.0.43 

func (e ListSeedPeersRequestValidationError) Reason() string

Reason function returns reason value.

type ListSeedPeersResponse added in v2.0.43 

type ListSeedPeersResponse struct {

	// Seed peers to which the source service belongs.
	SeedPeers []*SeedPeer `protobuf:"bytes,1,rep,name=seed_peers,json=seedPeers,proto3" json:"seed_peers,omitempty"`
	// contains filtered or unexported fields
}

ListSeedPeersResponse represents response of ListSeedPeers.

func (*ListSeedPeersResponse) Descriptor deprecated added in v2.0.43 

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

Deprecated: Use ListSeedPeersResponse.ProtoReflect.Descriptor instead.

func (*ListSeedPeersResponse) GetSeedPeers added in v2.0.43 

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

func (*ListSeedPeersResponse) ProtoMessage added in v2.0.43 

func (*ListSeedPeersResponse) ProtoMessage()

func (*ListSeedPeersResponse) ProtoReflect added in v2.0.43 

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

func (*ListSeedPeersResponse) Reset added in v2.0.43 

func (x *ListSeedPeersResponse) Reset()

func (*ListSeedPeersResponse) String added in v2.0.43 

func (x *ListSeedPeersResponse) String() string

func (*ListSeedPeersResponse) Validate added in v2.0.43 

func (m *ListSeedPeersResponse) Validate() error

Validate checks the field values on ListSeedPeersResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListSeedPeersResponse) ValidateAll added in v2.0.43 

func (m *ListSeedPeersResponse) ValidateAll() error

ValidateAll checks the field values on ListSeedPeersResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListSeedPeersResponseMultiError, or nil if none found.

type ListSeedPeersResponseMultiError added in v2.0.43 

type ListSeedPeersResponseMultiError []error

ListSeedPeersResponseMultiError is an error wrapping multiple validation errors returned by ListSeedPeersResponse.ValidateAll() if the designated constraints aren't met.

func (ListSeedPeersResponseMultiError) AllErrors added in v2.0.43 

func (m ListSeedPeersResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListSeedPeersResponseMultiError) Error added in v2.0.43 

func (m ListSeedPeersResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListSeedPeersResponseValidationError added in v2.0.43 

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

ListSeedPeersResponseValidationError is the validation error returned by ListSeedPeersResponse.Validate if the designated constraints aren't met.

func (ListSeedPeersResponseValidationError) Cause added in v2.0.43 

func (e ListSeedPeersResponseValidationError) Cause() error

Cause function returns cause value.

func (ListSeedPeersResponseValidationError) Error added in v2.0.43 

func (e ListSeedPeersResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListSeedPeersResponseValidationError) ErrorName added in v2.0.43 

func (e ListSeedPeersResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListSeedPeersResponseValidationError) Field added in v2.0.43 

func (e ListSeedPeersResponseValidationError) Field() string

Field function returns field value.

func (ListSeedPeersResponseValidationError) Key added in v2.0.43 

func (e ListSeedPeersResponseValidationError) Key() bool

Key function returns key value.

func (ListSeedPeersResponseValidationError) Reason added in v2.0.43 

func (e ListSeedPeersResponseValidationError) Reason() string

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)
	// List acitve schedulers configuration.
	ListSeedPeers(ctx context.Context, in *ListSeedPeersRequest, opts ...grpc.CallOption) (*ListSeedPeersResponse, 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)
	// List applications configuration.
	ListApplications(ctx context.Context, in *ListApplicationsRequest, opts ...grpc.CallOption) (*ListApplicationsResponse, error)
	// Create model and update data of model to object storage.
	CreateModel(ctx context.Context, in *CreateModelRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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 SeedPeer and SeedPeer cluster configuration.
	GetSeedPeer(context.Context, *GetSeedPeerRequest) (*SeedPeer, error)
	// List acitve schedulers configuration.
	ListSeedPeers(context.Context, *ListSeedPeersRequest) (*ListSeedPeersResponse, 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)
	// List applications configuration.
	ListApplications(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error)
	// Create model and update data of model to object storage.
	CreateModel(context.Context, *CreateModelRequest) (*emptypb.Empty, error)
	// KeepAlive with manager.
	KeepAlive(Manager_KeepAliveServer) error
}

ManagerServer is the server API for Manager service. All implementations should 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 ObjectStorage 

type ObjectStorage struct {

	// name is object storage name of type, it can be s3, oss or obs.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Region is storage region.
	Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	// Endpoint is datacenter endpoint.
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// AccessKey is access key ID.
	AccessKey string `protobuf:"bytes,4,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	// SecretKey is access key secret.
	SecretKey string `protobuf:"bytes,5,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	// S3ForcePathStyle sets force path style for s3, true by default.
	// Set this to `true` to force the request to use path-style addressing,
	// i.e., `http://s3.amazonaws.com/BUCKET/KEY`. By default, the S3 client
	// will use virtual hosted bucket addressing when possible
	// (`http://BUCKET.s3.amazonaws.com/KEY`).
	// Refer to https://github.com/aws/aws-sdk-go/blob/main/aws/config.go#L118.
	S3ForcePathStyle bool `protobuf:"varint,6,opt,name=s3_force_path_style,json=s3ForcePathStyle,proto3" json:"s3_force_path_style,omitempty"`
	// Scheme is the scheme of the http client.
	Scheme string `protobuf:"bytes,7,opt,name=scheme,proto3" json:"scheme,omitempty"`
	// contains filtered or unexported fields
}

ObjectStorage represents config of object storage.

func (*ObjectStorage) Descriptor deprecated 

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

Deprecated: Use ObjectStorage.ProtoReflect.Descriptor instead.

func (*ObjectStorage) GetAccessKey 

func (x *ObjectStorage) GetAccessKey() string

func (*ObjectStorage) GetEndpoint 

func (x *ObjectStorage) GetEndpoint() string

func (*ObjectStorage) GetName 

func (x *ObjectStorage) GetName() string

func (*ObjectStorage) GetRegion 

func (x *ObjectStorage) GetRegion() string

func (*ObjectStorage) GetS3ForcePathStyle 

func (x *ObjectStorage) GetS3ForcePathStyle() bool

func (*ObjectStorage) GetScheme added in v2.0.22 

func (x *ObjectStorage) GetScheme() string

func (*ObjectStorage) GetSecretKey 

func (x *ObjectStorage) GetSecretKey() string

func (*ObjectStorage) ProtoMessage 

func (*ObjectStorage) ProtoMessage()

func (*ObjectStorage) ProtoReflect 

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

func (*ObjectStorage) Reset 

func (x *ObjectStorage) Reset()

func (*ObjectStorage) String 

func (x *ObjectStorage) String() string

func (*ObjectStorage) Validate 

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, the first error encountered is returned, or nil if there are no violations.

func (*ObjectStorage) ValidateAll 

func (m *ObjectStorage) ValidateAll() error

ValidateAll checks the field values on ObjectStorage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ObjectStorageMultiError, or nil if none found.

type ObjectStorageMultiError 

type ObjectStorageMultiError []error

ObjectStorageMultiError is an error wrapping multiple validation errors returned by ObjectStorage.ValidateAll() if the designated constraints aren't met.

func (ObjectStorageMultiError) AllErrors 

func (m ObjectStorageMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ObjectStorageMultiError) Error 

func (m ObjectStorageMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ObjectStorageValidationError 

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 

func (e ObjectStorageValidationError) Cause() error

Cause function returns cause value.

func (ObjectStorageValidationError) Error 

func (e ObjectStorageValidationError) Error() string

Error satisfies the builtin error interface

func (ObjectStorageValidationError) ErrorName 

func (e ObjectStorageValidationError) ErrorName() string

ErrorName returns error name.

func (ObjectStorageValidationError) Field 

func (e ObjectStorageValidationError) Field() string

Field function returns field value.

func (ObjectStorageValidationError) Key 

func (e ObjectStorageValidationError) Key() bool

Key function returns key value.

func (ObjectStorageValidationError) Reason 

func (e ObjectStorageValidationError) Reason() string

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=hostname,proto3" json:"hostname,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"`
	// 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"`
	// Feature flags of scheduler.
	Features []byte `protobuf:"bytes,14,opt,name=features,proto3" json:"features,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) GetFeatures 

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

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) 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 

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

func (*Scheduler) GetState 

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, the first error encountered is returned, or nil if there are no violations.

func (*Scheduler) ValidateAll 

func (m *Scheduler) ValidateAll() error

ValidateAll checks the field values on Scheduler with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SchedulerMultiError, or nil if none found.

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"`
	// 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 

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

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, the first error encountered is returned, or nil if there are no violations.

func (*SchedulerCluster) ValidateAll 

func (m *SchedulerCluster) ValidateAll() error

ValidateAll checks the field values on SchedulerCluster with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SchedulerClusterMultiError, or nil if none found.

type SchedulerClusterMultiError 

type SchedulerClusterMultiError []error

SchedulerClusterMultiError is an error wrapping multiple validation errors returned by SchedulerCluster.ValidateAll() if the designated constraints aren't met.

func (SchedulerClusterMultiError) AllErrors 

func (m SchedulerClusterMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SchedulerClusterMultiError) Error 

func (m SchedulerClusterMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

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 SchedulerMultiError 

type SchedulerMultiError []error

SchedulerMultiError is an error wrapping multiple validation errors returned by Scheduler.ValidateAll() if the designated constraints aren't met.

func (SchedulerMultiError) AllErrors 

func (m SchedulerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SchedulerMultiError) Error 

func (m SchedulerMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

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 SeedPeer 

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=hostname,proto3" json:"hostname,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 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 

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

Deprecated: Use SeedPeer.ProtoReflect.Descriptor instead.

func (*SeedPeer) GetDownloadPort 

func (x *SeedPeer) GetDownloadPort() int32

func (*SeedPeer) GetHostname 

func (x *SeedPeer) GetHostname() string

func (*SeedPeer) GetId 

func (x *SeedPeer) GetId() uint64

func (*SeedPeer) GetIdc 

func (x *SeedPeer) GetIdc() string

func (*SeedPeer) GetIp 

func (x *SeedPeer) GetIp() string

func (*SeedPeer) GetLocation 

func (x *SeedPeer) GetLocation() string

func (*SeedPeer) GetObjectStoragePort 

func (x *SeedPeer) GetObjectStoragePort() int32

func (*SeedPeer) GetPort 

func (x *SeedPeer) GetPort() int32

func (*SeedPeer) GetSchedulers 

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

func (*SeedPeer) GetSeedPeerCluster 

func (x *SeedPeer) GetSeedPeerCluster() *SeedPeerCluster

func (*SeedPeer) GetSeedPeerClusterId 

func (x *SeedPeer) GetSeedPeerClusterId() uint64

func (*SeedPeer) GetState 

func (x *SeedPeer) GetState() string

func (*SeedPeer) GetType 

func (x *SeedPeer) GetType() string

func (*SeedPeer) ProtoMessage 

func (*SeedPeer) ProtoMessage()

func (*SeedPeer) ProtoReflect 

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

func (*SeedPeer) Reset 

func (x *SeedPeer) Reset()

func (*SeedPeer) String 

func (x *SeedPeer) String() string

func (*SeedPeer) Validate 

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, the first error encountered is returned, or nil if there are no violations.

func (*SeedPeer) ValidateAll 

func (m *SeedPeer) ValidateAll() error

ValidateAll checks the field values on SeedPeer with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SeedPeerMultiError, or nil if none found.

type SeedPeerCluster 

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"`
	// contains filtered or unexported fields
}

SeedPeerCluster represents cluster of seed peer.

func (*SeedPeerCluster) Descriptor deprecated 

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

Deprecated: Use SeedPeerCluster.ProtoReflect.Descriptor instead.

func (*SeedPeerCluster) GetBio 

func (x *SeedPeerCluster) GetBio() string

func (*SeedPeerCluster) GetConfig 

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

func (*SeedPeerCluster) GetId 

func (x *SeedPeerCluster) GetId() uint64

func (*SeedPeerCluster) GetName 

func (x *SeedPeerCluster) GetName() string

func (*SeedPeerCluster) ProtoMessage 

func (*SeedPeerCluster) ProtoMessage()

func (*SeedPeerCluster) ProtoReflect 

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

func (*SeedPeerCluster) Reset 

func (x *SeedPeerCluster) Reset()

func (*SeedPeerCluster) String 

func (x *SeedPeerCluster) String() string

func (*SeedPeerCluster) Validate 

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, the first error encountered is returned, or nil if there are no violations.

func (*SeedPeerCluster) ValidateAll 

func (m *SeedPeerCluster) ValidateAll() error

ValidateAll checks the field values on SeedPeerCluster with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SeedPeerClusterMultiError, or nil if none found.

type SeedPeerClusterMultiError 

type SeedPeerClusterMultiError []error

SeedPeerClusterMultiError is an error wrapping multiple validation errors returned by SeedPeerCluster.ValidateAll() if the designated constraints aren't met.

func (SeedPeerClusterMultiError) AllErrors 

func (m SeedPeerClusterMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SeedPeerClusterMultiError) Error 

func (m SeedPeerClusterMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SeedPeerClusterValidationError 

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 

func (e SeedPeerClusterValidationError) Cause() error

Cause function returns cause value.

func (SeedPeerClusterValidationError) Error 

func (e SeedPeerClusterValidationError) Error() string

Error satisfies the builtin error interface

func (SeedPeerClusterValidationError) ErrorName 

func (e SeedPeerClusterValidationError) ErrorName() string

ErrorName returns error name.

func (SeedPeerClusterValidationError) Field 

func (e SeedPeerClusterValidationError) Field() string

Field function returns field value.

func (SeedPeerClusterValidationError) Key 

func (e SeedPeerClusterValidationError) Key() bool

Key function returns key value.

func (SeedPeerClusterValidationError) Reason 

func (e SeedPeerClusterValidationError) Reason() string

Reason function returns reason value.

type SeedPeerMultiError 

type SeedPeerMultiError []error

SeedPeerMultiError is an error wrapping multiple validation errors returned by SeedPeer.ValidateAll() if the designated constraints aren't met.

func (SeedPeerMultiError) AllErrors 

func (m SeedPeerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SeedPeerMultiError) Error 

func (m SeedPeerMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SeedPeerValidationError 

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 

func (e SeedPeerValidationError) Cause() error

Cause function returns cause value.

func (SeedPeerValidationError) Error 

func (e SeedPeerValidationError) Error() string

Error satisfies the builtin error interface

func (SeedPeerValidationError) ErrorName 

func (e SeedPeerValidationError) ErrorName() string

ErrorName returns error name.

func (SeedPeerValidationError) Field 

func (e SeedPeerValidationError) Field() string

Field function returns field value.

func (SeedPeerValidationError) Key 

func (e SeedPeerValidationError) Key() bool

Key function returns key value.

func (SeedPeerValidationError) Reason 

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 

func (SourceType) Type() protoreflect.EnumType

type URLPriority 

type URLPriority struct {

	// URL regex.
	Regex string `protobuf:"bytes,1,opt,name=regex,proto3" json:"regex,omitempty"`
	// URL priority value.
	Value v1.Priority `protobuf:"varint,2,opt,name=value,proto3,enum=common.Priority" json:"value,omitempty"`
	// contains filtered or unexported fields
}

URLPriority represents config of url priority.

func (*URLPriority) Descriptor deprecated 

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

Deprecated: Use URLPriority.ProtoReflect.Descriptor instead.

func (*URLPriority) GetRegex 

func (x *URLPriority) GetRegex() string

func (*URLPriority) GetValue 

func (x *URLPriority) GetValue() v1.Priority

func (*URLPriority) ProtoMessage 

func (*URLPriority) ProtoMessage()

func (*URLPriority) ProtoReflect 

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

func (*URLPriority) Reset 

func (x *URLPriority) Reset()

func (*URLPriority) String 

func (x *URLPriority) String() string

func (*URLPriority) Validate 

func (m *URLPriority) Validate() error

Validate checks the field values on URLPriority with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*URLPriority) ValidateAll 

func (m *URLPriority) ValidateAll() error

ValidateAll checks the field values on URLPriority with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in URLPriorityMultiError, or nil if none found.

type URLPriorityMultiError 

type URLPriorityMultiError []error

URLPriorityMultiError is an error wrapping multiple validation errors returned by URLPriority.ValidateAll() if the designated constraints aren't met.

func (URLPriorityMultiError) AllErrors 

func (m URLPriorityMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (URLPriorityMultiError) Error 

func (m URLPriorityMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type URLPriorityValidationError 

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

URLPriorityValidationError is the validation error returned by URLPriority.Validate if the designated constraints aren't met.

func (URLPriorityValidationError) Cause 

func (e URLPriorityValidationError) Cause() error

Cause function returns cause value.

func (URLPriorityValidationError) Error 

func (e URLPriorityValidationError) Error() string

Error satisfies the builtin error interface

func (URLPriorityValidationError) ErrorName 

func (e URLPriorityValidationError) ErrorName() string

ErrorName returns error name.

func (URLPriorityValidationError) Field 

func (e URLPriorityValidationError) Field() string

Field function returns field value.

func (URLPriorityValidationError) Key 

func (e URLPriorityValidationError) Key() bool

Key function returns key value.

func (URLPriorityValidationError) Reason 

func (e URLPriorityValidationError) Reason() string

Reason function returns reason value.

type UnimplementedManagerServer 

type UnimplementedManagerServer struct {
}

UnimplementedManagerServer should be embedded to have forward compatible implementations.

func (UnimplementedManagerServer) CreateModel 

func (UnimplementedManagerServer) CreateModel(context.Context, *CreateModelRequest) (*emptypb.Empty, error)

func (UnimplementedManagerServer) GetObjectStorage 

func (UnimplementedManagerServer) GetObjectStorage(context.Context, *GetObjectStorageRequest) (*ObjectStorage, error)

func (UnimplementedManagerServer) GetScheduler 

func (UnimplementedManagerServer) GetScheduler(context.Context, *GetSchedulerRequest) (*Scheduler, error)

func (UnimplementedManagerServer) GetSeedPeer 

func (UnimplementedManagerServer) GetSeedPeer(context.Context, *GetSeedPeerRequest) (*SeedPeer, error)

func (UnimplementedManagerServer) KeepAlive 

func (UnimplementedManagerServer) KeepAlive(Manager_KeepAliveServer) error

func (UnimplementedManagerServer) ListApplications 

func (UnimplementedManagerServer) ListApplications(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error)

func (UnimplementedManagerServer) ListBuckets 

func (UnimplementedManagerServer) ListBuckets(context.Context, *ListBucketsRequest) (*ListBucketsResponse, error)

func (UnimplementedManagerServer) ListSchedulers 

func (UnimplementedManagerServer) ListSchedulers(context.Context, *ListSchedulersRequest) (*ListSchedulersResponse, error)

func (UnimplementedManagerServer) ListSeedPeers added in v2.0.43 

func (UnimplementedManagerServer) ListSeedPeers(context.Context, *ListSeedPeersRequest) (*ListSeedPeersResponse, error)

func (UnimplementedManagerServer) UpdateScheduler 

func (UnimplementedManagerServer) UpdateScheduler(context.Context, *UpdateSchedulerRequest) (*Scheduler, error)

func (UnimplementedManagerServer) UpdateSeedPeer 

func (UnimplementedManagerServer) UpdateSeedPeer(context.Context, *UpdateSeedPeerRequest) (*SeedPeer, 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 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=hostname,proto3" json:"hostname,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: Remove net_config params.
	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"`
	// 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) 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, the first error encountered is returned, or nil if there are no violations.

func (*UpdateSchedulerRequest) ValidateAll 

func (m *UpdateSchedulerRequest) ValidateAll() error

ValidateAll checks the field values on UpdateSchedulerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UpdateSchedulerRequestMultiError, or nil if none found.

type UpdateSchedulerRequestMultiError 

type UpdateSchedulerRequestMultiError []error

UpdateSchedulerRequestMultiError is an error wrapping multiple validation errors returned by UpdateSchedulerRequest.ValidateAll() if the designated constraints aren't met.

func (UpdateSchedulerRequestMultiError) AllErrors 

func (m UpdateSchedulerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpdateSchedulerRequestMultiError) Error 

func (m UpdateSchedulerRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

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.

type UpdateSeedPeerRequest 

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=hostname,proto3" json:"hostname,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 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 

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

Deprecated: Use UpdateSeedPeerRequest.ProtoReflect.Descriptor instead.

func (*UpdateSeedPeerRequest) GetDownloadPort 

func (x *UpdateSeedPeerRequest) GetDownloadPort() int32

func (*UpdateSeedPeerRequest) GetHostname 

func (x *UpdateSeedPeerRequest) GetHostname() string

func (*UpdateSeedPeerRequest) GetIdc 

func (x *UpdateSeedPeerRequest) GetIdc() string

func (*UpdateSeedPeerRequest) GetIp 

func (x *UpdateSeedPeerRequest) GetIp() string

func (*UpdateSeedPeerRequest) GetLocation 

func (x *UpdateSeedPeerRequest) GetLocation() string

func (*UpdateSeedPeerRequest) GetObjectStoragePort 

func (x *UpdateSeedPeerRequest) GetObjectStoragePort() int32

func (*UpdateSeedPeerRequest) GetPort 

func (x *UpdateSeedPeerRequest) GetPort() int32

func (*UpdateSeedPeerRequest) GetSeedPeerClusterId 

func (x *UpdateSeedPeerRequest) GetSeedPeerClusterId() uint64

func (*UpdateSeedPeerRequest) GetSourceType 

func (x *UpdateSeedPeerRequest) GetSourceType() SourceType

func (*UpdateSeedPeerRequest) GetType 

func (x *UpdateSeedPeerRequest) GetType() string

func (*UpdateSeedPeerRequest) ProtoMessage 

func (*UpdateSeedPeerRequest) ProtoMessage()

func (*UpdateSeedPeerRequest) ProtoReflect 

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

func (*UpdateSeedPeerRequest) Reset 

func (x *UpdateSeedPeerRequest) Reset()

func (*UpdateSeedPeerRequest) String 

func (x *UpdateSeedPeerRequest) String() string

func (*UpdateSeedPeerRequest) Validate 

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, the first error encountered is returned, or nil if there are no violations.

func (*UpdateSeedPeerRequest) ValidateAll 

func (m *UpdateSeedPeerRequest) ValidateAll() error

ValidateAll checks the field values on UpdateSeedPeerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UpdateSeedPeerRequestMultiError, or nil if none found.

type UpdateSeedPeerRequestMultiError 

type UpdateSeedPeerRequestMultiError []error

UpdateSeedPeerRequestMultiError is an error wrapping multiple validation errors returned by UpdateSeedPeerRequest.ValidateAll() if the designated constraints aren't met.

func (UpdateSeedPeerRequestMultiError) AllErrors 

func (m UpdateSeedPeerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpdateSeedPeerRequestMultiError) Error 

func (m UpdateSeedPeerRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type UpdateSeedPeerRequestValidationError 

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 

func (e UpdateSeedPeerRequestValidationError) Cause() error

Cause function returns cause value.

func (UpdateSeedPeerRequestValidationError) Error 

func (e UpdateSeedPeerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UpdateSeedPeerRequestValidationError) ErrorName 

func (e UpdateSeedPeerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UpdateSeedPeerRequestValidationError) Field 

func (e UpdateSeedPeerRequestValidationError) Field() string

Field function returns field value.

func (UpdateSeedPeerRequestValidationError) Key 

func (e UpdateSeedPeerRequestValidationError) Key() bool

Key function returns key value.

func (UpdateSeedPeerRequestValidationError) Reason 

func (e UpdateSeedPeerRequestValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Directories

Path Synopsis
Code generated by MockGen.
 Code generated by MockGen.

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.