manager

Nov 8, 2023

Changes in this version

+ type ListSeedPeersRequest struct

+ Commit string

+ Hostname string

+ Ip string

+ SourceType SourceType

+ Version string

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

+ func (*ListSeedPeersRequest) ProtoMessage()

+ func (m *ListSeedPeersRequest) Validate() error

+ func (m *ListSeedPeersRequest) ValidateAll() error

+ func (x *ListSeedPeersRequest) GetCommit() string

+ func (x *ListSeedPeersRequest) GetHostname() string

+ func (x *ListSeedPeersRequest) GetIp() string

+ func (x *ListSeedPeersRequest) GetSourceType() SourceType

+ func (x *ListSeedPeersRequest) GetVersion() string

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

+ func (x *ListSeedPeersRequest) Reset()

+ func (x *ListSeedPeersRequest) String() string

+ type ListSeedPeersRequestMultiError []error

+ func (m ListSeedPeersRequestMultiError) AllErrors() []error

+ func (m ListSeedPeersRequestMultiError) Error() string

+ type ListSeedPeersRequestValidationError struct

+ func (e ListSeedPeersRequestValidationError) Cause() error

+ func (e ListSeedPeersRequestValidationError) Error() string

+ func (e ListSeedPeersRequestValidationError) ErrorName() string

+ func (e ListSeedPeersRequestValidationError) Field() string

+ func (e ListSeedPeersRequestValidationError) Key() bool

+ func (e ListSeedPeersRequestValidationError) Reason() string

+ type ListSeedPeersResponse struct

+ SeedPeers []*SeedPeer

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

+ func (*ListSeedPeersResponse) ProtoMessage()

+ func (m *ListSeedPeersResponse) Validate() error

+ func (m *ListSeedPeersResponse) ValidateAll() error

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

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

+ func (x *ListSeedPeersResponse) Reset()

+ func (x *ListSeedPeersResponse) String() string

+ type ListSeedPeersResponseMultiError []error

+ func (m ListSeedPeersResponseMultiError) AllErrors() []error

+ func (m ListSeedPeersResponseMultiError) Error() string

+ type ListSeedPeersResponseValidationError struct

+ func (e ListSeedPeersResponseValidationError) Cause() error

+ func (e ListSeedPeersResponseValidationError) Error() string

+ func (e ListSeedPeersResponseValidationError) ErrorName() string

+ func (e ListSeedPeersResponseValidationError) Field() string

+ func (e ListSeedPeersResponseValidationError) Key() bool

+ func (e ListSeedPeersResponseValidationError) Reason() string

type ManagerClient

+ ListSeedPeers func(ctx context.Context, in *ListSeedPeersRequest, opts ...grpc.CallOption) (*ListSeedPeersResponse, error)

type ManagerServer

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

type UnimplementedManagerServer

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

Aug 25, 2023

Changes in this version

type ListSchedulersRequest

+ Idc *string

+ Location *string

+ func (x *ListSchedulersRequest) GetIdc() string

+ func (x *ListSchedulersRequest) GetLocation() string

Aug 22, 2023

Changes in this version

type ObjectStorage

+ Scheme string

+ func (x *ObjectStorage) GetScheme() string

Aug 2, 2023

Changes in this version

type DeleteSeedPeerRequest

+ SeedPeerClusterId uint64

+ func (x *DeleteSeedPeerRequest) GetSeedPeerClusterId() uint64

Aug 2, 2023

Changes in this version

+ type DeleteSeedPeerRequest struct

+ ClusterId uint64

+ Hostname string

+ Ip string

+ SourceType SourceType

+ func (*DeleteSeedPeerRequest) Descriptor() ([]byte, []int)

+ func (*DeleteSeedPeerRequest) ProtoMessage()

+ func (m *DeleteSeedPeerRequest) Validate() error

+ func (m *DeleteSeedPeerRequest) ValidateAll() error

+ func (x *DeleteSeedPeerRequest) GetClusterId() uint64

+ func (x *DeleteSeedPeerRequest) GetHostname() string

+ func (x *DeleteSeedPeerRequest) GetIp() string

+ func (x *DeleteSeedPeerRequest) GetSourceType() SourceType

+ func (x *DeleteSeedPeerRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteSeedPeerRequest) Reset()

+ func (x *DeleteSeedPeerRequest) String() string

+ type DeleteSeedPeerRequestMultiError []error

+ func (m DeleteSeedPeerRequestMultiError) AllErrors() []error

+ func (m DeleteSeedPeerRequestMultiError) Error() string

+ type DeleteSeedPeerRequestValidationError struct

+ func (e DeleteSeedPeerRequestValidationError) Cause() error

+ func (e DeleteSeedPeerRequestValidationError) Error() string

+ func (e DeleteSeedPeerRequestValidationError) ErrorName() string

+ func (e DeleteSeedPeerRequestValidationError) Field() string

+ func (e DeleteSeedPeerRequestValidationError) Key() bool

+ func (e DeleteSeedPeerRequestValidationError) Reason() string

type ManagerClient

