util

package
v0.1.52 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 2, 2022 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DEFAULT_LOCK = LockType(0)
	SYNC_LOCK    = LockType(1)
	DEBUG_LOCK   = LockType(2)
	MOCK_LOCK    = LockType(3)
)

Variables

This section is empty.

Functions

func BytesToString 

func BytesToString(bytes []byte) string

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

func CopySSH 

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

func CreateSelfSignedTLSConfig added in v0.1.38 

func CreateSelfSignedTLSConfig(organization string, host string) (*tls.Config, error)

func CreateTLSConfig added in v0.1.38 

func CreateTLSConfig(certificate []byte, key []byte) (*tls.Config, error)

func CreateX509Certificate added in v0.1.38 

func CreateX509Certificate(organization string, host string, rsa bool, ca bool) (*x509.Certificate, error)

func ExecSSH 

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

func Exit added in v0.1.22 

func Exit(code int)

func ExitOnSIGTERM added in v0.1.33 

func ExitOnSIGTERM()

func Fail 

func Fail(message string)

func FailOnError 

func FailOnError(err error)

func Failf 

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

func FromBase64 added in v0.1.4 

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

func GetFileHash 

func GetFileHash(path string) (string, error)

func GetGoBin added in v0.1.31 

func GetGoBin() (string, error)

func GetGoPath added in v0.1.31 

func GetGoPath() (string, error)

func NewMockLocker added in v0.1.51 

func NewMockLocker() sync.Locker

func ParseX509CertPool added in v0.1.6 

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

func ParseX509Certificates added in v0.1.6 

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

func ReaderSize 

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

func ResetAdHocLocks added in v0.1.51 

func ResetAdHocLocks()

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 SignX509Certificate added in v0.1.38 

func SignX509Certificate(certificate *x509.Certificate, privateKey interface{}, publicKey interface{}) (*x509.Certificate, error)

func SortedMapStringStringKeys 

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

func StringToBytes 

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

This casting *does not* copy data. Note that casting via "[]byte(value)" *does* copy data.

func Timestamp 

func Timestamp(asString bool) interface{}

func ToBase64 added in v0.1.4 

func ToBase64(bytes []byte) string

func WriteNewline added in v0.1.27 

func WriteNewline(writer io.Writer) error

Types

type BufferedWriter added in v0.1.22 

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

func NewBufferedWriter added in v0.1.22 

func NewBufferedWriter(writer io.Writer, size int) BufferedWriter

func (BufferedWriter) Close added in v0.1.22 

func (self BufferedWriter) Close() error

io.Closer interface

func (BufferedWriter) CloseOnExit added in v0.1.27 

func (self BufferedWriter) CloseOnExit() ExitFunctionHandle

func (BufferedWriter) Write added in v0.1.22 

func (self BufferedWriter) Write(p []byte) (int, error)

io.Writer interface

type CoordinatedWork added in v0.1.52 

type CoordinatedWork struct {
	sync.Map
}

func NewCoordinatedWork added in v0.1.52 

func NewCoordinatedWork() *CoordinatedWork

func (*CoordinatedWork) Start added in v0.1.52 

func (self *CoordinatedWork) Start(key string) (Promise, bool)

type ExitFunctionHandle added in v0.1.22 

type ExitFunctionHandle uint64

func OnExit added in v0.1.22 

func OnExit(exitFunction func()) ExitFunctionHandle

func OnExitError added in v0.1.50 

func OnExitError(exitFunction func() error) ExitFunctionHandle

func (ExitFunctionHandle) Cancel added in v0.1.22 

func (self ExitFunctionHandle) Cancel()

type ForceHTTPSRoundTripper added in v0.1.4 

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

func NewForceHTTPSRoundTripper added in v0.1.4 

func NewForceHTTPSRoundTripper(roundTripper http.RoundTripper) *ForceHTTPSRoundTripper

func (*ForceHTTPSRoundTripper) RoundTrip added in v0.1.4 

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

http.RoundTripper interface

type LockType added in v0.1.51 

type LockType int

type LockableEntity added in v0.1.51 

type LockableEntity interface {
	GetEntityLock() RWLocker
}

type MockLocker added in v0.1.51 

type MockLocker struct{}

func (MockLocker) Lock added in v0.1.51 

func (self MockLocker) Lock()

sync.Locker interface

func (MockLocker) Unlock added in v0.1.51 

func (self MockLocker) Unlock()

sync.Locker interface

type MockRWLocker added in v0.1.51 

type MockRWLocker struct {
	MockLocker
}

func (MockRWLocker) RLock added in v0.1.51 

func (self MockRWLocker) RLock()

RWLocker interface

func (MockRWLocker) RLocker added in v0.1.51 

func (self MockRWLocker) RLocker() sync.Locker

RWLocker interface

func (MockRWLocker) RUnlock added in v0.1.51 

func (self MockRWLocker) RUnlock()

RWLocker interface

type Promise added in v0.1.52 

type Promise chan struct{}

func NewPromise added in v0.1.52 

func NewPromise() Promise

func (Promise) Release added in v0.1.52 

func (self Promise) Release()

func (Promise) Wait added in v0.1.52 

func (self Promise) Wait()

type RWLocker added in v0.1.51 

type RWLocker interface {
	sync.Locker
	RLock()
	RUnlock()
	RLocker() sync.Locker
}

func GetAdHocLock added in v0.1.51 

func GetAdHocLock(pointer interface{}, type_ LockType) RWLocker

Warning: Addresses can be re-used after the resource if freed. This facililty should only be used for long-lived objects.

func GetEntityLock added in v0.1.51 

func GetEntityLock(entity interface{}) RWLocker

func NewDebugRWLocker added in v0.1.51 

func NewDebugRWLocker() RWLocker

func NewDefaultRWLocker added in v0.1.51 

func NewDefaultRWLocker() RWLocker

func NewMockRWLocker added in v0.1.51 

func NewMockRWLocker() RWLocker

func NewRWLocker added in v0.1.51 

func NewRWLocker(type_ LockType) RWLocker

func NewSyncRWLocker added in v0.1.52 

func NewSyncRWLocker() RWLocker

type SyncedWriter added in v0.1.22 

type SyncedWriter struct {
	Writer io.Writer
	// contains filtered or unexported fields
}

func NewSyncedWriter added in v0.1.22 

func NewSyncedWriter(writer io.Writer) *SyncedWriter

func (*SyncedWriter) Close added in v0.1.22 

func (self *SyncedWriter) Close() error

io.Closer interface

func (*SyncedWriter) Write added in v0.1.22 

func (self *SyncedWriter) Write(p []byte) (int, error)

io.Writer 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

type TestLogWriter added in v0.1.51 

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

func NewTestLogWriter added in v0.1.51 

func NewTestLogWriter(t *testing.T) *TestLogWriter

func (*TestLogWriter) Write added in v0.1.51 

func (self *TestLogWriter) Write(p []byte) (n int, err error)

io.Writer interface

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.