Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type V1 ¶
type V1 interface { // Update Seed peer configuration. UpdateSeedPeer(context.Context, *managerv1.UpdateSeedPeerRequest, ...grpc.CallOption) (*managerv1.SeedPeer, error) // Get Scheduler and Scheduler cluster configuration. GetScheduler(context.Context, *managerv1.GetSchedulerRequest, ...grpc.CallOption) (*managerv1.Scheduler, error) // Update scheduler configuration. UpdateScheduler(context.Context, *managerv1.UpdateSchedulerRequest, ...grpc.CallOption) (*managerv1.Scheduler, error) // List acitve schedulers configuration. ListSchedulers(context.Context, *managerv1.ListSchedulersRequest, ...grpc.CallOption) (*managerv1.ListSchedulersResponse, error) // Get object storage configuration. GetObjectStorage(context.Context, *managerv1.GetObjectStorageRequest, ...grpc.CallOption) (*managerv1.ObjectStorage, error) // List buckets configuration. ListBuckets(context.Context, *managerv1.ListBucketsRequest, ...grpc.CallOption) (*managerv1.ListBucketsResponse, error) // List applications configuration. ListApplications(context.Context, *managerv1.ListApplicationsRequest, ...grpc.CallOption) (*managerv1.ListApplicationsResponse, error) // Create model and update data of model to object storage. CreateModel(context.Context, *managerv1.CreateModelRequest, ...grpc.CallOption) error // KeepAlive with manager. KeepAlive(time.Duration, *managerv1.KeepAliveRequest, <-chan struct{}, ...grpc.CallOption) // Close tears down the ClientConn and all underlying connections. Close() error }
V1 is the interface for v1 version of the grpc client.
func GetV1ByAddr ¶
GetV1ByAddr returns v1 version of the manager client by address.
func GetV1ByNetAddrs ¶
func GetV1ByNetAddrs(ctx context.Context, netAddrs []dfnet.NetAddr, opts ...grpc.DialOption) (V1, error)
GetV1ByNetAddrs returns v1 version of the manager client with net addresses.
type V2 ¶
type V2 interface { // Update Seed peer configuration. UpdateSeedPeer(context.Context, *managerv2.UpdateSeedPeerRequest, ...grpc.CallOption) (*managerv2.SeedPeer, error) // Get Scheduler and Scheduler cluster configuration. GetScheduler(context.Context, *managerv2.GetSchedulerRequest, ...grpc.CallOption) (*managerv2.Scheduler, error) // Update scheduler configuration. UpdateScheduler(context.Context, *managerv2.UpdateSchedulerRequest, ...grpc.CallOption) (*managerv2.Scheduler, error) // List acitve schedulers configuration. ListSchedulers(context.Context, *managerv2.ListSchedulersRequest, ...grpc.CallOption) (*managerv2.ListSchedulersResponse, error) // Get object storage configuration. GetObjectStorage(context.Context, *managerv2.GetObjectStorageRequest, ...grpc.CallOption) (*managerv2.ObjectStorage, error) // List buckets configuration. ListBuckets(context.Context, *managerv2.ListBucketsRequest, ...grpc.CallOption) (*managerv2.ListBucketsResponse, error) // List applications configuration. ListApplications(context.Context, *managerv2.ListApplicationsRequest, ...grpc.CallOption) (*managerv2.ListApplicationsResponse, error) // Create model and update data of model to object storage. CreateModel(context.Context, *managerv2.CreateModelRequest, ...grpc.CallOption) error // KeepAlive with manager. KeepAlive(time.Duration, *managerv2.KeepAliveRequest, <-chan struct{}, ...grpc.CallOption) // Close tears down the ClientConn and all underlying connections. Close() error }
V2 is the interface for v2 version of the grpc client.
func GetV2ByAddr ¶
GetV2ByAddr returns v2 version of the manager client by address.
func GetV2ByNetAddrs ¶
func GetV2ByNetAddrs(ctx context.Context, netAddrs []dfnet.NetAddr, opts ...grpc.DialOption) (V2, error)
GetV2ByNetAddrs returns v2 version of the manager client with net addresses.
Click to show internal directories.
Click to hide internal directories.