dockercompose

package
v0.26.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 15, 2022 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const ZeroTime = "0001-01-01T00:00:00Z"

Helper functions for dealing with ContainerState.

Variables

This section is empty.

Functions

func FormatError 

func FormatError(cmd *exec.Cmd, stdout []byte, err error) error

func ToContainerState added in v0.26.0 

func ToContainerState(state *types.ContainerState) *v1alpha1.DockerContainerState

Convert ContainerState into an apiserver-compatible state model.

func ToServiceStatus added in v0.26.0 

func ToServiceStatus(id container.ID, state *types.ContainerState, ports nat.PortMap) v1alpha1.DockerComposeServiceStatus

Convert a full into an apiserver-compatible status model.

Types

type Action 

type Action int
const (

	// CONTAINER actions
	ActionUnknown Action = iota
	ActionAttach
	ActionCommit
	ActionCopy
	ActionCreate
	ActionDestroy
	ActionDie
	ActionExecCreate
	ActionExecDetach
	ActionExecDie
	ActionExecStart
	ActionExport
	ActionHealthStatus
	ActionKill
	ActionOom
	ActionPause
	ActionRename
	ActionResize
	ActionRestart
	ActionStart
	ActionStop
	ActionTop
	ActionUnpause
	ActionUpdate
)

func (Action) MarshalJSON added in v0.4.3 

func (a Action) MarshalJSON() ([]byte, error)

func (Action) String added in v0.4.3 

func (a Action) String() string

func (*Action) UnmarshalJSON 

func (a *Action) UnmarshalJSON(b []byte) error

type Attributes 

type Attributes struct {
	Name  string `json:"name"`
	Image string `json:"image"`
}

type DockerComposeClient 

type DockerComposeClient interface {
	Up(ctx context.Context, spec v1alpha1.DockerComposeServiceSpec, shouldBuild bool, stdout, stderr io.Writer) error
	Down(ctx context.Context, spec v1alpha1.DockerComposeProject, stdout, stderr io.Writer) error
	Rm(ctx context.Context, specs []v1alpha1.DockerComposeServiceSpec, stdout, stderr io.Writer) error
	StreamLogs(ctx context.Context, spec v1alpha1.DockerComposeServiceSpec) io.ReadCloser
	StreamEvents(ctx context.Context, spec v1alpha1.DockerComposeProject) (<-chan string, error)
	Project(ctx context.Context, spec v1alpha1.DockerComposeProject) (*types.Project, error)
	ContainerID(ctx context.Context, spec v1alpha1.DockerComposeServiceSpec) (container.ID, error)
	Version(ctx context.Context) (canonicalVersion string, build string, err error)
}

func NewDockerComposeClient 

func NewDockerComposeClient(env docker.LocalEnv) DockerComposeClient

TODO(dmiller): we might want to make this take a path to the docker-compose config so we don't have to keep passing it in.

type DownCall added in v0.23.5 

type DownCall struct {
	Proj v1alpha1.DockerComposeProject
}

Represents a single call to Down

type Event 

type Event struct {
	Time       string     `json:"time"` // todo: time
	Type       Type       `json:"type"`
	Action     Action     `json:"action"`
	ID         string     `json:"id"` // todo: type?
	Service    string     `json:"service"`
	Attributes Attributes `json:"attributes"`
}

func EventFromJsonStr 

func EventFromJsonStr(j string) (Event, error)

func (Event) IsStartupEvent added in v0.4.2 

func (evt Event) IsStartupEvent() bool

type FakeDCClient 

type FakeDCClient struct {
	RunLogOutput      map[string]<-chan string
	ContainerIdOutput container.ID

	ConfigOutput  string
	VersionOutput string

	DownError error
	RmError   error
	RmOutput  string
	WorkDir   string
	// contains filtered or unexported fields
}

func NewFakeDockerComposeClient 

func NewFakeDockerComposeClient(t *testing.T, ctx context.Context) *FakeDCClient

func (*FakeDCClient) Config 

func (c *FakeDCClient) Config(_ context.Context, _ []string) (string, error)

func (*FakeDCClient) ContainerID added in v0.5.1 

func (c *FakeDCClient) ContainerID(ctx context.Context, spec v1alpha1.DockerComposeServiceSpec) (container.ID, error)

