astikit

package module
v0.0.11 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2020 License: MIT Imports: 23 Imported by: 233

README

Astikit is a set of golang helpers that don't require any external dependencies.

Documentation

Index

Constants

View Source 
const (
	ExecStatusCrashed = "crashed"
	ExecStatusRunning = "running"
	ExecStatusStopped = "stopped"
)

Statuses

View Source 
const (
	ChanAddStrategyBlockWhenStarted = "block.when.started"
	ChanAddStrategyNoBlock          = "no.block"
	ChanOrderFIFO                   = "fifo"
	ChanOrderFILO                   = "filo"
)

Variables

View Source 
var (
	DefaultDirMode os.FileMode = 0755
)

Default modes

Functions

func BoolPtr added in v0.0.3 

func BoolPtr(i bool) *bool

BoolPtr transforms a bool into a *bool

func ByteHamming84Decode added in v0.0.10 

func ByteHamming84Decode(i uint8) (o uint8, ok bool)

ByteHamming84Decode hamming 8/4 decodes

func ByteParity added in v0.0.10 

func ByteParity(i uint8) (o uint8, ok bool)

ByteParityreturns the byte parity

func BytePtr added in v0.0.3 

func BytePtr(i byte) *byte

BytePtr transforms a byte into a *byte

func BytesPad added in v0.0.10 

func BytesPad(i []byte, repeat byte, length int, options ...PadOption) []byte

BytesPad pads the slice of bytes

func ChainHTTPMiddlewares added in v0.0.3 

func ChainHTTPMiddlewares(h http.Handler, ms ...HTTPMiddleware) http.Handler

ChainHTTPMiddlewares chains HTTP middlewares

func ChainHTTPMiddlewaresWithPrefix added in v0.0.3 

func ChainHTTPMiddlewaresWithPrefix(h http.Handler, prefixes []string, ms ...HTTPMiddleware) http.Handler

ChainHTTPMiddlewaresWithPrefix chains HTTP middlewares if one of prefixes is present

func ConvertPCMBitDepth added in v0.0.3 

func ConvertPCMBitDepth(srcSample int, srcBitDepth, dstBitDepth int) (dstSample int, err error)

ConvertPCMBitDepth converts the PCM bit depth

func Copy added in v0.0.5 

func Copy(ctx context.Context, dst io.Writer, src io.Reader) (int64, error)

Copy is a copy with a context

func CopyFile added in v0.0.5 

func CopyFile(ctx context.Context, dst, src string, f CopyFileFunc) (err error)

CopyFile is a cancellable copy of a local file to a local or remote location

func DurationPtr added in v0.0.3 

func DurationPtr(i time.Duration) *time.Duration

DurationPtr transforms a time.Duration into a *time.Duration

func FlagCmd added in v0.0.4 

func FlagCmd() (o string)

FlagCmd retrieves the command from the input Args

func Float64Ptr added in v0.0.3 

func Float64Ptr(i float64) *float64

Float64Ptr transforms a float64 into a *float64

func Int64Ptr added in v0.0.3 

func Int64Ptr(i int64) *int64

Int64Ptr transforms an int64 into an *int64

func IntPtr added in v0.0.3 

func IntPtr(i int) *int

IntPtr transforms an int into an *int

func LocalCopyFileFunc added in v0.0.5 

func LocalCopyFileFunc(ctx context.Context, dst string, srcStat os.FileInfo, srcFile *os.File) (err error)

LocalCopyFileFunc is the local CopyFileFunc that allows doing cross partition copies

func MoveFile added in v0.0.8 

func MoveFile(ctx context.Context, dst, src string, f CopyFileFunc) (err error)

MoveFile is a cancellable move of a local file to a local or remote location

func NopCloser added in v0.0.5 

func NopCloser(w io.Writer) io.WriteCloser

NopCloser returns a WriteCloser with a no-op Close method wrapping the provided Writer w.

func PCMLevel added in v0.0.3 

func PCMLevel(samples []int) float64

PCMLevel computes the PCM level of samples https://dsp.stackexchange.com/questions/2951/loudness-of-pcm-stream https://dsp.stackexchange.com/questions/290/getting-loudness-of-a-track-with-rms?noredirect=1&lq=1

func PCMNormalize added in v0.0.3 

func PCMNormalize(samples []int, bitDepth int) (o []int)

func PadCut added in v0.0.10 