+ DeleteSeedPeer func(ctx context.Context, in *DeleteSeedPeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

type ManagerServer

+ DeleteSeedPeer func(context.Context, *DeleteSeedPeerRequest) (*emptypb.Empty, error)

type UnimplementedManagerServer

+ func (UnimplementedManagerServer) DeleteSeedPeer(context.Context, *DeleteSeedPeerRequest) (*emptypb.Empty, error)

Jul 20, 2023

Changes in this version

type SeedPeer

+ DownloadPort int32

+ func (x *SeedPeer) GetDownloadPort() int32

type UpdateSeedPeerRequest

+ DownloadPort int32

+ func (x *UpdateSeedPeerRequest) GetDownloadPort() int32

Jul 20, 2023

Changes in this version

+ var File_pkg_apis_manager_v2_manager_proto protoreflect.FileDescriptor

+ var Manager_ServiceDesc = grpc.ServiceDesc

+ var SourceType_name = map[int32]string

+ var SourceType_value = map[string]int32

+ func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)

+ type Application struct

+ Bio string

+ Id uint64

+ Name string

+ Priority *ApplicationPriority

+ Url string

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

+ func (*Application) ProtoMessage()

+ func (m *Application) Validate() error

+ func (m *Application) ValidateAll() error

+ func (x *Application) GetBio() string

+ func (x *Application) GetId() uint64

+ func (x *Application) GetName() string

+ func (x *Application) GetPriority() *ApplicationPriority

+ func (x *Application) GetUrl() string

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

+ func (x *Application) Reset()

+ func (x *Application) String() string

+ type ApplicationMultiError []error

+ func (m ApplicationMultiError) AllErrors() []error

+ func (m ApplicationMultiError) Error() string

+ type ApplicationPriority struct

+ Urls []*URLPriority

+ Value v2.Priority

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

+ func (*ApplicationPriority) ProtoMessage()

+ func (m *ApplicationPriority) Validate() error

+ func (m *ApplicationPriority) ValidateAll() error

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

+ func (x *ApplicationPriority) GetValue() v2.Priority

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

+ func (x *ApplicationPriority) Reset()

+ func (x *ApplicationPriority) String() string

+ type ApplicationPriorityMultiError []error

+ func (m ApplicationPriorityMultiError) AllErrors() []error

+ func (m ApplicationPriorityMultiError) Error() string

+ type ApplicationPriorityValidationError struct

+ func (e ApplicationPriorityValidationError) Cause() error

+ func (e ApplicationPriorityValidationError) Error() string

+ func (e ApplicationPriorityValidationError) ErrorName() string

+ func (e ApplicationPriorityValidationError) Field() string

+ func (e ApplicationPriorityValidationError) Key() bool

+ func (e ApplicationPriorityValidationError) Reason() string

+ type ApplicationValidationError struct

+ func (e ApplicationValidationError) Cause() error

+ func (e ApplicationValidationError) Error() string

+ func (e ApplicationValidationError) ErrorName() string

+ func (e ApplicationValidationError) Field() string

+ func (e ApplicationValidationError) Key() bool

+ func (e ApplicationValidationError) Reason() string

+ type Bucket struct

+ Name string

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

+ func (*Bucket) ProtoMessage()

+ func (m *Bucket) Validate() error

+ func (m *Bucket) ValidateAll() error

+ func (x *Bucket) GetName() string

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

+ func (x *Bucket) Reset()

+ func (x *Bucket) String() string

+ type BucketMultiError []error

+ func (m BucketMultiError) AllErrors() []error

+ func (m BucketMultiError) Error() string

+ type BucketValidationError struct

+ func (e BucketValidationError) Cause() error

+ func (e BucketValidationError) Error() string

+ func (e BucketValidationError) ErrorName() string

+ func (e BucketValidationError) Field() string

+ func (e BucketValidationError) Key() bool

+ func (e BucketValidationError) Reason() string

+ type CreateGNNRequest struct

+ Data []byte

+ F1Score float64

+ Precision float64

+ Recall float64

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

+ func (*CreateGNNRequest) ProtoMessage()

+ func (m *CreateGNNRequest) Validate() error

+ func (m *CreateGNNRequest) ValidateAll() error

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

+ func (x *CreateGNNRequest) GetF1Score() float64

+ func (x *CreateGNNRequest) GetPrecision() float64

+ func (x *CreateGNNRequest) GetRecall() float64

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

+ func (x *CreateGNNRequest) Reset()

+ func (x *CreateGNNRequest) String() string

+ type CreateGNNRequestMultiError []error

+ func (m CreateGNNRequestMultiError) AllErrors() []error

+ func (m CreateGNNRequestMultiError) Error() string

+ type CreateGNNRequestValidationError struct

+ func (e CreateGNNRequestValidationError) Cause() error

+ func (e CreateGNNRequestValidationError) Error() string

+ func (e CreateGNNRequestValidationError) ErrorName() string

+ func (e CreateGNNRequestValidationError) Field() string

+ func (e CreateGNNRequestValidationError) Key() bool

+ func (e CreateGNNRequestValidationError) Reason() string

