util

Documentation

Index

• func BytesToString(bytes []byte) string
• func ConfigureLogging(verbosity int, path *string)
• func CopySSH(host string, username string, key string, reader io.Reader, targetPath string, ...) error
• func ExecSSH(host string, username string, key string, stdin io.Reader, command ...string) (string, error)
• func Fail(message string)
• func FailOnError(err error)
• func Failf(f string, args ...interface{})
• func FromBase64(b64 string) ([]byte, error)
• func GetFileHash(path string) (string, error)
• func GetLock(pointer interface{}) *sync.RWMutex
• func LogStack(log *logging.Logger, message string, skip int)
• func ParseX509CertPool(bytes []byte) (*x509.CertPool, error)
• func ParseX509Certificates(bytes []byte) ([]*x509.Certificate, error)
• func ReaderSize(reader io.Reader) (int64, error)
• func ResetLocks()
• func SanitizeFilename(name string) string
• func SetFlagsFromEnvironment(prefix string)
• func SetupSignalHandler() <-chan struct{}
• func SortedMapStringStringKeys(map_ map[string]string) []string
• func StringToBytes(string_ string) (bytes []byte)
• func Timestamp(asString bool) interface{}
• func ToBase64(bytes []byte) string
• type ForceHTTPSRoundTripper
  • func NewForceHTTPSRoundTripper(roundTripper http.RoundTripper) *ForceHTTPSRoundTripper
  • func (self *ForceHTTPSRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)
• type TarEncoder
  • func NewTarEncoder(reader io.Reader, name string, size int64) *TarEncoder
  • func (self *TarEncoder) Drain()
  • func (self *TarEncoder) Encode() io.Reader

Functions

func BytesToString

func BytesToString(bytes []byte) string

This casting *does not* copy data. Note that casting via "string(bytes)" *does* copy data.

func ConfigureLogging

func ConfigureLogging(verbosity int, path *string)

func CopySSH

func CopySSH(host string, username string, key string, reader io.Reader, targetPath string, permissions *int64) error

func ExecSSH

func ExecSSH(host string, username string, key string, stdin io.Reader, command ...string) (string, error)

func Fail

func Fail(message string)

func FailOnError

func FailOnError(err error)

func Failf

func Failf(f string, args ...interface{})

func FromBase64

func FromBase64(b64 string) ([]byte, error)

func GetFileHash

func GetFileHash(path string) (string, error)

func GetLock

func GetLock(pointer interface{}) *sync.RWMutex

func LogStack

func LogStack(log *logging.Logger, message string, skip int)

func ParseX509CertPool

func ParseX509CertPool(bytes []byte) (*x509.CertPool, error)

func ParseX509Certificates

func ParseX509Certificates(bytes []byte) ([]*x509.Certificate, error)

func ReaderSize

func ReaderSize(reader io.Reader) (int64, error)

func ResetLocks

func ResetLocks()

func SanitizeFilename

func SanitizeFilename(name string) string

func SetFlagsFromEnvironment

func SetFlagsFromEnvironment(prefix string)

func SetupSignalHandler

func SetupSignalHandler() <-chan struct{}

SetupSignalHandler registered for SIGTERM and SIGINT. A stop channel is returned which is closed on one of these signals. If a second signal is caught, the program is terminated with exit code 1.

func SortedMapStringStringKeys

func SortedMapStringStringKeys(map_ map[string]string) []string

func StringToBytes

func StringToBytes(string_ string) (bytes []byte)

func Timestamp

func Timestamp(asString bool) interface{}

func ToBase64

func ToBase64(bytes []byte) string

Types

type ForceHTTPSRoundTripper

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

func NewForceHTTPSRoundTripper

func NewForceHTTPSRoundTripper(roundTripper http.RoundTripper) *ForceHTTPSRoundTripper

func (*ForceHTTPSRoundTripper) RoundTrip

func (self *ForceHTTPSRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)

http.RoundTripper interface

type TarEncoder

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

func NewTarEncoder

func NewTarEncoder(reader io.Reader, name string, size int64) *TarEncoder

func (*TarEncoder) Drain

func (self *TarEncoder) Drain()

func (*TarEncoder) Encode

func (self *TarEncoder) Encode() io.Reader