func PadCut(p *bytesPadder)

func PadLeft added in v0.0.10 

func PadLeft(p *bytesPadder)

func PadRight added in v0.0.10 

func PadRight(p *bytesPadder)

func RandStr added in v0.0.5 

func RandStr(n int) string

RandStr generates a random string of length n https://stackoverflow.com/questions/22892120/how-to-generate-a-random-string-of-a-fixed-length-in-golang

func ServeHTTP added in v0.0.2 

func ServeHTTP(w *Worker, o ServeHTTPOptions)

ServeHTTP spawns an HTTP server

func Sleep 

func Sleep(ctx context.Context, d time.Duration) (err error)

Sleep is a cancellable sleep

func SortInt64 added in v0.0.6 

func SortInt64(a []int64)

SortInt64 sorts a slice of int64s in increasing order.

func StrPad added in v0.0.10 

func StrPad(i string, repeat rune, length int, options ...PadOption) string

StrPad pads the string

func StrPtr added in v0.0.3 

func StrPtr(i string) *string

StrPtr transforms a string into a *string

func UInt32Ptr added in v0.0.3 

func UInt32Ptr(i uint32) *uint32

UInt32Ptr transforms a uint32 into a *uint32

func UInt8Ptr added in v0.0.3 

func UInt8Ptr(i uint8) *uint8

UInt8Ptr transforms a uint8 into a *uint8

func Unzip added in v0.0.7 

func Unzip(ctx context.Context, dst, src string) (err error)

Unzip unzips a src into a dst Possible src formats are:

  • /path/to/zip.zip
  • /path/to/zip.zip/root/path

func Zip added in v0.0.7 

func Zip(ctx context.Context, dst, src string) (err error)

Zip zips a src into a dst Possible dst formats are:

  • /path/to/zip.zip
  • /path/to/zip.zip/root/path

Types

type BiMap added in v0.0.10 

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

BiMap represents a bidirectional map

func NewBiMap added in v0.0.10 

func NewBiMap() *BiMap

NewBiMap creates a new BiMap

func (*BiMap) Get added in v0.0.10 

func (m *BiMap) Get(k interface{}) (interface{}, bool)

Get gets the value in the forward map based on the provided key

func (*BiMap) GetInverse added in v0.0.10 

func (m *BiMap) GetInverse(k interface{}) (interface{}, bool)

GetInverse gets the value in the inverse map based on the provided key

func (*BiMap) Set added in v0.0.10 

func (m *BiMap) Set(k, v interface{}) *BiMap

Set sets the value in the forward and inverse map for the provided forward key

func (*BiMap) SetInverse added in v0.0.10 

func (m *BiMap) SetInverse(k, v interface{}) *BiMap

SetInverse sets the value in the forward and inverse map for the provided inverse key

type BitsWriter added in v0.0.9 

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

BitsWriter represents an object that can write individual bits into a writer in a developer-friendly way. Check out the Write method for more information. This is particularly helpful when you want to build a slice of bytes based on individual bits for testing purposes.

func NewBitsWriter added in v0.0.9 

func NewBitsWriter(o BitsWriterOptions) (w *BitsWriter)

NewBitsWriter creates a new BitsWriter

func (*BitsWriter) Write added in v0.0.9 

func (w *BitsWriter) Write(i interface{}) (err error)

Write writes bits into the writer. Bits are only written when there are enough to create a byte. When using a string or a bool, bits are added from left to right as if Available types are:

  • string("10010"): processed as n bits, n being the length of the input
  • []byte: processed as n bytes, n being the length of the input
  • bool: processed as one bit
  • uint8/uint16/uint32/uint64: processed as n bits, if type is uintn

func (*BitsWriter) WriteN added in v0.0.9 

func (w *BitsWriter) WriteN(i interface{}, n int) error

WriteN writes the input into n bits

type BitsWriterOptions added in v0.0.9 

type BitsWriterOptions struct {
	ByteOrder binary.ByteOrder
	Writer    io.Writer
}

BitsWriterOptions represents BitsWriter options

type BufferPool added in v0.0.6 

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

BufferPool represents a *bytes.Buffer pool

func NewBufferPool added in v0.0.6 

func NewBufferPool() *BufferPool

NewBufferPool creates a new BufferPool

func (*BufferPool) New added in v0.0.6 

func (p *BufferPool) New() *BufferPoolItem