func (*FakeDCClient) Down 

func (c *FakeDCClient) Down(ctx context.Context, proj v1alpha1.DockerComposeProject, stdout, stderr io.Writer) error

func (*FakeDCClient) DownCalls added in v0.23.5 

func (c *FakeDCClient) DownCalls() []DownCall

func (*FakeDCClient) Project added in v0.22.1 

func (c *FakeDCClient) Project(_ context.Context, m v1alpha1.DockerComposeProject) (*types.Project, error)

func (*FakeDCClient) Rm added in v0.23.5 

func (c *FakeDCClient) Rm(ctx context.Context, specs []v1alpha1.DockerComposeServiceSpec, stdout, stderr io.Writer) error

func (*FakeDCClient) RmCalls added in v0.23.5 

func (c *FakeDCClient) RmCalls() []RmCall

func (*FakeDCClient) SendEvent 

func (c *FakeDCClient) SendEvent(evt Event) error

func (*FakeDCClient) StreamEvents 

func (c *FakeDCClient) StreamEvents(ctx context.Context, p v1alpha1.DockerComposeProject) (<-chan string, error)

func (*FakeDCClient) StreamLogs 

func (c *FakeDCClient) StreamLogs(ctx context.Context, spec v1alpha1.DockerComposeServiceSpec) io.ReadCloser

func (*FakeDCClient) Up 

func (c *FakeDCClient) Up(ctx context.Context, spec v1alpha1.DockerComposeServiceSpec,
	shouldBuild bool, stdout, stderr io.Writer) error

func (*FakeDCClient) UpCalls added in v0.6.0 

func (c *FakeDCClient) UpCalls() []UpCall

func (*FakeDCClient) Version added in v0.22.9 

func (c *FakeDCClient) Version(_ context.Context) (string, string, error)

type RmCall added in v0.23.5 

type RmCall struct {
	Specs []v1alpha1.DockerComposeServiceSpec
}

type State 

type State struct {
	ContainerState v1alpha1.DockerContainerState
	ContainerID    container.ID
	Ports          []v1alpha1.DockerPortBinding

	// TODO(nick): It might make since to get rid of StartTime
	// and parse it out of the ContainerState.StartedAt string,
	// though we would have to decide how to treat containers
	// started before Tilt start.
	StartTime time.Time

	LastReadyTime time.Time

	SpanID model.LogSpanID
}

func (State) HasEverBeenReadyOrSucceeded added in v0.14.0 

func (s State) HasEverBeenReadyOrSucceeded() bool

func (State) RuntimeState added in v0.10.5 

func (State) RuntimeState()

func (State) RuntimeStatus added in v0.14.0 

func (s State) RuntimeStatus() v1alpha1.RuntimeStatus

func (State) RuntimeStatusError added in v0.14.0 

func (s State) RuntimeStatusError() error

func (State) WithContainerID added in v0.5.0 

func (s State) WithContainerID(cID container.ID) State

func (State) WithContainerState added in v0.14.0 

func (s State) WithContainerState(state v1alpha1.DockerContainerState) State

func (State) WithLastReadyTime added in v0.10.15 

func (s State) WithLastReadyTime(time time.Time) State

func (State) WithPorts added in v0.22.12 

func (s State) WithPorts(ports []v1alpha1.DockerPortBinding) State

func (State) WithSpanID added in v0.10.25 

func (s State) WithSpanID(spanID model.LogSpanID) State

func (State) WithStartTime added in v0.4.2 

func (s State) WithStartTime(time time.Time) State

type Type 

type Type int

https://docs.docker.com/engine/reference/commandline/events/ 

const (
	// Add 'types' here (and to `stringToType` below) as we support them
	TypeUnknown Type = iota
	TypeContainer
)

func (Type) MarshalJSON added in v0.4.3 

func (t Type) MarshalJSON() ([]byte, error)

func (Type) String added in v0.4.3 

func (t Type) String() string

func (*Type) UnmarshalJSON 

func (t *Type) UnmarshalJSON(b []byte) error

type UpCall added in v0.6.0 

type UpCall struct {
	Spec        v1alpha1.DockerComposeServiceSpec
	ShouldBuild bool
}

Represents a single call to Up

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.