rpc

Documentation

Index

• type ObjAny
  • func Any(ctx *core.Context, node *object.Node) *ObjAny
  • func (obj *ObjAny) Run(req *ReqAnyRun) (*ResAnyRun, error)
• type ObjContext
  • func Context(ctx *core.Context, node *object.Node) *ObjContext
  • func (obj *ObjContext) Pull(req *ReqContextPull) (*ResContextPull, error)
  • func (obj *ObjContext) Push(req *ReqContextPush) (*ResContextPush, error)
• type ObjDocker
  • func Docker(ctx *core.Context, node *object.Node) *ObjDocker
  • func (obj *ObjDocker) Run(req *ReqDockerRun) (*ResDockerRun, error)
• type ObjDockerd
  • func Dockerd(ctx *core.Context, node *object.Node) *ObjDockerd
  • func (obj *ObjDockerd) Start(req *ReqDockerdStart) (*ResDockerdStart, error)
• type ObjServer
  • func Server(ctx *core.Context) *ObjServer
  • func (obj *ObjServer) Serve(req *ReqServerServe) (*ResServerServe, error)
• type ReqAnyRun
• type ReqContextPull
• type ReqContextPush
• type ReqDockerRun
• type ReqDockerdStart
• type ReqServerServe
• type ResAnyRun
• type ResContextPull
• type ResContextPush
• type ResDockerRun
• type ResDockerdStart
• type ResServerServe
• type Rpc
  • func (rpc *Rpc) AnyRun(req *ReqAnyRun, res *ResAnyRun) error
  • func (rpc *Rpc) ContextPull(req *ReqContextPull, res *ResContextPull) error
  • func (rpc *Rpc) ContextPush(req *ReqContextPush, res *ResContextPush) error
  • func (rpc *Rpc) DockerRun(req *ReqDockerRun, res *ResDockerRun) error
  • func (rpc *Rpc) DockerdStart(req *ReqDockerdStart, res *ResDockerdStart) error

Types

type ObjAny

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

func Any

func Any(ctx *core.Context, node *object.Node) *ObjAny

func (*ObjAny) Run

func (obj *ObjAny) Run(req *ReqAnyRun) (*ResAnyRun, error)

type ObjContext

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

func Context

func Context(ctx *core.Context, node *object.Node) *ObjContext

func (*ObjContext) Pull

func (obj *ObjContext) Pull(req *ReqContextPull) (*ResContextPull, error)

func (*ObjContext) Push

func (obj *ObjContext) Push(req *ReqContextPush) (*ResContextPush, error)

type ObjDocker

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

func Docker

func Docker(ctx *core.Context, node *object.Node) *ObjDocker

func (*ObjDocker) Run

func (obj *ObjDocker) Run(req *ReqDockerRun) (*ResDockerRun, error)

type ObjDockerd

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

func Dockerd

func Dockerd(ctx *core.Context, node *object.Node) *ObjDockerd

func (*ObjDockerd) Start

func (obj *ObjDockerd) Start(req *ReqDockerdStart) (*ResDockerdStart, error)

type ObjServer

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

func Server

func Server(ctx *core.Context) *ObjServer

func (*ObjServer) Serve

func (obj *ObjServer) Serve(req *ReqServerServe) (*ResServerServe, error)

type ReqAnyRun

type ReqAnyRun struct {
	Name string
	Args []string
}

type ReqContextPull

type ReqContextPull struct {
}

type ReqContextPush

type ReqContextPush struct {
	Dir         string
	ManagerNode *object.Node
	NodeList    []*object.Node
}

type ReqDockerRun

type ReqDockerRun struct {
	Args []string
}

type ReqDockerdStart

type ReqDockerdStart struct {
}

type ReqServerServe

type ReqServerServe struct {
}

type ResAnyRun

type ResAnyRun struct {
	Stdout string
}

type ResContextPull

type ResContextPull struct {
	Dir         string
	ManagerNode *object.Node
	NodeList    []*object.Node
}

type ResContextPush

type ResContextPush struct {
}

type ResDockerRun

type ResDockerRun struct {
	Stdout string
}

type ResDockerdStart

type ResDockerdStart struct {
}

type ResServerServe

type ResServerServe struct {
}

type Rpc

type Rpc struct {
}

func (*Rpc) AnyRun

func (rpc *Rpc) AnyRun(req *ReqAnyRun, res *ResAnyRun) error

func (*Rpc) ContextPull

func (rpc *Rpc) ContextPull(req *ReqContextPull, res *ResContextPull) error

func (*Rpc) ContextPush

func (rpc *Rpc) ContextPush(req *ReqContextPush, res *ResContextPush) error

func (*Rpc) DockerRun

func (rpc *Rpc) DockerRun(req *ReqDockerRun, res *ResDockerRun) error

func (*Rpc) DockerdStart

func (rpc *Rpc) DockerdStart(req *ReqDockerdStart, res *ResDockerdStart) error