New creates a new BufferPoolItem

type BufferPoolItem added in v0.0.6 

type BufferPoolItem struct {
	*bytes.Buffer
	// contains filtered or unexported fields
}

BufferPoolItem represents a BufferPool item

func (*BufferPoolItem) Close added in v0.0.6 

func (i *BufferPoolItem) Close() error

Close implements the io.Closer interface

type BytesIterator added in v0.0.9 

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

BytesIterator represents an object capable of iterating sequentially and safely through a slice of bytes. This is particularly useful when you need to iterate through a slice of bytes and don't want to check for "index out of range" errors manually.

func NewBytesIterator added in v0.0.9 

func NewBytesIterator(bs []byte) *BytesIterator

NewBytesIterator creates a new BytesIterator

func (*BytesIterator) Dump added in v0.0.9 

func (i *BytesIterator) Dump() (bs []byte)

Dump dumps the rest of the slice

func (*BytesIterator) HasBytesLeft added in v0.0.9 

func (i *BytesIterator) HasBytesLeft() bool

HasBytesLeft checks whether there are bytes left

func (*BytesIterator) Len added in v0.0.9 

func (i *BytesIterator) Len() int

Len returns the slice length

func (*BytesIterator) NextByte added in v0.0.9 

func (i *BytesIterator) NextByte() (b byte, err error)

NextByte returns the next byte

func (*BytesIterator) NextBytes added in v0.0.9 

func (i *BytesIterator) NextBytes(n int) (bs []byte, err error)

NextBytes returns the n next bytes

func (*BytesIterator) Offset added in v0.0.9 

func (i *BytesIterator) Offset() int

Offset returns the offset

func (*BytesIterator) Seek added in v0.0.9 

func (i *BytesIterator) Seek(n int)

Seek seeks to the nth byte

func (*BytesIterator) Skip added in v0.0.9 

func (i *BytesIterator) Skip(n int)

Skip skips the n previous/next bytes

type Chan added in v0.0.3 

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

Chan is an object capable of executing funcs in a specific order while controlling the conditions in which adding new funcs is blocking Check out ChanOptions for detailed options

func NewChan added in v0.0.3 

func NewChan(o ChanOptions) *Chan

NewChan creates a new Chan

func (*Chan) Add added in v0.0.3 

func (c *Chan) Add(i func())

Add adds a new item to the chan

func (*Chan) AddStats added in v0.0.4 

func (c *Chan) AddStats(s *Stater)

AddStats adds stats to the stater

func (*Chan) Reset added in v0.0.3 

func (c *Chan) Reset()

Reset resets the chan

func (*Chan) Start added in v0.0.3 

func (c *Chan) Start(ctx context.Context)

Start starts the chan by looping through functions in the buffer and executing them if any, or waiting for a new one otherwise

func (*Chan) Stop added in v0.0.3 

func (c *Chan) Stop()

Stop stops the chan

type ChanOptions added in v0.0.3 

type ChanOptions struct {
	// Determines the conditions in which adding new funcs is blocking.
	// Possible strategies are :
	//   - calling Add() never blocks (default). Use the ChanAddStrategyNoBlock constant.
	//   - calling Add() only blocks if the chan has been started and the ctx
	//     has not been canceled. Use the ChanAddStrategyBlockWhenStarted constant.
	AddStrategy string
	// Order in which the funcs will be processed. See constants with the pattern ChanOrder*
	Order string
	// By default the funcs not yet processed when the context is cancelled are dropped.
	// If "ProcessAll" is true,  ALL funcs are processed even after the context is cancelled.
	// However, no funcs can be added after the context is cancelled
	ProcessAll bool
}

ChanOptions are Chan options

type CloseFunc added in v0.0.4 

type CloseFunc func() error

CloseFunc is a method that closes something

type Closer added in v0.0.4 

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

Closer is an object that can close several things

func NewCloser added in v0.0.4 

func NewCloser() *Closer

NewCloser creates a new closer

func (*Closer) Add added in v0.0.4 

func (c *Closer) Add(f CloseFunc)

Add adds a close func at the beginning of the list

func (*Closer) Close added in v0.0.4 

func (c *Closer) Close() error

Close implements the io.Closer interface

func (*Closer) NewChild added in v0.0.4 

func (c *Closer) NewChild() (child *Closer)

NewChild creates a new child closer