+ type CreateMLPRequest struct

+ Data []byte

+ Mae float64

+ Mse float64

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

+ func (*CreateMLPRequest) ProtoMessage()

+ func (m *CreateMLPRequest) Validate() error

+ func (m *CreateMLPRequest) ValidateAll() error

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

+ func (x *CreateMLPRequest) GetMae() float64

+ func (x *CreateMLPRequest) GetMse() float64

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

+ func (x *CreateMLPRequest) Reset()

+ func (x *CreateMLPRequest) String() string

+ type CreateMLPRequestMultiError []error

+ func (m CreateMLPRequestMultiError) AllErrors() []error

+ func (m CreateMLPRequestMultiError) Error() string

+ type CreateMLPRequestValidationError struct

+ func (e CreateMLPRequestValidationError) Cause() error

+ func (e CreateMLPRequestValidationError) Error() string

+ func (e CreateMLPRequestValidationError) ErrorName() string

+ func (e CreateMLPRequestValidationError) Field() string

+ func (e CreateMLPRequestValidationError) Key() bool

+ func (e CreateMLPRequestValidationError) Reason() string

+ type CreateModelRequest struct

+ Hostname string

+ Ip string

+ Request isCreateModelRequest_Request

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

+ func (*CreateModelRequest) ProtoMessage()

+ func (m *CreateModelRequest) GetRequest() isCreateModelRequest_Request

+ func (m *CreateModelRequest) Validate() error

+ func (m *CreateModelRequest) ValidateAll() error

+ func (x *CreateModelRequest) GetCreateGnnRequest() *CreateGNNRequest

+ func (x *CreateModelRequest) GetCreateMlpRequest() *CreateMLPRequest

+ func (x *CreateModelRequest) GetHostname() string

+ func (x *CreateModelRequest) GetIp() string

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

+ func (x *CreateModelRequest) Reset()

+ func (x *CreateModelRequest) String() string

+ type CreateModelRequestMultiError []error

+ func (m CreateModelRequestMultiError) AllErrors() []error

+ func (m CreateModelRequestMultiError) Error() string

+ type CreateModelRequestValidationError struct

+ func (e CreateModelRequestValidationError) Cause() error

+ func (e CreateModelRequestValidationError) Error() string

+ func (e CreateModelRequestValidationError) ErrorName() string

+ func (e CreateModelRequestValidationError) Field() string

+ func (e CreateModelRequestValidationError) Key() bool

+ func (e CreateModelRequestValidationError) Reason() string

+ type CreateModelRequest_CreateGnnRequest struct

+ CreateGnnRequest *CreateGNNRequest

+ type CreateModelRequest_CreateMlpRequest struct

+ CreateMlpRequest *CreateMLPRequest

+ type GetObjectStorageRequest struct

+ Hostname string

+ Ip string

+ SourceType SourceType

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

+ func (*GetObjectStorageRequest) ProtoMessage()

+ func (m *GetObjectStorageRequest) Validate() error

+ func (m *GetObjectStorageRequest) ValidateAll() error

+ func (x *GetObjectStorageRequest) GetHostname() string

+ func (x *GetObjectStorageRequest) GetIp() string

+ func (x *GetObjectStorageRequest) GetSourceType() SourceType

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

+ func (x *GetObjectStorageRequest) Reset()

+ func (x *GetObjectStorageRequest) String() string

+ type GetObjectStorageRequestMultiError []error

+ func (m GetObjectStorageRequestMultiError) AllErrors() []error

+ func (m GetObjectStorageRequestMultiError) Error() string

+ type GetObjectStorageRequestValidationError struct

+ func (e GetObjectStorageRequestValidationError) Cause() error

+ func (e GetObjectStorageRequestValidationError) Error() string

+ func (e GetObjectStorageRequestValidationError) ErrorName() string

+ func (e GetObjectStorageRequestValidationError) Field() string

+ func (e GetObjectStorageRequestValidationError) Key() bool

+ func (e GetObjectStorageRequestValidationError) Reason() string

+ type GetSchedulerRequest struct

+ Hostname string

+ Ip string

+ SchedulerClusterId uint64

+ SourceType SourceType

+ func (*GetSchedulerRequest) Descriptor() ([]byte, []int)

+ func (*GetSchedulerRequest) ProtoMessage()

+ func (m *GetSchedulerRequest) Validate() error

+ func (m *GetSchedulerRequest) ValidateAll() error

+ func (x *GetSchedulerRequest) GetHostname() string

+ func (x *GetSchedulerRequest) GetIp() string

+ func (x *GetSchedulerRequest) GetSchedulerClusterId() uint64

+ func (x *GetSchedulerRequest) GetSourceType() SourceType

+ func (x *GetSchedulerRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSchedulerRequest) Reset()

+ func (x *GetSchedulerRequest) String() string

+ type GetSchedulerRequestMultiError []error

+ func (m GetSchedulerRequestMultiError) AllErrors() []error

+ func (m GetSchedulerRequestMultiError) Error() string

+ type GetSchedulerRequestValidationError struct

