proxy

Documentation

Index

• Constants
• Variables
• func ListenToNewSock(newsock string, sigc chan os.Signal) (l net.Listener, err error)
• func ReadLineFile(reader io.Reader) (patterns []string, err error)
• type Headers
• type Proxy
  • func NewProxy(opts ...ProxyOption) Proxy
  • func (p *Proxy) GetOptions() map[string]interface{}
  • func (p *Proxy) Run()
• type ProxyOption
  • func WithBindMounts(bm []string) ProxyOption
  • func WithDebugEnabled() ProxyOption
  • func WithDebugValue(d bool) ProxyOption
  • func WithDevMappings(dm []string) ProxyOption
  • func WithDockerSocket(s string) ProxyOption
  • func WithGpuValue(b bool) ProxyOption
  • func WithPattern(p string) ProxyOption
  • func WithPatterns(p []string) ProxyOption
  • func WithPinUserValue(pu string) ProxyOption
  • func WithProxySocket(s string) ProxyOption
• type ProxyOptions
• type UnixSocket
  • func NewUnixSocket(path string) UnixSocket
• type UpStream
  • func NewUpstream(socket string, regs []string, binds []string, devs []string, gpu bool, ...) *UpStream
  • func (u *UpStream) ServeHTTP(w http.ResponseWriter, req *http.Request)

Constants

const (
	DOCKER_SOCKET = "/var/run/docker.sock"
	PROXY_SOCKET  = "/tmp/doxy.sock"
	PATTERN_FILE  = "/etc/doxy.pattern"
	DEVICE_FILE   = "/etc/doxy.devices"
)

Variables

var (
	DEF_PAT = []string{
		`^/(v\d\.\d+/)?containers(/\w+)?/(json|stats|top)$`,
		`^/(v\d\.\d+/)?services(/[0-9a-f]+)?$`,
		`^/(v\d\.\d+/)?tasks(/\w+)?$`,
		`^/(v\d\.\d+/)?networks(/\w+)?$`,
		`^/(v\d\.\d+/)?volumes(/\w+)?$`,
		`^/(v\d\.\d+/)?nodes(/\w+)?$`,
		`^/(v\d\.\d+/)?info$`,
		`^/(v\d\.\d+/)?version$`,
		"^/_ping$",
	}
	HPC_PAT = []string{
		`^/(v\d\.\d+/)?containers(/\w+)?/(json|stats|top|create|start|run|kill)$`,
		`^/(v\d\.\d+/)?images(/\w+)?/(json|pull)$`,
		`^/(v\d\.\d+/)?info$`,
		`^/(v\d\.\d+/)?images/(pull|create)$`,
		`^/(v\d\.\d+/)?version$`,
		"^/_ping$",
	}
	DEVICES = []string{
		"/dev/nvidia0:/dev/nvidia0:rwm",
		"/dev/nvidia-uvm:/dev/nvidia-uvm:rwm",
		"/dev/nvidiactl:/dev/nvidiactl:rwm",
	}
	PATTERNS = map[string][]string{
		"default": DEF_PAT,
		"hpc":     HPC_PAT,
	}
)

Functions

func ListenToNewSock

func ListenToNewSock(newsock string, sigc chan os.Signal) (l net.Listener, err error)

func ReadLineFile

func ReadLineFile(reader io.Reader) (patterns []string, err error)

Types

type Headers

type Headers map[string][]string

type Proxy

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

func NewProxy

func NewProxy(opts ...ProxyOption) Proxy

func (*Proxy) GetOptions

func (p *Proxy) GetOptions() map[string]interface{}

func (*Proxy) Run

func (p *Proxy) Run()

type ProxyOption

type ProxyOption func(*ProxyOptions)

func WithBindMounts

func WithBindMounts(bm []string) ProxyOption

func WithDebugEnabled

func WithDebugEnabled() ProxyOption

func WithDebugValue

func WithDebugValue(d bool) ProxyOption

func WithDevMappings

func WithDevMappings(dm []string) ProxyOption

func WithDockerSocket

func WithDockerSocket(s string) ProxyOption

func WithGpuValue

func WithGpuValue(b bool) ProxyOption

func WithPattern

func WithPattern(p string) ProxyOption

func WithPatterns

func WithPatterns(p []string) ProxyOption

func WithPinUserValue

func WithPinUserValue(pu string) ProxyOption

func WithProxySocket

func WithProxySocket(s string) ProxyOption

type ProxyOptions

type ProxyOptions struct {
	DockerSocket string
	ProxySocket  string
	PinUser      string
	Debug, Gpu   bool
	Patterns     []string
	BindMounts   []string
	DevMappings  []string
}

type UnixSocket

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

UnixSocket just provides the path, so that I can test it

func NewUnixSocket

func NewUnixSocket(path string) UnixSocket

NewUnixSocket return a socket using the path

type UpStream

type UpStream struct {
	Name string
	// contains filtered or unexported fields
}

UpStream creates upstream handler struct

func NewUpstream

func NewUpstream(socket string, regs []string, binds []string, devs []string, gpu bool, pinUser string) *UpStream

NewUpstream returns a new socket (magic)

func (*UpStream) ServeHTTP

func (u *UpStream) ServeHTTP(w http.ResponseWriter, req *http.Request)