type CopyFileFunc added in v0.0.5 

type CopyFileFunc func(ctx context.Context, dst string, srcStat os.FileInfo, srcFile *os.File) error

CopyFileFunc represents a CopyFile func

func SSHCopyFileFunc added in v0.0.5 

func SSHCopyFileFunc(fn SSHSessionFunc) CopyFileFunc

type CounterAvgStat added in v0.0.4 

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

CounterAvgStat is an object capable of computing the average value of a counter per second

func NewCounterAvgStat added in v0.0.4 

func NewCounterAvgStat() *CounterAvgStat

NewCounterAvgStat creates a new counter avg stat

func (CounterAvgStat) Add added in v0.0.4 

func (s CounterAvgStat) Add(delta float64)

func (CounterAvgStat) Start added in v0.0.4 

func (s CounterAvgStat) Start()

func (CounterAvgStat) Stop added in v0.0.4 

func (s CounterAvgStat) Stop()

func (CounterAvgStat) Value added in v0.0.4 

func (s CounterAvgStat) Value(delta time.Duration) interface{}

type CtxReader added in v0.0.5 

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

CtxReader represents a reader with a context

func NewCtxReader added in v0.0.5 

func NewCtxReader(ctx context.Context, r io.Reader) *CtxReader

NewCtxReader creates a reader with a context

func (*CtxReader) Read added in v0.0.5 

func (r *CtxReader) Read(p []byte) (n int, err error)

Read implements the io.Reader interface

type DurationPercentageStat added in v0.0.4 

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

DurationPercentageStat is an object capable of computing the percentage of time some work is taking per second

func NewDurationPercentageStat added in v0.0.4 

func NewDurationPercentageStat() *DurationPercentageStat

NewDurationPercentageStat creates a new duration percentage stat

func (DurationPercentageStat) Begin added in v0.0.4 

func (s DurationPercentageStat) Begin()

func (DurationPercentageStat) End added in v0.0.4 

func (s DurationPercentageStat) End()

func (DurationPercentageStat) Start added in v0.0.4 

func (s DurationPercentageStat) Start()

func (DurationPercentageStat) Stop added in v0.0.4 

func (s DurationPercentageStat) Stop()

func (DurationPercentageStat) Value added in v0.0.4 

func (s DurationPercentageStat) Value(delta time.Duration) (o interface{})

type Errors added in v0.0.4 

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

Errors is an error containing multiple errors

func NewErrors added in v0.0.4 

func NewErrors(errs ...error) *Errors

NewErrors creates new errors

func (*Errors) Add added in v0.0.4 

func (errs *Errors) Add(err error)

Add adds a new error

func (*Errors) Error added in v0.0.4 

func (errs *Errors) Error() string

Error implements the error interface

func (*Errors) IsNil added in v0.0.4 

func (errs *Errors) IsNil() bool

IsNil checks whether the error is nil

func (*Errors) Loop added in v0.0.4 

func (errs *Errors) Loop(fn func(idx int, err error) bool)

Loop loops through the errors

type ExecCmdOptions added in v0.0.2 

type ExecCmdOptions struct {
	Args       []string
	CmdAdapter func(cmd *exec.Cmd, h *ExecHandler) error
	Name       string
	StopFunc   func(cmd *exec.Cmd) error
}

ExecCmdOptions represents exec options

type ExecHandler added in v0.0.2 

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

ExecHandler represents an object capable of handling the execution of a cmd

func ExecCmd added in v0.0.2 

func ExecCmd(w *Worker, o ExecCmdOptions) (h *ExecHandler, err error)

ExecCmd executes a cmd The process will be stopped when the worker stops

func (*ExecHandler) Status added in v0.0.2 

func (h *ExecHandler) Status() string

func (*ExecHandler) Stop added in v0.0.2 

func (h *ExecHandler) Stop()

type FlagStrings added in v0.0.9 

type FlagStrings struct {
	Map   map[string]bool
	Slice *[]string
}

FlagStrings represents a flag that can be set several times and stores unique string values

func NewFlagStrings added in v0.0.9 

func NewFlagStrings() FlagStrings

NewFlagStrings creates a new FlagStrings

func (FlagStrings) Set added in v0.0.9 

func (f FlagStrings) Set(i string) error

Set implements the flag.Value interface

func (FlagStrings) String added in v0.0.9 

