Documentation ¶
Index ¶
- type Client
- type EnsembleClient
- func (c *EnsembleClient) Close() error
- func (c *EnsembleClient) Connected() bool
- func (c *EnsembleClient) GetHost() string
- func (c *EnsembleClient) RequestAction(ctx context.Context, in *pb.ActionRequest, opts ...grpc.CallOption) (*pb.Response, error)
- func (c *EnsembleClient) RequestStatus(ctx context.Context, in *pb.StatusRequest, opts ...grpc.CallOption) (*pb.Response, error)
- func (c *EnsembleClient) RequestUpdate(ctx context.Context, in *pb.UpdateRequest, opts ...grpc.CallOption) (*pb.Response, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface { // Ensemble interactions RequestUpdate(ctx context.Context, in *pb.UpdateRequest, opts ...grpc.CallOption) (*pb.Response, error) RequestStatus(ctx context.Context, in *pb.StatusRequest, opts ...grpc.CallOption) (*pb.Response, error) RequestAction(ctx context.Context, in *pb.ActionRequest, opts ...grpc.CallOption) (*pb.Response, error) }
Client interface defines functions required for a valid client
type EnsembleClient ¶
type EnsembleClient struct {
// contains filtered or unexported fields
}
EnsembleClient interacts with client endpoints
func (*EnsembleClient) Close ¶
func (c *EnsembleClient) Close() error
Close closes the created resources (e.g. connection).
func (*EnsembleClient) Connected ¶
func (c *EnsembleClient) Connected() bool
Connected returns true if we are connected and the connection is ready
func (*EnsembleClient) GetHost ¶
func (c *EnsembleClient) GetHost() string
GetHost returns the private hostn name
func (*EnsembleClient) RequestAction ¶
func (c *EnsembleClient) RequestAction( ctx context.Context, in *pb.ActionRequest, opts ...grpc.CallOption, ) (*pb.Response, error)
func (*EnsembleClient) RequestStatus ¶
func (c *EnsembleClient) RequestStatus( ctx context.Context, in *pb.StatusRequest, opts ...grpc.CallOption, ) (*pb.Response, error)
RequestStatus gets the queue and jobs status. This is primarily for scaling/termination
func (*EnsembleClient) RequestUpdate ¶
func (c *EnsembleClient) RequestUpdate( ctx context.Context, in *pb.UpdateRequest, opts ...grpc.CallOption, ) (*pb.Response, error)
UpdateRequest issues a setup or update request
Click to show internal directories.
Click to hide internal directories.