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) Set(containers []Container)
  • func (cs *Containers) SetShell(cID, shell string)
• type InitMessage
• type LogOptions
• type ShareTTY
  • func NewShareTTY(t TTY) *ShareTTY
  • func (t *ShareTTY) Close() error
  • func (t *ShareTTY) Exit() error
  • func (t *ShareTTY) Fork(clientIP string) io.ReadCloser
  • func (t *ShareTTY) Read(p []byte) (n int, err error)
  • func (t *ShareTTY) Write(p []byte) (n int, err 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
	ExecCMD string
}

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) Set

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

func (*Containers) SetShell

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

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 ShareTTY

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

func NewShareTTY

func NewShareTTY(t TTY) *ShareTTY

func (*ShareTTY) Close

func (t *ShareTTY) Close() error

func (*ShareTTY) Exit

func (t *ShareTTY) Exit() error

func (*ShareTTY) Fork

func (t *ShareTTY) Fork(clientIP string) io.ReadCloser

func (*ShareTTY) Read

func (t *ShareTTY) Read(p []byte) (n int, err error)

func (*ShareTTY) Write

func (t *ShareTTY) Write(p []byte) (n int, err 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.