func (f FlagStrings) String() string

String implements the flag.Value interface

type GoroutineLimiter added in v0.0.6 

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

GoroutineLimiter is an object capable of doing several things in parallel while maintaining the max number of things running in parallel under a threshold

func NewGoroutineLimiter added in v0.0.6 

func NewGoroutineLimiter(o GoroutineLimiterOptions) (l *GoroutineLimiter)

NewGoroutineLimiter creates a new GoroutineLimiter

func (*GoroutineLimiter) Close added in v0.0.6 

func (l *GoroutineLimiter) Close() error

Close closes the limiter properly

func (*GoroutineLimiter) Do added in v0.0.6 

func (l *GoroutineLimiter) Do(fn GoroutineLimiterFunc) (err error)

Do executes custom work in a goroutine

type GoroutineLimiterFunc added in v0.0.6 

type GoroutineLimiterFunc func()

GoroutineLimiterFunc is a GoroutineLimiter func

type GoroutineLimiterOptions added in v0.0.6 

type GoroutineLimiterOptions struct {
	Max int
}

GoroutineLimiterOptions represents GoroutineLimiter options

type HTTPClient added in v0.0.4 

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPClient represents an HTTP client

type HTTPDownloader added in v0.0.6 

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

HTTPDownloader represents an object capable of downloading several HTTP srcs simultaneously and doing stuff to the results

func NewHTTPDownloader added in v0.0.6 

func NewHTTPDownloader(o HTTPDownloaderOptions) (d *HTTPDownloader)

NewHTTPDownloader creates a new HTTPDownloader

func (*HTTPDownloader) Close added in v0.0.6 

func (d *HTTPDownloader) Close() error

Close closes the downloader properly

func (*HTTPDownloader) DownloadInDirectory added in v0.0.6 

func (d *HTTPDownloader) DownloadInDirectory(ctx context.Context, dst string, srcs ...HTTPDownloaderSrc) error

DownloadInDirectory downloads in parallel a set of srcs and saves them in a dst directory

func (*HTTPDownloader) DownloadInFile added in v0.0.6 

func (d *HTTPDownloader) DownloadInFile(ctx context.Context, dst string, srcs ...HTTPDownloaderSrc) (err error)

DownloadInFile downloads in parallel a set of srcs and concatenates them in a dst file while maintaining the initial order

func (*HTTPDownloader) DownloadInWriter added in v0.0.6 

func (d *HTTPDownloader) DownloadInWriter(ctx context.Context, dst io.Writer, srcs ...HTTPDownloaderSrc) error

DownloadInWriter downloads in parallel a set of srcs and concatenates them in a writer while maintaining the initial order

type HTTPDownloaderOptions added in v0.0.6 

type HTTPDownloaderOptions struct {
	Limiter      GoroutineLimiterOptions
	ResponseFunc HTTPResponseFunc
	Sender       HTTPSenderOptions
}

HTTPDownloaderOptions represents HTTPDownloader options

type HTTPDownloaderSrc added in v0.0.6 

type HTTPDownloaderSrc struct {
	Body   io.Reader
	Header http.Header
	Method string
	URL    string
}

type HTTPMiddleware added in v0.0.3 

type HTTPMiddleware func(http.Handler) http.Handler

HTTPMiddleware represents an HTTP middleware

func HTTPMiddlewareBasicAuth added in v0.0.3 

func HTTPMiddlewareBasicAuth(username, password string) HTTPMiddleware

HTTPMiddlewareBasicAuth adds basic HTTP auth to an HTTP handler

func HTTPMiddlewareContentType added in v0.0.3 

func HTTPMiddlewareContentType(contentType string) HTTPMiddleware

HTTPMiddlewareContentType adds a content type to an HTTP handler

func HTTPMiddlewareHeaders added in v0.0.5 

func HTTPMiddlewareHeaders(vs map[string]string) HTTPMiddleware

HTTPMiddlewareHeaders adds headers to an HTTP handler

type HTTPResponseFunc added in v0.0.6 

type HTTPResponseFunc func(resp *http.Response) error

HTTPResponseFunc is a func that can process an $http.Response

type HTTPSender added in v0.0.4 

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

HTTPSender represents an object capable of sending http requests

func NewHTTPSender added in v0.0.4 

func NewHTTPSender(o HTTPSenderOptions) (s *HTTPSender)

NewHTTPSender creates a new HTTP sender

