goutils

README

hmac

warden-hmac-signer compatible hmac signer

synchronized

simple java like synchronized(obj){ ... } locking

uuid

generates a uuid from /dev/urandom

execute

executes external process with timeout, stdin, stderr and stdout support

Documentation

Index

• Constants
• Variables
• func GojiRestJsonWrapper(f interface{}) func(c web.C, w http.ResponseWriter, r *http.Request)
• func UUID() string
• func WriterError(w http.ResponseWriter, e error)
• type Bench
  • func (b *Bench) Start()
  • func (b *Bench) Stop() int64
  • func (b *Bench) Sum() int64
• type ConcurrencyLimit
  • func NewConcurrencyLimit(limit int) ConcurrencyLimit
  • func NewConcurrencyLimitCPU() ConcurrencyLimit
  • func NewConcurrencyLimitCPUFactore(f float64) ConcurrencyLimit
  • func NewConcurrencyLimitOne() ConcurrencyLimit
  • func (l *ConcurrencyLimit) Free()
  • func (l *ConcurrencyLimit) Len() int
  • func (l *ConcurrencyLimit) Limit() func()
  • func (l *ConcurrencyLimit) Size() int
  • func (l *ConcurrencyLimit) Use()
• type Hmac
  • func (h *Hmac) SignUrl(url string, secret string, ttl int) string
  • func (h *Hmac) Validate(urlp string, secret string) bool
  • func (h *Hmac) ValidateTime(urlp string, secret string) (bool, int)
• type Processes
  • func (c *Processes) AppendProcTitle(title string)
  • func (c *Processes) Execute(timeout int, stdin []byte, parms ...string) ([]byte, []byte, error)
  • func (c *Processes) SetProcTitle(title string)
• type Synchronized
  • func (s *Synchronized) Call(lock interface{}, call func())
  • func (s *Synchronized) Lock(key interface{})
  • func (s *Synchronized) Unlock(key interface{})

Constants

const (
	ErrorTimeout     = "Execute: Timeout running command"
	ErrorTimeoutKill = "Execute: Could not kill process after timeout"
)

const (
	DATE   = "auth[date]="
	SIG    = "&auth[signature]="
	FORMAT = "Mon, _2 Jan 2006 15:04:05 GMT"
)

Variables

var ErrorRequestBody = errors.New("{\"error\":\"Could not read request body\"}")

var ErrorRequestJsonUnmarshal = errors.New("{\"error\":\"Could not generate struct vom json\"}")

var ErrorRestFunc = errors.New("{\"error\":\"Rest function must be func(struct, web.C) (struct, error)\"}")

Functions

func GojiRestJsonWrapper

func GojiRestJsonWrapper(f interface{}) func(c web.C, w http.ResponseWriter, r *http.Request)

func UUID

func UUID() string

func WriterError

func WriterError(w http.ResponseWriter, e error)

Types

type Bench

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

func (*Bench) Start

func (b *Bench) Start()

func (*Bench) Stop

func (b *Bench) Stop() int64

func (*Bench) Sum

func (b *Bench) Sum() int64

type ConcurrencyLimit

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

func NewConcurrencyLimit

func NewConcurrencyLimit(limit int) ConcurrencyLimit

func NewConcurrencyLimitCPU

func NewConcurrencyLimitCPU() ConcurrencyLimit

func NewConcurrencyLimitCPUFactore

func NewConcurrencyLimitCPUFactore(f float64) ConcurrencyLimit

func NewConcurrencyLimitOne

func NewConcurrencyLimitOne() ConcurrencyLimit

func (*ConcurrencyLimit) Free

func (l *ConcurrencyLimit) Free()

func (*ConcurrencyLimit) Len

func (l *ConcurrencyLimit) Len() int

func (*ConcurrencyLimit) Limit

func (l *ConcurrencyLimit) Limit() func()

usage: defer x.Limit()()

^ ^ double ()

func (*ConcurrencyLimit) Size

func (l *ConcurrencyLimit) Size() int

func (*ConcurrencyLimit) Use

func (l *ConcurrencyLimit) Use()

type Hmac

type Hmac struct {
}

var HMAC Hmac

func (*Hmac) SignUrl

func (h *Hmac) SignUrl(url string, secret string, ttl int) string

func (*Hmac) Validate

func (h *Hmac) Validate(urlp string, secret string) bool

func (*Hmac) ValidateTime

func (h *Hmac) ValidateTime(urlp string, secret string) (bool, int)

type Processes

type Processes struct {
}

var Process Processes

func (*Processes) AppendProcTitle

func (c *Processes) AppendProcTitle(title string)

func (*Processes) Execute

func (c *Processes) Execute(timeout int, stdin []byte, parms ...string) ([]byte, []byte, error)

func (*Processes) SetProcTitle

func (c *Processes) SetProcTitle(title string)

type Synchronized

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

var Sync Synchronized

func (*Synchronized) Call

func (s *Synchronized) Call(lock interface{}, call func())

func (*Synchronized) Lock

func (s *Synchronized) Lock(key interface{})

func (*Synchronized) Unlock

func (s *Synchronized) Unlock(key interface{})