remote

Documentation

Index

• func AddControllerCommands(cmd *cobra.Command, dockerCli command.Cli)
• func NewRemoteBuildxController(ctx context.Context, dockerCli command.Cli, opts control.ControlOptions, ...) (control.BuildxController, error)
• type BuildFunc
• type Client
  • func NewClient(ctx context.Context, addr string) (*Client, error)
  • func (c *Client) Build(ctx context.Context, options pb.BuildOptions, in io.ReadCloser, ...) (string, *client.SolveResponse, error)
  • func (c *Client) Close() (err error)
  • func (c *Client) Disconnect(ctx context.Context, key string) error
  • func (c *Client) DisconnectProcess(ctx context.Context, ref, pid string) error
  • func (c *Client) Inspect(ctx context.Context, ref string) (*pb.InspectResponse, error)
  • func (c *Client) Invoke(ctx context.Context, ref string, pid string, invokeConfig pb.InvokeConfig, ...) error
  • func (c *Client) List(ctx context.Context) (keys []string, retErr error)
  • func (c *Client) ListProcesses(ctx context.Context, ref string) (infos []*pb.ProcessInfo, retErr error)
  • func (c *Client) Version(ctx context.Context) (string, string, string, error)
• type Server
  • func NewServer(buildFunc BuildFunc) *Server
  • func (m *Server) Build(ctx context.Context, req *pb.BuildRequest) (*pb.BuildResponse, error)
  • func (m *Server) Close() error
  • func (m *Server) Disconnect(ctx context.Context, req *pb.DisconnectRequest) (res *pb.DisconnectResponse, err error)
  • func (m *Server) DisconnectProcess(ctx context.Context, req *pb.DisconnectProcessRequest) (res *pb.DisconnectProcessResponse, err error)
  • func (m *Server) Info(ctx context.Context, req *pb.InfoRequest) (res *pb.InfoResponse, err error)
  • func (m *Server) Input(stream pb.Controller_InputServer) (err error)
  • func (m *Server) Inspect(ctx context.Context, req *pb.InspectRequest) (*pb.InspectResponse, error)
  • func (m *Server) Invoke(srv pb.Controller_InvokeServer) error
  • func (m *Server) List(ctx context.Context, req *pb.ListRequest) (res *pb.ListResponse, err error)
  • func (m *Server) ListProcesses(ctx context.Context, req *pb.ListProcessesRequest) (res *pb.ListProcessesResponse, err error)
  • func (m *Server) Status(req *pb.StatusRequest, stream pb.Controller_StatusServer) error

Functions

func AddControllerCommands

func AddControllerCommands(cmd *cobra.Command, dockerCli command.Cli)

func NewRemoteBuildxController

func NewRemoteBuildxController(ctx context.Context, dockerCli command.Cli, opts control.ControlOptions, logger progress.SubLogger) (control.BuildxController, error)

Types

type BuildFunc

type BuildFunc func(ctx context.Context, options *pb.BuildOptions, stdin io.Reader, progress progress.Writer) (resp *client.SolveResponse, res *build.ResultHandle, err error)

type Client

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

func NewClient

func NewClient(ctx context.Context, addr string) (*Client, error)

func (*Client) Build

func (c *Client) Build(ctx context.Context, options pb.BuildOptions, in io.ReadCloser, progress progress.Writer) (string, *client.SolveResponse, error)

func (*Client) Close

func (c *Client) Close() (err error)

func (*Client) Disconnect

func (c *Client) Disconnect(ctx context.Context, key string) error

func (*Client) DisconnectProcess

func (c *Client) DisconnectProcess(ctx context.Context, ref, pid string) error

func (*Client) Inspect

func (c *Client) Inspect(ctx context.Context, ref string) (*pb.InspectResponse, error)

func (*Client) Invoke

func (c *Client) Invoke(ctx context.Context, ref string, pid string, invokeConfig pb.InvokeConfig, in io.ReadCloser, stdout io.WriteCloser, stderr io.WriteCloser) error

func (*Client) List

func (c *Client) List(ctx context.Context) (keys []string, retErr error)

func (*Client) ListProcesses

func (c *Client) ListProcesses(ctx context.Context, ref string) (infos []*pb.ProcessInfo, retErr error)

func (*Client) Version

func (c *Client) Version(ctx context.Context) (string, string, string, error)

type Server

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

func NewServer

func NewServer(buildFunc BuildFunc) *Server

func (*Server) Build

func (m *Server) Build(ctx context.Context, req *pb.BuildRequest) (*pb.BuildResponse, error)

func (*Server) Close

func (m *Server) Close() error

func (*Server) Disconnect

func (m *Server) Disconnect(ctx context.Context, req *pb.DisconnectRequest) (res *pb.DisconnectResponse, err error)

func (*Server) DisconnectProcess

func (m *Server) DisconnectProcess(ctx context.Context, req *pb.DisconnectProcessRequest) (res *pb.DisconnectProcessResponse, err error)

func (*Server) Info

func (m *Server) Info(ctx context.Context, req *pb.InfoRequest) (res *pb.InfoResponse, err error)

func (*Server) Input

func (m *Server) Input(stream pb.Controller_InputServer) (err error)

func (*Server) Inspect

func (m *Server) Inspect(ctx context.Context, req *pb.InspectRequest) (*pb.InspectResponse, error)

func (*Server) Invoke

func (m *Server) Invoke(srv pb.Controller_InvokeServer) error

func (*Server) List

func (m *Server) List(ctx context.Context, req *pb.ListRequest) (res *pb.ListResponse, err error)

func (*Server) ListProcesses

func (m *Server) ListProcesses(ctx context.Context, req *pb.ListProcessesRequest) (res *pb.ListProcessesResponse, err error)

func (*Server) Status

func (m *Server) Status(req *pb.StatusRequest, stream pb.Controller_StatusServer) error