func (*HTTPSender) Send added in v0.0.4 

func (s *HTTPSender) Send(req *http.Request) (resp *http.Response, err error)

Send sends a new *http.Request

type HTTPSenderOptions added in v0.0.4 

type HTTPSenderOptions struct {
	Client     HTTPClient
	Logger     StdLogger
	RetryFunc  HTTPSenderRetryFunc
	RetryMax   int
	RetrySleep time.Duration
}

HTTPSenderOptions represents HTTPSender options

type HTTPSenderRetryFunc added in v0.0.4 

type HTTPSenderRetryFunc func(name string, resp *http.Response) bool

HTTPSenderRetryFunc is a function that decides whether to retry an HTTP request

type Limiter added in v0.0.3 

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

Limiter represents a limiter

func NewLimiter added in v0.0.3 

func NewLimiter() *Limiter

NewLimiter creates a new limiter

func (*Limiter) Add added in v0.0.3 

func (l *Limiter) Add(name string, cap int, period time.Duration) *LimiterBucket

Add adds a new bucket

func (*Limiter) Bucket added in v0.0.3 

func (l *Limiter) Bucket(name string) (b *LimiterBucket, ok bool)

Bucket retrieves a bucket from the limiter

func (*Limiter) Close added in v0.0.3 

func (l *Limiter) Close()

Close closes the limiter properly

type LimiterBucket added in v0.0.3 

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

LimiterBucket represents a limiter bucket

func (*LimiterBucket) Close added in v0.0.3 

func (b *LimiterBucket) Close()

close closes the bucket properly

func (*LimiterBucket) Inc added in v0.0.3 

func (b *LimiterBucket) Inc() bool

Inc increments the bucket count

type PCMChannelsConverter added in v0.0.3 

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

func NewPCMChannelsConverter added in v0.0.3 

func NewPCMChannelsConverter(srcNumChannels, dstNumChannels int, fn PCMSampleFunc) *PCMChannelsConverter

func (*PCMChannelsConverter) Add added in v0.0.3 

func (c *PCMChannelsConverter) Add(i int) (err error)

func (*PCMChannelsConverter) Reset added in v0.0.3 

func (c *PCMChannelsConverter) Reset()

type PCMSampleFunc added in v0.0.3 

type PCMSampleFunc func(s int) error

type PCMSampleRateConverter added in v0.0.3 

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

func NewPCMSampleRateConverter added in v0.0.3 

func NewPCMSampleRateConverter(srcSampleRate, dstSampleRate, numChannels int, fn PCMSampleFunc) *PCMSampleRateConverter

func (*PCMSampleRateConverter) Add added in v0.0.3 

func (c *PCMSampleRateConverter) Add(i int) (err error)

func (*PCMSampleRateConverter) Reset added in v0.0.3 

func (c *PCMSampleRateConverter) Reset()

type PCMSilenceDetector added in v0.0.3 

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

PCMSilenceDetector represents a PCM silence detector

func NewPCMSilenceDetector added in v0.0.3 

func NewPCMSilenceDetector(o PCMSilenceDetectorOptions) (d *PCMSilenceDetector)

NewPCMSilenceDetector creates a new silence detector

func (*PCMSilenceDetector) Add added in v0.0.3 

func (d *PCMSilenceDetector) Add(samples []int) (validSamples [][]int)

Add adds samples to the buffer and checks whether there are valid samples between silences

func (*PCMSilenceDetector) Reset added in v0.0.3 

func (d *PCMSilenceDetector) Reset()

Reset resets the silence detector

type PCMSilenceDetectorOptions added in v0.0.3 

type PCMSilenceDetectorOptions struct {
	MaxSilenceLevel    float64       `toml:"max_silence_level"`
	MinSilenceDuration time.Duration `toml:"min_silence_duration"`
	SampleRate         int           `toml:"sample_rate"`
	StepDuration       time.Duration `toml:"step_duration"`
}

PCMSilenceDetectorOptions represents a PCM silence detector options

type PadOption added in v0.0.10 

type PadOption func(p *bytesPadder)

type Rational added in v0.0.4 

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

Rational represents a rational

func NewRational added in v0.0.4 

func NewRational(num, den int) *Rational

NewRational creates a new rational

func (*Rational) Den added in v0.0.4 

func (r *Rational) Den() int

Den returns the rational den

