types

Documentation

Index

• type Container
• type ContainerAct
• type ContainerActionMessage
• type Containers
  • func (cs *Containers) Append(c Container)
  • func (cs *Containers) Find(cID string) Container
  • func (cs *Containers) Len() int
  • func (cs *Containers) List() []Container
  • func (cs *Containers) Set(containers []Container)
  • func (cs *Containers) SetShell(cID, shell string)
• type ExecOptions
• type InitMessage
• type LogOptions
• type MasterTTY
  • func NewMasterTTY(ctx context.Context, t TTY, execID string) (*MasterTTY, error)
  • func (m *MasterTTY) Close() error
  • func (m *MasterTTY) Fork(ctx context.Context, collaborate bool) *SlaveTTY
  • func (m *MasterTTY) Read(p []byte) (n int, err error)
  • func (m *MasterTTY) Write(p []byte) (n int, err error)
• type SlaveTTY
  • func (s *SlaveTTY) Close() error
  • func (s *SlaveTTY) Read(p []byte) (int, error)
  • func (s *SlaveTTY) Write(p []byte) (int, error)
• type TTY

Types

type Container

type Container struct {
	// common
	ID, Name       string
	Image, Command string
	State, Status  string // "running"  "Up 13 minutes"
	IPs            []string
	Shell          string

	// k8s
	PodName, ContainerName string
	Namespace, RunningNode string

	// remote location server address
	// use this to locate the container
	// in the proxy mode
	LocServer string

	// exec commands in arguments
	// permit user to execute any command
	// in that container
	Exec ExecOptions
}

Container instance

type ContainerAct

type ContainerAct int

const (
	EXEC ContainerAct = iota
	LOGS
)

type ContainerActionMessage

type ContainerActionMessage struct {
	Error   string `json:"err"`
	Code    int    `json:"code"`
	Message string `json:"msg"`
}

ContainerActionMessage tells the web browser the action's status

type Containers

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

func (*Containers) Append

func (cs *Containers) Append(c Container)

func (*Containers) Find

func (cs *Containers) Find(cID string) Container

func (*Containers) Len

func (cs *Containers) Len() int

func (*Containers) List

func (cs *Containers) List() []Container

func (*Containers) Set

func (cs *Containers) Set(containers []Container)

func (*Containers) SetShell

func (cs *Containers) SetShell(cID, shell string)

type ExecOptions

type ExecOptions struct {
	User string
	Env  string
	Cmd  string
	// alias as `p`
	Privileged bool
}

type InitMessage

type InitMessage struct {
	Arguments string `json:"Arguments,omitempty"`
	AuthToken string `json:"AuthToken,omitempty"`
}

type LogOptions

type LogOptions struct {
	ID     string
	Follow bool
	Tail   string
}

type MasterTTY

type MasterTTY struct {
	TTY
	// contains filtered or unexported fields
}

func NewMasterTTY

func NewMasterTTY(ctx context.Context, t TTY, execID string) (*MasterTTY, error)

func (*MasterTTY) Close

func (m *MasterTTY) Close() error

func (*MasterTTY) Fork

func (m *MasterTTY) Fork(ctx context.Context, collaborate bool) *SlaveTTY

func (*MasterTTY) Read

func (m *MasterTTY) Read(p []byte) (n int, err error)

func (*MasterTTY) Write

func (m *MasterTTY) Write(p []byte) (n int, err error)

type SlaveTTY

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

func (*SlaveTTY) Close

func (s *SlaveTTY) Close() error

func (*SlaveTTY) Read

func (s *SlaveTTY) Read(p []byte) (int, error)

func (*SlaveTTY) Write

func (s *SlaveTTY) Write(p []byte) (int, error)

type TTY

type TTY interface {
	webtty.Slave
	Exit() error
	// ActiveChan is to notify that the connection is active
	ActiveChan() <-chan struct{}
}

TTY is webtty.Slave with some additional methods.