+ func (e GetSchedulerRequestValidationError) Cause() error

+ func (e GetSchedulerRequestValidationError) Error() string

+ func (e GetSchedulerRequestValidationError) ErrorName() string

+ func (e GetSchedulerRequestValidationError) Field() string

+ func (e GetSchedulerRequestValidationError) Key() bool

+ func (e GetSchedulerRequestValidationError) Reason() string

+ type GetSeedPeerRequest struct

+ Hostname string

+ Ip string

+ SeedPeerClusterId uint64

+ SourceType SourceType

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

+ func (*GetSeedPeerRequest) ProtoMessage()

+ func (m *GetSeedPeerRequest) Validate() error

+ func (m *GetSeedPeerRequest) ValidateAll() error

+ func (x *GetSeedPeerRequest) GetHostname() string

+ func (x *GetSeedPeerRequest) GetIp() string

+ func (x *GetSeedPeerRequest) GetSeedPeerClusterId() uint64

+ func (x *GetSeedPeerRequest) GetSourceType() SourceType

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

+ func (x *GetSeedPeerRequest) Reset()

+ func (x *GetSeedPeerRequest) String() string

+ type GetSeedPeerRequestMultiError []error

+ func (m GetSeedPeerRequestMultiError) AllErrors() []error

+ func (m GetSeedPeerRequestMultiError) Error() string

+ type GetSeedPeerRequestValidationError struct

+ func (e GetSeedPeerRequestValidationError) Cause() error

+ func (e GetSeedPeerRequestValidationError) Error() string

+ func (e GetSeedPeerRequestValidationError) ErrorName() string

+ func (e GetSeedPeerRequestValidationError) Field() string

+ func (e GetSeedPeerRequestValidationError) Key() bool

+ func (e GetSeedPeerRequestValidationError) Reason() string

+ type KeepAliveRequest struct

+ ClusterId uint64

+ Hostname string

+ Ip string

+ SourceType SourceType

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

+ func (*KeepAliveRequest) ProtoMessage()

+ func (m *KeepAliveRequest) Validate() error

+ func (m *KeepAliveRequest) ValidateAll() error

+ func (x *KeepAliveRequest) GetClusterId() uint64

+ func (x *KeepAliveRequest) GetHostname() string

+ func (x *KeepAliveRequest) GetIp() string

+ func (x *KeepAliveRequest) GetSourceType() SourceType

+ func (x *KeepAliveRequest) ProtoReflect() protoreflect.Message

+ func (x *KeepAliveRequest) Reset()

+ func (x *KeepAliveRequest) String() string

+ type KeepAliveRequestMultiError []error

+ func (m KeepAliveRequestMultiError) AllErrors() []error

+ func (m KeepAliveRequestMultiError) Error() string

+ type KeepAliveRequestValidationError struct

+ func (e KeepAliveRequestValidationError) Cause() error

+ func (e KeepAliveRequestValidationError) Error() string

+ func (e KeepAliveRequestValidationError) ErrorName() string

+ func (e KeepAliveRequestValidationError) Field() string

+ func (e KeepAliveRequestValidationError) Key() bool

+ func (e KeepAliveRequestValidationError) Reason() string

+ type ListApplicationsRequest struct

+ Hostname string

+ Ip string

+ SourceType SourceType

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

+ func (*ListApplicationsRequest) ProtoMessage()

+ func (m *ListApplicationsRequest) Validate() error

+ func (m *ListApplicationsRequest) ValidateAll() error

+ func (x *ListApplicationsRequest) GetHostname() string

+ func (x *ListApplicationsRequest) GetIp() string

+ func (x *ListApplicationsRequest) GetSourceType() SourceType

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

+ func (x *ListApplicationsRequest) Reset()

+ func (x *ListApplicationsRequest) String() string

+ type ListApplicationsRequestMultiError []error

+ func (m ListApplicationsRequestMultiError) AllErrors() []error

+ func (m ListApplicationsRequestMultiError) Error() string

+ type ListApplicationsRequestValidationError struct

+ func (e ListApplicationsRequestValidationError) Cause() error

+ func (e ListApplicationsRequestValidationError) Error() string

+ func (e ListApplicationsRequestValidationError) ErrorName() string

+ func (e ListApplicationsRequestValidationError) Field() string

+ func (e ListApplicationsRequestValidationError) Key() bool

+ func (e ListApplicationsRequestValidationError) Reason() string

+ type ListApplicationsResponse struct

+ Applications []*Application

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

+ func (*ListApplicationsResponse) ProtoMessage()

+ func (m *ListApplicationsResponse) Validate() error

+ func (m *ListApplicationsResponse) ValidateAll() error

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

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

+ func (x *ListApplicationsResponse) Reset()

+ func (x *ListApplicationsResponse) String() string

+ type ListApplicationsResponseMultiError []error

+ func (m ListApplicationsResponseMultiError) AllErrors() []error

+ func (m ListApplicationsResponseMultiError) Error() string

+ type ListApplicationsResponseValidationError struct