func (*Rational) MarshalText added in v0.0.4 

func (r *Rational) MarshalText() (b []byte, err error)

MarshalText implements the TextMarshaler interface

func (*Rational) Num added in v0.0.4 

func (r *Rational) Num() int

Num returns the rational num

func (*Rational) ToFloat64 added in v0.0.4 

func (r *Rational) ToFloat64() float64

ToFloat64 returns the rational as a float64

func (*Rational) UnmarshalText added in v0.0.4 

func (r *Rational) UnmarshalText(b []byte) (err error)

UnmarshalText implements the TextUnmarshaler interface

type SSHSession added in v0.0.5 

type SSHSession interface {
	Run(string) error
	Start(string) error
	StdinPipe() (io.WriteCloser, error)
	Wait() error
}

type SSHSessionFunc added in v0.0.5 

type SSHSessionFunc func() (s SSHSession, c *Closer, err error)

type ServeHTTPOptions added in v0.0.2 

type ServeHTTPOptions struct {
	Addr    string
	Handler http.Handler
}

ServeHTTPOptions represents serve options

type SeverityLogger added in v0.0.4 

type SeverityLogger interface {
	Debug(v ...interface{})
	Debugf(format string, v ...interface{})
	Error(v ...interface{})
	Errorf(format string, v ...interface{})
	Info(v ...interface{})
	Infof(format string, v ...interface{})
}

func AdaptStdLogger added in v0.0.4 

func AdaptStdLogger(i StdLogger) SeverityLogger

type SignalHandler added in v0.0.2 

type SignalHandler func(s os.Signal)

SignalHandler represents a func that can handle a signal

func TermSignalHandler added in v0.0.2 

func TermSignalHandler(f func()) SignalHandler

TermSignalHandler returns a SignalHandler that is executed only on a term signal

type SortInt64Slice added in v0.0.6 

type SortInt64Slice []int64

SortInt64Slice attaches the methods of Interface to []int64, sorting in increasing order.

func (SortInt64Slice) Len added in v0.0.6 

func (p SortInt64Slice) Len() int

func (SortInt64Slice) Less added in v0.0.6 

func (p SortInt64Slice) Less(i, j int) bool

func (SortInt64Slice) Swap added in v0.0.6 

func (p SortInt64Slice) Swap(i, j int)

type Stat added in v0.0.4 

type Stat struct {
	StatMetadata
	Value interface{}
}

Stat represents a stat

type StatHandler added in v0.0.4 

type StatHandler interface {
	Start()
	Stop()
	Value(delta time.Duration) interface{}
}

StatHandler represents a stat handler

type StatMetadata added in v0.0.4 

type StatMetadata struct {
	Description string
	Label       string
	Unit        string
}

StatMetadata represents a stat metadata

type Stater added in v0.0.4 

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

Stater is an object that can compute and handle stats

func NewStater added in v0.0.4 

func NewStater(o StaterOptions) *Stater

NewStater creates a new stater

func (*Stater) AddStat added in v0.0.4 

func (s *Stater) AddStat(m StatMetadata, h StatHandler)

AddStat adds a stat

func (*Stater) Start added in v0.0.4 

func (s *Stater) Start(ctx context.Context)

Start starts the stater

func (*Stater) StatsMetadata added in v0.0.4 

func (s *Stater) StatsMetadata() (ms []StatMetadata)

StatsMetadata returns the stats metadata

func (*Stater) Stop added in v0.0.4 

func (s *Stater) Stop()

Stop stops the stater

type StaterOptions added in v0.0.4 

type StaterOptions struct {
	HandleFunc StatsHandleFunc
	Period     time.Duration
}

StaterOptions represents stater options

type StatsHandleFunc added in v0.0.4 

type StatsHandleFunc func(stats []Stat)

StatsHandleFunc is a method that can handle stats

type StdLogger added in v0.0.4 

type StdLogger interface {
	Print(v ...interface{})
	Printf(format string, v ...interface{})
}

type Task added in v0.0.2 

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

Task represents a task

func (*Task) Do added in v0.0.2 

func (t *Task) Do(f func())

Do executes the task

func (*Task) Done added in v0.0.2 

func (t *Task) Done()

Done indicates the task is done

func (*Task) NewSubTask added in v0.0.2 

func (t *Task) NewSubTask() *Task

NewSubTask creates a new sub task

