cli

Documentation

Index

• Variables
• func CreateComposer()
• func DisplayGreeting(w http.ResponseWriter, r *http.Request)
• func NewListener(addr string, readTimeout, writeTimeout time.Duration) (net.Listener, error)
• func ParseFlags()
• func PrepareGreeting()
• func Serve()
• func SetupMetrics(handler *tusd.Handler)
• func SetupPostHooks(handler *tusd.Handler)
• func SetupPreHooks(composer *tusd.StoreComposer)
• func ShowVersion()
• type Conn
  • func (c *Conn) Close() error
  • func (c *Conn) Read(b []byte) (int, error)
  • func (c *Conn) Write(b []byte) (int, error)
• type HookType
• type Listener
  • func (l *Listener) Accept() (net.Conn, error)

Variables

var BuildDate = "n/a"

var Composer *tusd.StoreComposer

var Flags struct {
	HttpHost          string
	HttpPort          string
	MaxSize           int64
	UploadDir         string
	StoreSize         int64
	Basepath          string
	Timeout           int64
	S3Bucket          string
	S3Endpoint        string
	GCSBucket         string
	FileHooksDir      string
	HttpHooksEndpoint string
	HttpHooksRetry    int
	HttpHooksBackoff  int
	ShowVersion       bool
	ExposeMetrics     bool
	MetricsPath       string
	BehindProxy       bool

	FileHooksInstalled bool
	HttpHooksInstalled bool
}

var GitCommit = "n/a"

var MetricsOpenConnections = prometheus.NewGauge(prometheus.GaugeOpts{
	Name: "tusd_connections_open",
	Help: "Current number of open connections.",
})

var VersionName = "n/a"

Functions

func CreateComposer

func CreateComposer()

func DisplayGreeting

func DisplayGreeting(w http.ResponseWriter, r *http.Request)

func NewListener

func NewListener(addr string, readTimeout, writeTimeout time.Duration) (net.Listener, error)

func ParseFlags

func ParseFlags()

func PrepareGreeting

func PrepareGreeting()

func Serve

func Serve()

func SetupMetrics

func SetupMetrics(handler *tusd.Handler)

func SetupPostHooks

func SetupPostHooks(handler *tusd.Handler)

func SetupPreHooks

func SetupPreHooks(composer *tusd.StoreComposer)

func ShowVersion

func ShowVersion()

Types

type Conn

type Conn struct {
	net.Conn
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	// contains filtered or unexported fields
}

Conn wraps a net.Conn, and sets a deadline for every read and write operation.

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) Read

func (c *Conn) Read(b []byte) (int, error)

func (*Conn) Write

func (c *Conn) Write(b []byte) (int, error)

type HookType

type HookType string

const (
	HookPostFinish    HookType = "post-finish"
	HookPostTerminate HookType = "post-terminate"
	HookPostReceive   HookType = "post-receive"
	HookPostCreate    HookType = "post-create"
	HookPreCreate     HookType = "pre-create"
)

type Listener

type Listener struct {
	net.Listener
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
}

Listener wraps a net.Listener, and gives a place to store the timeout parameters. On Accept, it will wrap the net.Conn with our own Conn for us. Original implementation taken from https://gist.github.com/jbardin/9663312 Thanks! <3

func (*Listener) Accept

func (l *Listener) Accept() (net.Conn, error)