client

package

v0.9.280 Latest Latest Go to latest Published: Dec 28, 2025 License: AGPL-3.0 Imports: 17 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cedana/cedana

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Client
- func New(address, protocol string) (*Client, error)

Constants ¶

View Source

const (
	DEFAULT_DUMP_TIMEOUT     = 5 * time.Minute
	DEFAULT_FREEZE_TIMEOUT   = 1 * time.Minute
	DEFAULT_UNFREEZE_TIMEOUT = 1 * time.Minute
	DEFAULT_RESTORE_TIMEOUT  = 5 * time.Minute
	DEFAULT_RUN_TIMEOUT      = 1 * time.Minute
	DEFAULT_MANAGE_TIMEOUT   = 1 * time.Minute
	DEFAULT_DB_TIMEOUT       = 20 * time.Second
	DEFAULT_HEALTH_TIMEOUT   = 1 * time.Minute
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Client ¶

type Client struct {
	*grpc.ClientConn
	// contains filtered or unexported fields
}

func New ¶

func New(address, protocol string) (*Client, error)

func (*Client) Attach ¶

func (c *Client) Attach(ctx context.Context, args *daemon.AttachReq, opts ...grpc.CallOption) error

Attach attaches to a managed process/container. Exits the program with the exit code of the process.

func (*Client) AttachIO ¶

func (c *Client) AttachIO(ctx context.Context, args *daemon.AttachReq, opts ...grpc.CallOption) (io.Writer, io.Reader, io.Reader, chan int, chan error, error)

Just like attach but returns the streams instead of attaching to stdin/stdout/stderr

func (*Client) Delete ¶

func (c *Client) Delete(ctx context.Context, args *daemon.DeleteReq, opts ...grpc.CallOption) (*daemon.DeleteResp, error)

func (*Client) DeleteCheckpoint ¶

func (c *Client) DeleteCheckpoint(ctx context.Context, args *daemon.DeleteCheckpointReq, opts ...grpc.CallOption) (*daemon.DeleteCheckpointResp, error)

func (*Client) Dump ¶

func (c *Client) Dump(ctx context.Context, args *daemon.DumpReq, opts ...grpc.CallOption) (*daemon.DumpResp, *profiling.Data, error)

func (*Client) DumpVM ¶ added in v0.9.242

func (c *Client) DumpVM(ctx context.Context, args *daemon.DumpVMReq, opts ...grpc.CallOption) (*daemon.DumpVMResp, *profiling.Data, error)

func (*Client) Freeze ¶ added in v0.9.263

func (c *Client) Freeze(ctx context.Context, args *daemon.DumpReq, opts ...grpc.CallOption) (*daemon.DumpResp, *profiling.Data, error)

func (*Client) Get ¶

func (c *Client) Get(ctx context.Context, args *daemon.GetReq, opts ...grpc.CallOption) (*daemon.GetResp, error)

func (*Client) GetCheckpoint ¶

func (c *Client) GetCheckpoint(ctx context.Context, args *daemon.GetCheckpointReq, opts ...grpc.CallOption) (*daemon.GetCheckpointResp, error)

func (*Client) HealthCheck ¶

func (c *Client) HealthCheck(ctx context.Context, args *daemon.HealthCheckReq, opts ...grpc.CallOption) (*daemon.HealthCheckResp, error)

func (*Client) HealthCheckConnection ¶

func (c *Client) HealthCheckConnection(ctx context.Context, opts ...grpc.CallOption) (bool, error)

func (*Client) Kill ¶

func (c *Client) Kill(ctx context.Context, args *daemon.KillReq, opts ...grpc.CallOption) (*daemon.KillResp, error)

func (*Client) List ¶

func (c *Client) List(ctx context.Context, args *daemon.ListReq, opts ...grpc.CallOption) (*daemon.ListResp, error)

func (*Client) ListCheckpoints ¶

func (c *Client) ListCheckpoints(ctx context.Context, args *daemon.ListCheckpointsReq, opts ...grpc.CallOption) (*daemon.ListCheckpointsResp, error)

func (*Client) Manage ¶

func (c *Client) Manage(ctx context.Context, args *daemon.RunReq, opts ...grpc.CallOption) (*daemon.RunResp, *profiling.Data, error)

func (*Client) Query ¶

func (c *Client) Query(ctx context.Context, args *daemon.QueryReq, opts ...grpc.CallOption) (*daemon.QueryResp, error)

func (*Client) ReloadPlugins ¶

func (c *Client) ReloadPlugins(ctx context.Context, args *daemon.Empty, opts ...grpc.CallOption) (*daemon.Empty, error)

func (*Client) Restore ¶

func (c *Client) Restore(
	ctx context.Context,
	args *daemon.RestoreReq,
	opts ...grpc.CallOption,
) (*daemon.RestoreResp, *profiling.Data, error)

func (*Client) Run ¶

func (c *Client) Run(ctx context.Context, args *daemon.RunReq, opts ...grpc.CallOption) (*daemon.RunResp, *profiling.Data, error)

func (*Client) Unfreeze ¶ added in v0.9.263

func (c *Client) Unfreeze(ctx context.Context, args *daemon.DumpReq, opts ...grpc.CallOption) (*daemon.DumpResp, *profiling.Data, error)

Source Files ¶

View all Source files

client.go

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