func (*Task) Wait added in v0.0.2 

func (t *Task) Wait()

Wait waits for the task to be finished

type TaskFunc added in v0.0.2 

type TaskFunc func() *Task

TaskFunc represents a function that can create a new task

type Templater added in v0.0.3 

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

Templater represents an object capable of storing and parsing templates

func NewTemplater added in v0.0.3 

func NewTemplater() *Templater

NewTemplater creates a new templater

func (*Templater) AddLayout added in v0.0.3 

func (t *Templater) AddLayout(c string)

AddLayout adds a new layout

func (*Templater) AddLayoutsFromDir added in v0.0.3 

func (t *Templater) AddLayoutsFromDir(dirPath, ext string) (err error)

AddLayoutsFromDir walks through a dir and add files as layouts

func (*Templater) AddTemplate added in v0.0.3 

func (t *Templater) AddTemplate(path, content string) (err error)

AddTemplate adds a new template

func (*Templater) AddTemplatesFromDir added in v0.0.3 

func (t *Templater) AddTemplatesFromDir(dirPath, ext string) (err error)

AddTemplatesFromDir walks through a dir and add files as templates

func (*Templater) DelTemplate added in v0.0.3 

func (t *Templater) DelTemplate(path string)

DelTemplate deletes a template

func (*Templater) Parse added in v0.0.3 

func (t *Templater) Parse(content string) (o *template.Template, err error)

Parse parses the content of a template

func (*Templater) Template added in v0.0.3 

func (t *Templater) Template(path string) (tpl *template.Template, ok bool)

Template retrieves a templates

type Timestamp 

type Timestamp struct {
	time.Time
}

Timestamp represents a timestamp you can marshal and umarshal

func NewTimestamp 

func NewTimestamp(t time.Time) *Timestamp

NewTimestamp creates a new timestamp

func (Timestamp) MarshalJSON 

func (t Timestamp) MarshalJSON() ([]byte, error)

MarshalJSON implements the JSONMarshaler interface

func (Timestamp) MarshalText 

func (t Timestamp) MarshalText() (text []byte, err error)

MarshalText implements the TextMarshaler interface

func (*Timestamp) UnmarshalJSON 

func (t *Timestamp) UnmarshalJSON(text []byte) error

UnmarshalJSON implements the JSONUnmarshaler interface

func (*Timestamp) UnmarshalText 

func (t *Timestamp) UnmarshalText(text []byte) (err error)

UnmarshalText implements the TextUnmarshaler interface

type Worker added in v0.0.2 

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

Worker represents an object capable of blocking, handling signals and stopping

func NewWorker added in v0.0.2 

func NewWorker(o WorkerOptions) (w *Worker)

NewWorker builds a new worker

func (*Worker) Context added in v0.0.2 

func (w *Worker) Context() context.Context

Context returns the worker's context

func (*Worker) HandleSignals added in v0.0.2 

func (w *Worker) HandleSignals(hs ...SignalHandler)

HandleSignals handles signals

func (*Worker) Logger added in v0.0.2 

func (w *Worker) Logger() SeverityLogger

Logger returns the worker's logger

func (*Worker) NewTask added in v0.0.2 

func (w *Worker) NewTask() *Task

NewTask creates a new task

func (*Worker) Stop added in v0.0.2 

func (w *Worker) Stop()

Stop stops the Worker

func (*Worker) Wait added in v0.0.2 

func (w *Worker) Wait()

Wait is a blocking pattern

type WorkerOptions added in v0.0.3 

type WorkerOptions struct {
	Logger StdLogger
}

WorkerOptions represents worker options

type WriterAdapter added in v0.0.3 

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

WriterAdapter represents an object that can adapt a Writer

func NewWriterAdapter added in v0.0.3 

func NewWriterAdapter(o WriterAdapterOptions) *WriterAdapter

NewWriterAdapter creates a new WriterAdapter

func (*WriterAdapter) Close added in v0.0.3 

func (w *WriterAdapter) Close()

Close closes the adapter properly

func (*WriterAdapter) Write added in v0.0.3 

func (w *WriterAdapter) Write(i []byte) (n int, err error)

Write implements the io.Writer interface

type WriterAdapterOptions added in v0.0.3 

type WriterAdapterOptions struct {
	Callback func(i []byte)
	Split    []byte
}

WriterAdapterOptions represents WriterAdapter options

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.