+ func (e ListApplicationsResponseValidationError) Cause() error

+ func (e ListApplicationsResponseValidationError) Error() string

+ func (e ListApplicationsResponseValidationError) ErrorName() string

+ func (e ListApplicationsResponseValidationError) Field() string

+ func (e ListApplicationsResponseValidationError) Key() bool

+ func (e ListApplicationsResponseValidationError) Reason() string

+ type ListBucketsRequest struct

+ Hostname string

+ Ip string

+ SourceType SourceType

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

+ func (*ListBucketsRequest) ProtoMessage()

+ func (m *ListBucketsRequest) Validate() error

+ func (m *ListBucketsRequest) ValidateAll() error

+ func (x *ListBucketsRequest) GetHostname() string

+ func (x *ListBucketsRequest) GetIp() string

+ func (x *ListBucketsRequest) GetSourceType() SourceType

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

+ func (x *ListBucketsRequest) Reset()

+ func (x *ListBucketsRequest) String() string

+ type ListBucketsRequestMultiError []error

+ func (m ListBucketsRequestMultiError) AllErrors() []error

+ func (m ListBucketsRequestMultiError) Error() string

+ type ListBucketsRequestValidationError struct

+ func (e ListBucketsRequestValidationError) Cause() error

+ func (e ListBucketsRequestValidationError) Error() string

+ func (e ListBucketsRequestValidationError) ErrorName() string

+ func (e ListBucketsRequestValidationError) Field() string

+ func (e ListBucketsRequestValidationError) Key() bool

+ func (e ListBucketsRequestValidationError) Reason() string

+ type ListBucketsResponse struct

+ Buckets []*Bucket

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

+ func (*ListBucketsResponse) ProtoMessage()

+ func (m *ListBucketsResponse) Validate() error

+ func (m *ListBucketsResponse) ValidateAll() error

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

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

+ func (x *ListBucketsResponse) Reset()

+ func (x *ListBucketsResponse) String() string

+ type ListBucketsResponseMultiError []error

+ func (m ListBucketsResponseMultiError) AllErrors() []error

+ func (m ListBucketsResponseMultiError) Error() string

+ type ListBucketsResponseValidationError struct

+ func (e ListBucketsResponseValidationError) Cause() error

+ func (e ListBucketsResponseValidationError) Error() string

+ func (e ListBucketsResponseValidationError) ErrorName() string

+ func (e ListBucketsResponseValidationError) Field() string

+ func (e ListBucketsResponseValidationError) Key() bool

+ func (e ListBucketsResponseValidationError) Reason() string

+ type ListSchedulersRequest struct

+ Commit string

+ HostInfo map[string]string

+ Hostname string

+ Ip string

+ SourceType SourceType

+ Version string

+ func (*ListSchedulersRequest) Descriptor() ([]byte, []int)

+ func (*ListSchedulersRequest) ProtoMessage()

+ func (m *ListSchedulersRequest) Validate() error

+ func (m *ListSchedulersRequest) ValidateAll() error

+ func (x *ListSchedulersRequest) GetCommit() string

+ func (x *ListSchedulersRequest) GetHostInfo() map[string]string

+ func (x *ListSchedulersRequest) GetHostname() string

+ func (x *ListSchedulersRequest) GetIp() string

+ func (x *ListSchedulersRequest) GetSourceType() SourceType

+ func (x *ListSchedulersRequest) GetVersion() string

+ func (x *ListSchedulersRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSchedulersRequest) Reset()

+ func (x *ListSchedulersRequest) String() string

+ type ListSchedulersRequestMultiError []error

+ func (m ListSchedulersRequestMultiError) AllErrors() []error

+ func (m ListSchedulersRequestMultiError) Error() string

+ type ListSchedulersRequestValidationError struct

+ func (e ListSchedulersRequestValidationError) Cause() error

+ func (e ListSchedulersRequestValidationError) Error() string

+ func (e ListSchedulersRequestValidationError) ErrorName() string

+ func (e ListSchedulersRequestValidationError) Field() string

+ func (e ListSchedulersRequestValidationError) Key() bool

+ func (e ListSchedulersRequestValidationError) Reason() string

+ type ListSchedulersResponse struct

+ Schedulers []*Scheduler

+ func (*ListSchedulersResponse) Descriptor() ([]byte, []int)

+ func (*ListSchedulersResponse) ProtoMessage()

+ func (m *ListSchedulersResponse) Validate() error

+ func (m *ListSchedulersResponse) ValidateAll() error

+ func (x *ListSchedulersResponse) GetSchedulers() []*Scheduler

+ func (x *ListSchedulersResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSchedulersResponse) Reset()

+ func (x *ListSchedulersResponse) String() string

+ type ListSchedulersResponseMultiError []error

+ func (m ListSchedulersResponseMultiError) AllErrors() []error

+ func (m ListSchedulersResponseMultiError) Error() string

+ type ListSchedulersResponseValidationError struct

+ func (e ListSchedulersResponseValidationError) Cause() error

+ func (e ListSchedulersResponseValidationError) Error() string

