container

type Builder ¶

type Builder interface {
	Build() (io.Reader, error)
}

type PlatformBuilder ¶

type PlatformBuilder struct {
	DeploymentSpec *pb.ChaincodeDeploymentSpec
}

PlatformBuilder implements the Build interface using the platforms package GenerateDockerBuild function. XXX This is a pretty awkward spot for the builder, it should really probably be pushed into the dockercontroller, as it only builds docker images, but, doing so would require contaminating the dockercontroller package with the CDS, which is also undesirable.

func (b *PlatformBuilder) Build() (io.Reader, error)

type StartContainerReq ¶

type StartContainerReq struct {
	ccintf.CCID
	Builder       Builder
	Args          []string
	Env           []string
	FilesToUpload map[string][]byte
}

StartContainerReq - properties for starting a container.

func (si StartContainerReq) Do(ctxt context.Context, v VM) error

func (si StartContainerReq) GetCCID() ccintf.CCID

type StopContainerReq ¶

type StopContainerReq struct {
	ccintf.CCID
	Timeout uint
	//by default we will kill the container after stopping
	Dontkill bool
	//by default we will remove the container after killing
	Dontremove bool
}

StopContainerReq - properties for stopping a container.

func (si StopContainerReq) Do(ctxt context.Context, v VM) error

func (si StopContainerReq) GetCCID() ccintf.CCID

type VM ¶

type VM interface {
	Start(ctxt context.Context, ccid ccintf.CCID, args []string, env []string, filesToUpload map[string][]byte, builder Builder) error
	Stop(ctxt context.Context, ccid ccintf.CCID, timeout uint, dontkill bool, dontremove bool) error
}

VM is an abstract virtual image for supporting arbitrary virual machines

type VMCReq ¶

type VMCReq interface {
	Do(ctxt context.Context, v VM) error
	GetCCID() ccintf.CCID
}

VMCReq - all requests should implement this interface. The context should be passed and tested at each layer till we stop note that we'd stop on the first method on the stack that does not take context

type VMController ¶

type VMController struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

VMController - manages VMs

. abstract construction of different types of VMs (we only care about Docker for now)
. manage lifecycle of VM (start with build, start, stop ...
  eventually probably need fine grained management)

func NewVMController(vmProviders map[string]VMProvider) *VMController

func (vmc *VMController) Process(ctxt context.Context, vmtype string, req VMCReq) error

type VMProvider ¶

type VMProvider interface {
	NewVM() VM
}