+ func (e ListSchedulersResponseValidationError) ErrorName() string

+ func (e ListSchedulersResponseValidationError) Field() string

+ func (e ListSchedulersResponseValidationError) Key() bool

+ func (e ListSchedulersResponseValidationError) Reason() string

+ type ManagerClient interface

+ CreateModel func(ctx context.Context, in *CreateModelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetObjectStorage func(ctx context.Context, in *GetObjectStorageRequest, opts ...grpc.CallOption) (*ObjectStorage, error)

+ GetScheduler func(ctx context.Context, in *GetSchedulerRequest, opts ...grpc.CallOption) (*Scheduler, error)

+ GetSeedPeer func(ctx context.Context, in *GetSeedPeerRequest, opts ...grpc.CallOption) (*SeedPeer, error)

+ KeepAlive func(ctx context.Context, opts ...grpc.CallOption) (Manager_KeepAliveClient, error)

+ ListApplications func(ctx context.Context, in *ListApplicationsRequest, opts ...grpc.CallOption) (*ListApplicationsResponse, error)

+ ListBuckets func(ctx context.Context, in *ListBucketsRequest, opts ...grpc.CallOption) (*ListBucketsResponse, error)

+ ListSchedulers func(ctx context.Context, in *ListSchedulersRequest, opts ...grpc.CallOption) (*ListSchedulersResponse, error)

+ UpdateScheduler func(ctx context.Context, in *UpdateSchedulerRequest, opts ...grpc.CallOption) (*Scheduler, error)

+ UpdateSeedPeer func(ctx context.Context, in *UpdateSeedPeerRequest, opts ...grpc.CallOption) (*SeedPeer, error)

+ func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient

+ type ManagerServer interface

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

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

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

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

+ KeepAlive func(Manager_KeepAliveServer) error

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

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

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

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

+ UpdateSeedPeer func(context.Context, *UpdateSeedPeerRequest) (*SeedPeer, error)

+ type Manager_KeepAliveClient interface

+ CloseAndRecv func() (*emptypb.Empty, error)

+ Send func(*KeepAliveRequest) error

+ type Manager_KeepAliveServer interface

+ Recv func() (*KeepAliveRequest, error)

+ SendAndClose func(*emptypb.Empty) error

+ type ObjectStorage struct

+ AccessKey string

+ Endpoint string

+ Name string

+ Region string

+ S3ForcePathStyle bool

+ SecretKey string

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

+ func (*ObjectStorage) ProtoMessage()

+ func (m *ObjectStorage) Validate() error

+ func (m *ObjectStorage) ValidateAll() error

+ func (x *ObjectStorage) GetAccessKey() string

+ func (x *ObjectStorage) GetEndpoint() string

+ func (x *ObjectStorage) GetName() string

+ func (x *ObjectStorage) GetRegion() string

+ func (x *ObjectStorage) GetS3ForcePathStyle() bool

+ func (x *ObjectStorage) GetSecretKey() string

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

+ func (x *ObjectStorage) Reset()

+ func (x *ObjectStorage) String() string

+ type ObjectStorageMultiError []error

+ func (m ObjectStorageMultiError) AllErrors() []error

+ func (m ObjectStorageMultiError) Error() string

+ type ObjectStorageValidationError struct

+ func (e ObjectStorageValidationError) Cause() error

+ func (e ObjectStorageValidationError) Error() string

+ func (e ObjectStorageValidationError) ErrorName() string

+ func (e ObjectStorageValidationError) Field() string

+ func (e ObjectStorageValidationError) Key() bool

+ func (e ObjectStorageValidationError) Reason() string

+ type Scheduler struct

+ Features []byte

+ Hostname string

+ Id uint64

+ Idc string

+ Ip string

+ Location string

+ Port int32

+ SchedulerCluster *SchedulerCluster

+ SchedulerClusterId uint64

+ SeedPeers []*SeedPeer

+ State string

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

+ func (*Scheduler) ProtoMessage()

+ func (m *Scheduler) Validate() error

+ func (m *Scheduler) ValidateAll() error

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

+ func (x *Scheduler) GetHostname() string

+ func (x *Scheduler) GetId() uint64

+ func (x *Scheduler) GetIdc() string

+ func (x *Scheduler) GetIp() string

+ func (x *Scheduler) GetLocation() string

+ func (x *Scheduler) GetPort() int32

+ func (x *Scheduler) GetSchedulerCluster() *SchedulerCluster

+ func (x *Scheduler) GetSchedulerClusterId() uint64

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

+ func (x *Scheduler) GetState() string

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

+ func (x *Scheduler) Reset()

+ func (x *Scheduler) String() string

+ type SchedulerCluster struct

+ Bio string

+ ClientConfig []byte

+ Config []byte

+ Id uint64

+ Name string

+ Scopes []byte

+ func (*SchedulerCluster) Descriptor() ([]byte, []int)

+ func (*SchedulerCluster) ProtoMessage()

+ func (m *SchedulerCluster) Validate() error

+ func (m *SchedulerCluster) ValidateAll() error

+ func (x *SchedulerCluster) GetBio() string

+ func (x *SchedulerCluster) GetClientConfig() []byte

+ func (x *SchedulerCluster) GetConfig() []byte

+ func (x *SchedulerCluster) GetId() uint64

+ func (x *SchedulerCluster) GetName() string

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

+ func (x *SchedulerCluster) ProtoReflect() protoreflect.Message

+ func (x *SchedulerCluster) Reset()

+ func (x *SchedulerCluster) String() string

+ type SchedulerClusterMultiError []error

+ func (m SchedulerClusterMultiError) AllErrors() []error

+ func (m SchedulerClusterMultiError) Error() string

+ type SchedulerClusterValidationError struct

+ func (e SchedulerClusterValidationError) Cause() error

+ func (e SchedulerClusterValidationError) Error() string

+ func (e SchedulerClusterValidationError) ErrorName() string

+ func (e SchedulerClusterValidationError) Field() string

+ func (e SchedulerClusterValidationError) Key() bool

+ func (e SchedulerClusterValidationError) Reason() string

+ type SchedulerMultiError []error

+ func (m SchedulerMultiError) AllErrors() []error

+ func (m SchedulerMultiError) Error() string

+ type SchedulerValidationError struct

+ func (e SchedulerValidationError) Cause() error

+ func (e SchedulerValidationError) Error() string

+ func (e SchedulerValidationError) ErrorName() string

+ func (e SchedulerValidationError) Field() string

+ func (e SchedulerValidationError) Key() bool

+ func (e SchedulerValidationError) Reason() string

+ type SeedPeer struct

+ Hostname string

+ Id uint64

+ Idc string

+ Ip string

+ Location string

+ ObjectStoragePort int32

+ Port int32

+ Schedulers []*Scheduler

+ SeedPeerCluster *SeedPeerCluster

+ SeedPeerClusterId uint64

+ State string

+ Type string

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

+ func (*SeedPeer) ProtoMessage()

+ func (m *SeedPeer) Validate() error

+ func (m *SeedPeer) ValidateAll() error

+ func (x *SeedPeer) GetHostname() string

+ func (x *SeedPeer) GetId() uint64

+ func (x *SeedPeer) GetIdc() string

+ func (x *SeedPeer) GetIp() string

+ func (x *SeedPeer) GetLocation() string

+ func (x *SeedPeer) GetObjectStoragePort() int32

+ func (x *SeedPeer) GetPort() int32

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

+ func (x *SeedPeer) GetSeedPeerCluster() *SeedPeerCluster

+ func (x *SeedPeer) GetSeedPeerClusterId() uint64

+ func (x *SeedPeer) GetState() string

+ func (x *SeedPeer) GetType() string

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

+ func (x *SeedPeer) Reset()

+ func (x *SeedPeer) String() string

+ type SeedPeerCluster struct

+ Bio string

+ Config []byte

+ Id uint64

+ Name string

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

+ func (*SeedPeerCluster) ProtoMessage()

+ func (m *SeedPeerCluster) Validate() error

+ func (m *SeedPeerCluster) ValidateAll() error

+ func (x *SeedPeerCluster) GetBio() string

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

+ func (x *SeedPeerCluster) GetId() uint64

+ func (x *SeedPeerCluster) GetName() string

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

+ func (x *SeedPeerCluster) Reset()

+ func (x *SeedPeerCluster) String() string

+ type SeedPeerClusterMultiError []error

+ func (m SeedPeerClusterMultiError) AllErrors() []error

+ func (m SeedPeerClusterMultiError) Error() string

+ type SeedPeerClusterValidationError struct

+ func (e SeedPeerClusterValidationError) Cause() error

+ func (e SeedPeerClusterValidationError) Error() string

+ func (e SeedPeerClusterValidationError) ErrorName() string

+ func (e SeedPeerClusterValidationError) Field() string

+ func (e SeedPeerClusterValidationError) Key() bool

+ func (e SeedPeerClusterValidationError) Reason() string

+ type SeedPeerMultiError []error

+ func (m SeedPeerMultiError) AllErrors() []error

+ func (m SeedPeerMultiError) Error() string

+ type SeedPeerValidationError struct

+ func (e SeedPeerValidationError) Cause() error

+ func (e SeedPeerValidationError) Error() string

+ func (e SeedPeerValidationError) ErrorName() string

+ func (e SeedPeerValidationError) Field() string

+ func (e SeedPeerValidationError) Key() bool

+ func (e SeedPeerValidationError) Reason() string

+ type SourceType int32

+ const SourceType_PEER_SOURCE

+ const SourceType_SCHEDULER_SOURCE

+ const SourceType_SEED_PEER_SOURCE

+ func (SourceType) Descriptor() protoreflect.EnumDescriptor

+ func (SourceType) EnumDescriptor() ([]byte, []int)

+ func (SourceType) Type() protoreflect.EnumType

+ func (x SourceType) Enum() *SourceType

+ func (x SourceType) Number() protoreflect.EnumNumber

+ func (x SourceType) String() string

+ type URLPriority struct

+ Regex string

+ Value v2.Priority

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

+ func (*URLPriority) ProtoMessage()

+ func (m *URLPriority) Validate() error

+ func (m *URLPriority) ValidateAll() error

+ func (x *URLPriority) GetRegex() string

+ func (x *URLPriority) GetValue() v2.Priority

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

+ func (x *URLPriority) Reset()

+ func (x *URLPriority) String() string

+ type URLPriorityMultiError []error

+ func (m URLPriorityMultiError) AllErrors() []error

+ func (m URLPriorityMultiError) Error() string

+ type URLPriorityValidationError struct

+ func (e URLPriorityValidationError) Cause() error

+ func (e URLPriorityValidationError) Error() string

+ func (e URLPriorityValidationError) ErrorName() string

+ func (e URLPriorityValidationError) Field() string

+ func (e URLPriorityValidationError) Key() bool

+ func (e URLPriorityValidationError) Reason() string

+ type UnimplementedManagerServer struct

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

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

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

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

+ func (UnimplementedManagerServer) KeepAlive(Manager_KeepAliveServer) error

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

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

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

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

+ func (UnimplementedManagerServer) UpdateSeedPeer(context.Context, *UpdateSeedPeerRequest) (*SeedPeer, error)

+ type UnsafeManagerServer interface

+ type UpdateSchedulerRequest struct

+ Hostname string

+ Idc string

+ Ip string

+ Location string

+ Port int32

+ SchedulerClusterId uint64

+ SourceType SourceType

+ func (*UpdateSchedulerRequest) Descriptor() ([]byte, []int)

+ func (*UpdateSchedulerRequest) ProtoMessage()

+ func (m *UpdateSchedulerRequest) Validate() error

+ func (m *UpdateSchedulerRequest) ValidateAll() error

+ func (x *UpdateSchedulerRequest) GetHostname() string

+ func (x *UpdateSchedulerRequest) GetIdc() string

+ func (x *UpdateSchedulerRequest) GetIp() string

+ func (x *UpdateSchedulerRequest) GetLocation() string

+ func (x *UpdateSchedulerRequest) GetPort() int32

+ func (x *UpdateSchedulerRequest) GetSchedulerClusterId() uint64

+ func (x *UpdateSchedulerRequest) GetSourceType() SourceType

+ func (x *UpdateSchedulerRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateSchedulerRequest) Reset()

+ func (x *UpdateSchedulerRequest) String() string

+ type UpdateSchedulerRequestMultiError []error

+ func (m UpdateSchedulerRequestMultiError) AllErrors() []error

+ func (m UpdateSchedulerRequestMultiError) Error() string

+ type UpdateSchedulerRequestValidationError struct

+ func (e UpdateSchedulerRequestValidationError) Cause() error

+ func (e UpdateSchedulerRequestValidationError) Error() string

+ func (e UpdateSchedulerRequestValidationError) ErrorName() string

+ func (e UpdateSchedulerRequestValidationError) Field() string

+ func (e UpdateSchedulerRequestValidationError) Key() bool

+ func (e UpdateSchedulerRequestValidationError) Reason() string

+ type UpdateSeedPeerRequest struct

+ Hostname string

+ Idc string

+ Ip string

+ Location string

+ ObjectStoragePort int32

+ Port int32

+ SeedPeerClusterId uint64

+ SourceType SourceType

+ Type string

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

+ func (*UpdateSeedPeerRequest) ProtoMessage()

+ func (m *UpdateSeedPeerRequest) Validate() error

+ func (m *UpdateSeedPeerRequest) ValidateAll() error

+ func (x *UpdateSeedPeerRequest) GetHostname() string

+ func (x *UpdateSeedPeerRequest) GetIdc() string

+ func (x *UpdateSeedPeerRequest) GetIp() string

+ func (x *UpdateSeedPeerRequest) GetLocation() string

+ func (x *UpdateSeedPeerRequest) GetObjectStoragePort() int32

+ func (x *UpdateSeedPeerRequest) GetPort() int32

+ func (x *UpdateSeedPeerRequest) GetSeedPeerClusterId() uint64

+ func (x *UpdateSeedPeerRequest) GetSourceType() SourceType

+ func (x *UpdateSeedPeerRequest) GetType() string

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

+ func (x *UpdateSeedPeerRequest) Reset()

+ func (x *UpdateSeedPeerRequest) String() string

+ type UpdateSeedPeerRequestMultiError []error

+ func (m UpdateSeedPeerRequestMultiError) AllErrors() []error

+ func (m UpdateSeedPeerRequestMultiError) Error() string

+ type UpdateSeedPeerRequestValidationError struct

+ func (e UpdateSeedPeerRequestValidationError) Cause() error

+ func (e UpdateSeedPeerRequestValidationError) Error() string

+ func (e UpdateSeedPeerRequestValidationError) ErrorName() string

+ func (e UpdateSeedPeerRequestValidationError) Field() string

+ func (e UpdateSeedPeerRequestValidationError) Key() bool

+ func (e UpdateSeedPeerRequestValidationError) Reason() string