astikit

Mar 13, 2026

Changes in this version

+ type WriteChainer struct

+ func NewWriteChainer(w io.Writer) *WriteChainer

+ func (c *WriteChainer) Write(fs ...WriteChainerFunc) (int, error)

+ type WriteChainerFunc func(w io.Writer) (int, error)

+ func WriteWithCondition(label string, b []byte, do bool) WriteChainerFunc

+ func WriteWithLabel(label string, b []byte) WriteChainerFunc

Nov 9, 2025

Changes in this version

type Translator

+ func (t *Translator) LanguageC(ctx context.Context) string

+ func (t *Translator) ParseAcceptLanguageHeader(header string) string

Jun 25, 2025

Changes in this version

+ func MinMaxInt(v, min, max int) int

May 7, 2025

Changes in this version

+ type BufferedBatcher struct

+ func NewBufferedBatcher(o BufferedBatcherOptions) *BufferedBatcher

+ func (bb *BufferedBatcher) Add(i any)

+ func (bb *BufferedBatcher) Start(ctx context.Context)

+ func (bb *BufferedBatcher) Stop()

+ type BufferedBatcherOnBatchFunc func(ctx context.Context, batch []any)

+ type BufferedBatcherOptions struct

+ OnBatch BufferedBatcherOnBatchFunc

Mar 31, 2025

Changes in this version

+ type HTTPSenderInvalidStatusCodeError struct

+ Err error

+ StatusCode int

+ func (err HTTPSenderInvalidStatusCodeError) Error() string

+ func (err HTTPSenderInvalidStatusCodeError) Is(target error) bool

Feb 16, 2025

Changes in this version

+ type Cache struct

+ func NewCache(o CacheOptions) *Cache

+ func (c *Cache) Delete(remove func(i CacheItem) bool)

+ func (c *Cache) Get(found func(i CacheItem) bool) (CacheItem, bool)

+ func (c *Cache) Set(i CacheItem)

+ type CacheItem interface

+ Size func() int

+ type CacheOptions struct

+ MaxSize int

Dec 3, 2024

Changes in this version

type HTTPSendJSONOptions

+ Context context.Context

Nov 29, 2024

Changes in this version

+ func DurationMinimalistFormat(d time.Duration) string

+ func MockNow(fn func() time.Time) io.Closer

+ func Now() time.Time

+ type Stopwatch struct

+ func NewStopwatch() *Stopwatch

+ func (s *Stopwatch) Done()

+ func (s *Stopwatch) Dump() string

+ func (s *Stopwatch) Duration() time.Duration

+ func (s *Stopwatch) FindChild(id string, nextIDs ...string) (*Stopwatch, bool)

+ func (s *Stopwatch) Merge(i *Stopwatch)

+ func (s *Stopwatch) NewChild(id string) *Stopwatch

+ func (s *Stopwatch) UnmarshalJSON(text []byte) error

+ func (s Stopwatch) MarshalJSON() ([]byte, error)

+ type TimestampNano struct

+ func NewTimestampNano(t time.Time) *TimestampNano

+ func (t *TimestampNano) UnmarshalJSON(text []byte) error

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

+ func (t TimestampNano) MarshalJSON() ([]byte, error)

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

Nov 24, 2024

Changes in this version

+ var RandSource = rand.NewSource(time.Now().UnixNano())

Nov 24, 2024

Changes in this version

+ const IpcCreate — darwin/amd64, js/wasm, linux/amd64

+ const IpcExclusive — darwin/amd64, js/wasm, linux/amd64

+ func NewSystemVKey(projectID int, path string) (int, error) — darwin/amd64, js/wasm, linux/amd64

+ type FIFOMutex struct

+ func (m *FIFOMutex) Lock()

+ func (m *FIFOMutex) Unlock()

type HTTPSendJSONOptions

+ Timeout time.Duration

+ type PosixSharedMemory struct — darwin/amd64, js/wasm, linux/amd64

+ func CreatePosixSharedMemory(name string, size int) (*PosixSharedMemory, error)

+ func OpenPosixSharedMemory(name string) (*PosixSharedMemory, error)

+ func (shm *PosixSharedMemory) Addr() unsafe.Pointer

+ func (shm *PosixSharedMemory) Close() error

+ func (shm *PosixSharedMemory) Name() string

+ func (shm *PosixSharedMemory) ReadBytes(size int) ([]byte, error)

+ func (shm *PosixSharedMemory) Size() int

+ func (shm *PosixSharedMemory) Write(src unsafe.Pointer, size int) error

+ func (shm *PosixSharedMemory) WriteBytes(b []byte) error

+ type PosixVariableSizeSharedMemoryReadOptions struct — darwin/amd64, js/wasm, linux/amd64

+ Name string

+ Size int

+ type PosixVariableSizeSharedMemoryReader struct — darwin/amd64, js/wasm, linux/amd64

+ func NewPosixVariableSizeSharedMemoryReader() *PosixVariableSizeSharedMemoryReader

+ func (r *PosixVariableSizeSharedMemoryReader) Close()

+ func (r *PosixVariableSizeSharedMemoryReader) ReadBytes(o PosixVariableSizeSharedMemoryReadOptions) (b []byte, err error)

+ type PosixVariableSizeSharedMemoryWriter struct — darwin/amd64, js/wasm, linux/amd64

+ func NewPosixVariableSizeSharedMemoryWriter(prefix string) *PosixVariableSizeSharedMemoryWriter

+ func (w *PosixVariableSizeSharedMemoryWriter) Close()

+ func (w *PosixVariableSizeSharedMemoryWriter) Write(src unsafe.Pointer, size int) (ro PosixVariableSizeSharedMemoryReadOptions, err error)

+ func (w *PosixVariableSizeSharedMemoryWriter) WriteBytes(b []byte) (PosixVariableSizeSharedMemoryReadOptions, error)

+ type SystemVSemaphore struct — darwin/amd64, js/wasm, linux/amd64

+ func CreateSystemVSemaphore(key, flags int) (*SystemVSemaphore, error)

+ func OpenSystemVSemaphore(key int) (*SystemVSemaphore, error)

+ func (s *SystemVSemaphore) Close() error

+ func (s *SystemVSemaphore) Key() int

+ func (s *SystemVSemaphore) Lock() error

+ func (s *SystemVSemaphore) Unlock() error

+ type SystemVSemaphoredSharedMemoryReadOptions struct — darwin/amd64, js/wasm, linux/amd64

+ SemaphoreKey int

+ SharedMemoryAt int64

+ SharedMemoryKey int

+ Size int

+ type SystemVSemaphoredSharedMemoryReader struct — darwin/amd64, js/wasm, linux/amd64

+ func NewSystemVSemaphoredSharedMemoryReader() *SystemVSemaphoredSharedMemoryReader

+ func (r *SystemVSemaphoredSharedMemoryReader) Close()

+ func (r *SystemVSemaphoredSharedMemoryReader) ReadBytes(o *SystemVSemaphoredSharedMemoryReadOptions) (b []byte, err error)

+ type SystemVSemaphoredSharedMemoryWriter struct — darwin/amd64, js/wasm, linux/amd64

+ func NewSystemVSemaphoredSharedMemoryWriter() *SystemVSemaphoredSharedMemoryWriter

+ func (w *SystemVSemaphoredSharedMemoryWriter) Close()

+ func (w *SystemVSemaphoredSharedMemoryWriter) Write(src unsafe.Pointer, size int) (ro *SystemVSemaphoredSharedMemoryReadOptions, err error)

+ func (w *SystemVSemaphoredSharedMemoryWriter) WriteBytes(b []byte) (*SystemVSemaphoredSharedMemoryReadOptions, error)

+ type SystemVSharedMemory struct — darwin/amd64, js/wasm, linux/amd64

+ func CreateSystemVSharedMemory(key, size, flags int) (*SystemVSharedMemory, error)

+ func OpenSystemVSharedMemory(key int) (*SystemVSharedMemory, error)

+ func (shm *SystemVSharedMemory) Addr() unsafe.Pointer

+ func (shm *SystemVSharedMemory) Close() error

+ func (shm *SystemVSharedMemory) Key() int

+ func (shm *SystemVSharedMemory) ReadBytes(size int) ([]byte, error)

+ func (shm *SystemVSharedMemory) Write(src unsafe.Pointer, size int) error

+ func (shm *SystemVSharedMemory) WriteBytes(b []byte) error

Nov 16, 2024

Changes in this version

type SemaphoredSharedMemoryReadOptions — darwin/amd64, js/wasm, linux/amd64

+ SharedMemoryAt int64

Nov 5, 2024

Changes in this version

type Semaphore — darwin/amd64, js/wasm, linux/amd64

+ func CreateSemaphore(key, flags int) (*Semaphore, error)

+ func OpenSemaphore(key int) (*Semaphore, error)

+ type SemaphoredSharedMemoryReadOptions struct — darwin/amd64, js/wasm, linux/amd64

+ SemaphoreKey int

+ SharedMemoryKey int

+ Size int

+ type SemaphoredSharedMemoryReader struct — darwin/amd64, js/wasm, linux/amd64

+ func NewSemaphoredSharedMemoryReader() *SemaphoredSharedMemoryReader

+ func (r *SemaphoredSharedMemoryReader) Close()

+ func (r *SemaphoredSharedMemoryReader) ReadBytes(o *SemaphoredSharedMemoryReadOptions) (b []byte, err error)

+ type SemaphoredSharedMemoryWriter struct — darwin/amd64, js/wasm, linux/amd64

+ func NewSemaphoredSharedMemoryWriter(id string) *SemaphoredSharedMemoryWriter

+ func (w *SemaphoredSharedMemoryWriter) Close()

+ func (w *SemaphoredSharedMemoryWriter) Write(src unsafe.Pointer, size int) (ro *SemaphoredSharedMemoryReadOptions, err error)

+ func (w *SemaphoredSharedMemoryWriter) WriteBytes(b []byte) (*SemaphoredSharedMemoryReadOptions, error)

Oct 15, 2024

Changes in this version

type PiperOptions

+ ReadTimeoutError error

May 10, 2024

Changes in this version

+ const IpcFlagCreat — darwin/amd64, js/wasm, linux/amd64

+ const IpcFlagExcl — darwin/amd64, js/wasm, linux/amd64

+ var ErrPiperReadTimeout = errors.New("astikit: piper read timeout")

+ func NewSystemVIpcKey(projectID int, path string) (int, error) — darwin/amd64, js/wasm, linux/amd64

+ type Piper struct

+ func NewPiper(o PiperOptions) *Piper

+ func (p *Piper) Close() error

+ func (p *Piper) Read(i []byte) (n int, err error)

+ func (p *Piper) Write(i []byte) (n int, err error)

+ type PiperOptions struct

+ EOFError error

+ ReadTimeout PiperReadTimeoutOptions

+ type PiperReadTimeoutOptions struct

+ Duration time.Duration

+ Error error

+ type Semaphore struct — darwin/amd64, js/wasm, linux/amd64

+ func NewSemaphore(key, flags int) (*Semaphore, error)

+ func (s *Semaphore) Close() error

+ func (s *Semaphore) Key() int

+ func (s *Semaphore) Lock() error

+ func (s *Semaphore) Unlock() error

+ type SharedMemory struct — darwin/amd64, js/wasm, linux/amd64

+ func CreateSharedMemory(key, size, flags int) (*SharedMemory, error)

+ func OpenSharedMemory(key int) (*SharedMemory, error)

+ func (w *SharedMemory) Close() error

+ func (w *SharedMemory) Key() int

+ func (w *SharedMemory) Pointer() unsafe.Pointer

+ func (w *SharedMemory) ReadBytes(size int) ([]byte, error)

+ func (w *SharedMemory) Write(src unsafe.Pointer, size int) error

+ func (w *SharedMemory) WriteBytes(b []byte) error

Oct 3, 2023

Changes in this version

+ func SortUint64(a []uint64)

+ type BitFlags uint64

+ func (fs BitFlags) Add(f uint64) uint64

+ func (fs BitFlags) Del(f uint64) uint64

+ func (fs BitFlags) Has(f uint64) bool

type EventManager

+ func (m *EventManager) Off(id uint64)

+ type SortUint64Slice []uint64

+ func (p SortUint64Slice) Len() int

+ func (p SortUint64Slice) Less(i, j int) bool

+ func (p SortUint64Slice) Swap(i, j int)

Sep 29, 2023

Changes in this version

+ type EventHandler func(payload interface{}) (delete bool)

+ type EventManager struct

+ func NewEventManager() *EventManager

+ func (m *EventManager) Emit(n EventName, payload interface{})

+ func (m *EventManager) On(n EventName, h EventHandler)

+ type EventName string

May 28, 2023

Changes in this version

type Errors

+ func (errs *Errors) Is(target error) bool

Apr 5, 2023

Changes in this version

+ func UInt16Ptr(i uint16) *uint16

Jan 15, 2023

Changes in this version

+ type DebugMutex struct

+ func NewDebugMutex(name string, l StdLogger, opts ...DebugMutexOpt) *DebugMutex

+ func (m *DebugMutex) Lock()

+ func (m *DebugMutex) RLock()

+ func (m *DebugMutex) RUnlock()

+ func (m *DebugMutex) Unlock()

+ type DebugMutexOpt func(m *DebugMutex)

+ func DebugMutexWithDeadlockDetection(timeout time.Duration) DebugMutexOpt

+ func DebugMutexWithLockLogging(ll LoggerLevel) DebugMutexOpt

type HTTPSendJSONOptions

+ Host string

Nov 16, 2022

Changes in this version

+ type AtomicDuration struct

+ func NewAtomicDuration(d time.Duration) *AtomicDuration

+ func (d *AtomicDuration) Add(delta time.Duration)

+ func (d *AtomicDuration) Duration() time.Duration

+ type AtomicDurationAvgStat struct

+ func NewAtomicDurationAvgStat(d *AtomicDuration, count *uint64) *AtomicDurationAvgStat

+ func (s *AtomicDurationAvgStat) Value(_ time.Duration) interface{}

+ type AtomicDurationPercentageStat struct

+ func NewAtomicDurationPercentageStat(d *AtomicDuration) *AtomicDurationPercentageStat

+ func (s *AtomicDurationPercentageStat) Value(d time.Duration) interface{}

+ type AtomicUint64RateStat struct

+ func NewAtomicUint64RateStat(v *uint64) *AtomicUint64RateStat

+ func (s *AtomicUint64RateStat) Value(d time.Duration) interface{}

type Chan

+ func (c *Chan) StatOptions() []StatOptions

+ type ChanStats struct

+ WorkDuration time.Duration

+ type StatValuerFunc func(d time.Duration) interface

+ func (f StatValuerFunc) Value(d time.Duration) interface{}

Nov 12, 2022

Changes in this version

+ func UInt64Ptr(i uint64) *uint64

Oct 13, 2022

Changes in this version

+ type SeverityWriteCtxLogger interface

+ WriteC func(ctx context.Context, l LoggerLevel, v ...interface{})

+ WriteCf func(ctx context.Context, l LoggerLevel, format string, v ...interface{})

+ type SeverityWriteLogger interface

+ Write func(l LoggerLevel, v ...interface{})

+ Writef func(l LoggerLevel, format string, v ...interface{})

Oct 13, 2022

Changes in this version

+ type LoggerLevel int

+ const LoggerLevelDebug

+ const LoggerLevelError

+ const LoggerLevelFatal

+ const LoggerLevelInfo

+ const LoggerLevelWarn

+ func LoggerLevelFromString(s string) LoggerLevel

+ func (l *LoggerLevel) UnmarshalText(b []byte) error

+ func (l LoggerLevel) MarshalText() ([]byte, error)

+ func (l LoggerLevel) String() string

Oct 11, 2022

Changes in this version

+ type CounterStat struct

+ func NewCounterStat() *CounterStat

+ func (s *CounterStat) Add(delta float64)

+ func (s *CounterStat) Value() interface{}

type StatOptions

+ Valuer interface{}

+ type StatValuer interface

+ Value func() interface{}

+ type StatValuerOverTime interface

+ Value func(delta time.Duration) interface{}

Oct 6, 2022

Changes in this version

type Translator

+ func (t *Translator) TranslateC(ctx context.Context, key string) string

+ func (t *Translator) TranslateCf(ctx context.Context, key string, args ...interface{}) string

+ func (t *Translator) Translatef(language, key string, args ...interface{}) string

Sep 29, 2022

Changes in this version

+ func BoolToUInt32(b bool) uint32

Mar 10, 2022

Changes in this version

+ type HTTPSenderStatusCodeFunc func(code int) error

Mar 10, 2022

Changes in this version

+ func HTTPSenderDefaultStatusCodeFunc(code int) error

type HTTPSendJSONOptions

+ StatusCodeFunc func(code int) error

Feb 13, 2022

Changes in this version

+ type CloseFuncWithError func() error

type Closer

+ func (c *Closer) AddWithError(f CloseFuncWithError)

Feb 12, 2022

Changes in this version

+ type CloseWithoutErrorFunc func()

Feb 12, 2022

Changes in this version

type Closer

+ func (c *Closer) AddWithoutError(f func())

Jan 28, 2022

Changes in this version

type HTTPSendJSONOptions

+ HeadersIn map[string]string

+ HeadersOut HTTPSenderHeaderFunc

+ type HTTPSenderHeaderFunc func(h http.Header)

Jan 13, 2022

Changes in this version

type TranslatorOptions

+ ValidLanguages []string

Jan 8, 2022

Changes in this version

type CompleteLogger

+ func AdaptTestLogger(i TestLogger) CompleteLogger

+ type TestLogger interface

+ Error func(v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Fatal func(v ...interface{})

+ Fatalf func(format string, v ...interface{})

+ Log func(v ...interface{})

+ Logf func(format string, v ...interface{})

Dec 14, 2021

Changes in this version

type Closer

+ func (c *Closer) IsClosed() bool

+ func (c *Closer) OnClosed(fn CloserOnClosed)

+ type CloserOnClosed func(err error)

Oct 6, 2021

Changes in this version

+ func JSONClone(src, dst interface{}) (err error)

+ func JSONEqual(a, b interface{}) bool

type Closer

+ func (c *Closer) Append(dst *Closer)

May 4, 2021

Changes in this version

type Closer

+ func (c *Closer) Do(fn func())

Mar 27, 2021

Changes in this version

type BytesIterator

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

Mar 24, 2021

Changes in this version

type BitsWriter

+ func (w *BitsWriter) WriteBytesN(bs []byte, n int, padByte uint8) error

type BitsWriterBatch

+ func (b *BitsWriterBatch) WriteBytesN(bs []byte, n int, padByte uint8)

Mar 3, 2021

Changes in this version

+ func TimePtr(i time.Time) *time.Time

type BitsWriter

+ func (w *BitsWriter) SetWriteCallback(cb BitsWriterWriteCallback)

type BitsWriterOptions

+ WriteCallback BitsWriterWriteCallback

+ type BitsWriterWriteCallback func([]byte)

Feb 3, 2021

Changes in this version

+ type BitsWriterBatch struct

+ func NewBitsWriterBatch(w *BitsWriter) BitsWriterBatch

+ func (b *BitsWriterBatch) Err() error

+ func (b *BitsWriterBatch) Write(i interface{})

+ func (b *BitsWriterBatch) WriteN(i interface{}, n int)

Jan 16, 2021

Changes in this version

type HTTPMiddleware

+ func HTTPMiddlewareCORSHeaders() HTTPMiddleware

Jan 14, 2021

Changes in this version

+ func StrSlicePtr(i []string) *[]string

Nov 21, 2020

Changes in this version

type Chan

+ func (c *Chan) Stats() []StatOptions

+ type StatOptions struct

+ Handler StatHandler

+ Metadata *StatMetadata

+ type StatValue struct

+ Value interface{}

type Stater

+ func (s *Stater) AddStats(os ...StatOptions)

+ func (s *Stater) DelStats(os ...StatOptions)

Oct 28, 2020

Changes in this version

type SeverityCtxLogger

+ FatalC func(ctx context.Context, v ...interface{})

+ FatalCf func(ctx context.Context, format string, v ...interface{})

+ WarnC func(ctx context.Context, v ...interface{})

+ WarnCf func(ctx context.Context, format string, v ...interface{})

type SeverityLogger

+ Warn func(v ...interface{})

+ Warnf func(format string, v ...interface{})

type StdLogger

+ Fatal func(v ...interface{})

+ Fatalf func(format string, v ...interface{})

Oct 22, 2020

Changes in this version

+ const StatNameWorkRatio

+ var ErrHTTPSenderUnmarshaledError = errors.New("astikit: unmarshaled error")

type BiMap

+ func (m *BiMap) MustGet(k interface{}) interface{}

+ func (m *BiMap) MustGetInverse(k interface{}) interface{}

+ type HTTPSendJSONOptions struct

+ BodyError interface{}

+ BodyIn interface{}

+ BodyOut interface{}

+ Headers map[string]string

+ Method string

+ URL string

type HTTPSender

+ func (s *HTTPSender) SendJSON(o HTTPSendJSONOptions) (err error)

Sep 27, 2020

Changes in this version

+ const StatNameWaitRatio

Sep 27, 2020

Changes in this version

type StatMetadata

+ Name string

May 24, 2020

Changes in this version

+ type CounterRateStat struct

+ func NewCounterRateStat() *CounterRateStat

+ func (s CounterRateStat) Add(delta float64)

+ func (s CounterRateStat) Start()

+ func (s CounterRateStat) Stop()

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

May 2, 2020

Changes in this version

type SignalHandler

+ func LoggerSignalHandler(l SeverityLogger, ignoredSignals ...os.Signal) SignalHandler

Mar 9, 2020

Changes in this version

type HTTPSender

+ func (s *HTTPSender) SendWithTimeout(req *http.Request, timeout time.Duration) (resp *http.Response, err error)

type HTTPSenderOptions

+ Timeout time.Duration

Feb 22, 2020

Changes in this version

type Translator

+ func (t *Translator) LanguageCtx(ctx context.Context) string

Feb 3, 2020

Changes in this version

+ type Translator struct

+ func NewTranslator(o TranslatorOptions) *Translator

+ func (t *Translator) HTTPMiddleware(h http.Handler) http.Handler

+ func (t *Translator) ParseDir(dirPath string) (err error)

+ func (t *Translator) ParseFile(path string) (err error)

+ func (t *Translator) Translate(language, key string) string

+ func (t *Translator) TranslateCtx(ctx context.Context, key string) string

+ type TranslatorOptions struct

+ DefaultLanguage string

Jan 7, 2020

Changes in this version

+ func ErrorCause(err error) error

Jan 6, 2020

Changes in this version

+ type CompleteLogger interface

+ type RWMutex struct

+ func NewRWMutex(o RWMutexOptions) *RWMutex

+ func (m *RWMutex) IsDeadlocked(timeout time.Duration) (bool, string)

+ func (m *RWMutex) Lock()

+ func (m *RWMutex) RLock()

+ func (m *RWMutex) RUnlock()

+ func (m *RWMutex) Unlock()

+ type RWMutexOptions struct

+ Logger StdLogger

+ Name string

+ type SeverityCtxLogger interface

+ DebugC func(ctx context.Context, v ...interface{})

+ DebugCf func(ctx context.Context, format string, v ...interface{})

+ ErrorC func(ctx context.Context, v ...interface{})

+ ErrorCf func(ctx context.Context, format string, v ...interface{})

+ InfoC func(ctx context.Context, v ...interface{})

+ InfoCf func(ctx context.Context, format string, v ...interface{})

Jan 2, 2020

Changes in this version

+ type Eventer struct

+ func NewEventer(o EventerOptions) *Eventer

+ func (e *Eventer) Dispatch(name string, payload interface{})

+ func (e *Eventer) On(name string, h EventerHandler)

+ func (e *Eventer) Reset()

+ func (e *Eventer) Start(ctx context.Context)

+ func (e *Eventer) Stop()

+ type EventerHandler func(payload interface{})

+ type EventerOptions struct

+ Chan ChanOptions

Jan 2, 2020

Changes in this version

type FlagStrings

+ Map map[string]bool

+ Slice *[]string

Jan 2, 2020

Changes in this version

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

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

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

+ func PadCut(p *bytesPadder)

+ func PadLeft(p *bytesPadder)

+ func PadRight(p *bytesPadder)

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

+ type BiMap struct

+ func NewBiMap() *BiMap

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

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

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

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

+ type PadOption func(p *bytesPadder)

Dec 31, 2019

Changes in this version

+ type BitsWriter struct

+ func NewBitsWriter(o BitsWriterOptions) (w *BitsWriter)

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

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

+ type BitsWriterOptions struct

+ ByteOrder binary.ByteOrder

+ Writer io.Writer

+ type BytesIterator struct

+ func NewBytesIterator(bs []byte) *BytesIterator

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

+ func (i *BytesIterator) HasBytesLeft() bool

+ func (i *BytesIterator) Len() int

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

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

+ func (i *BytesIterator) Offset() int

+ func (i *BytesIterator) Seek(n int)

+ func (i *BytesIterator) Skip(n int)

+ type FlagStrings map[string]bool

+ func NewFlagStrings() FlagStrings

+ func (f FlagStrings) Set(i string) error

+ func (f FlagStrings) String() string

Dec 30, 2019

Changes in this version

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

Dec 30, 2019

Changes in this version

+ var DefaultDirMode os.FileMode = 0755

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

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

Dec 30, 2019

Changes in this version

+ func SortInt64(a []int64)

+ type BufferPool struct

+ func NewBufferPool() *BufferPool

+ func (p *BufferPool) New() *BufferPoolItem

+ type BufferPoolItem struct

+ func (i *BufferPoolItem) Close() error

+ type GoroutineLimiter struct

+ func NewGoroutineLimiter(o GoroutineLimiterOptions) (l *GoroutineLimiter)

+ func (l *GoroutineLimiter) Close() error

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

+ type GoroutineLimiterFunc func()

+ type GoroutineLimiterOptions struct

+ Max int

+ type HTTPDownloader struct

+ func NewHTTPDownloader(o HTTPDownloaderOptions) (d *HTTPDownloader)

+ func (d *HTTPDownloader) Close() error

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

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

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

+ type HTTPDownloaderOptions struct

+ Limiter GoroutineLimiterOptions

+ ResponseFunc HTTPResponseFunc

+ Sender HTTPSenderOptions

+ type HTTPDownloaderSrc struct

+ Body io.Reader

+ Header http.Header

+ Method string

+ URL string

+ type HTTPResponseFunc func(resp *http.Response) error

+ type SortInt64Slice []int64

+ func (p SortInt64Slice) Len() int

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

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

Dec 28, 2019

Changes in this version

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

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

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

+ func NopCloser(w io.Writer) io.WriteCloser

+ func RandStr(n int) string

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

+ func SSHCopyFileFunc(fn SSHSessionFunc) CopyFileFunc

+ type CtxReader struct

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

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

type HTTPMiddleware

+ func HTTPMiddlewareHeaders(vs map[string]string) HTTPMiddleware

+ type SSHSession interface

+ Run func(string) error

+ Start func(string) error

+ StdinPipe func() (io.WriteCloser, error)

+ Wait func() error

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

Dec 27, 2019

Changes in this version

+ const ChanAddStrategyBlockWhenStarted

+ const ChanAddStrategyNoBlock

+ const ChanOrderFIFO

+ const ChanOrderFILO

+ func FlagCmd() (o string)

type Chan

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

type ChanOptions

+ AddStrategy string

+ type CloseFunc func() error

+ type Closer struct

+ func NewCloser() *Closer

+ func (c *Closer) Add(f CloseFunc)

+ func (c *Closer) Close() error

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

+ type CounterAvgStat struct

+ func NewCounterAvgStat() *CounterAvgStat

+ func (s CounterAvgStat) Add(delta float64)

+ func (s CounterAvgStat) Start()

+ func (s CounterAvgStat) Stop()

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

+ type DurationPercentageStat struct

+ func NewDurationPercentageStat() *DurationPercentageStat

+ func (s DurationPercentageStat) Begin()

+ func (s DurationPercentageStat) End()

+ func (s DurationPercentageStat) Start()

+ func (s DurationPercentageStat) Stop()

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

+ type Errors struct

+ func NewErrors(errs ...error) *Errors

+ func (errs *Errors) Add(err error)

+ func (errs *Errors) Error() string

+ func (errs *Errors) IsNil() bool

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

+ type HTTPClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ type HTTPSender struct

+ func NewHTTPSender(o HTTPSenderOptions) (s *HTTPSender)

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

+ type HTTPSenderOptions struct

+ Client HTTPClient

+ Logger StdLogger

+ RetryFunc HTTPSenderRetryFunc

+ RetryMax int

+ RetrySleep time.Duration

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

+ type Rational struct

+ func NewRational(num, den int) *Rational

+ func (r *Rational) Den() int

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

+ func (r *Rational) Num() int

+ func (r *Rational) ToFloat64() float64

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

+ type SeverityLogger interface

+ Debug func(v ...interface{})

+ Debugf func(format string, v ...interface{})

+ Error func(v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Info func(v ...interface{})

+ Infof func(format string, v ...interface{})

+ func AdaptStdLogger(i StdLogger) SeverityLogger

+ type Stat struct

+ Value interface{}

+ type StatHandler interface

+ Start func()

+ Stop func()

+ Value func(delta time.Duration) interface{}

+ type StatMetadata struct

+ Description string

+ Label string

+ Unit string

+ type Stater struct

+ func NewStater(o StaterOptions) *Stater

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

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

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

+ func (s *Stater) Stop()

+ type StaterOptions struct

+ HandleFunc StatsHandleFunc

+ Period time.Duration

+ type StatsHandleFunc func(stats []Stat)

+ type StdLogger interface

+ Print func(v ...interface{})

+ Printf func(format string, v ...interface{})

Dec 24, 2019

Changes in this version

+ const ChanFIFOOrder

+ const ChanFILOOrder

+ func BoolPtr(i bool) *bool

+ func BytePtr(i byte) *byte

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

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

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

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

+ func Float64Ptr(i float64) *float64

+ func Int64Ptr(i int64) *int64

+ func IntPtr(i int) *int

+ func PCMLevel(samples []int) float64

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

+ func StrPtr(i string) *string

+ func UInt32Ptr(i uint32) *uint32

+ func UInt8Ptr(i uint8) *uint8

+ type Chan struct

+ func NewChan(o ChanOptions) *Chan

+ func (c *Chan) Add(fn func())

+ func (c *Chan) Reset()

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

+ func (c *Chan) Stop()

+ type ChanOptions struct

+ Order string

+ ProcessAll bool

+ type HTTPMiddleware func(http.Handler) http.Handler

+ func HTTPMiddlewareBasicAuth(username, password string) HTTPMiddleware

+ func HTTPMiddlewareContentType(contentType string) HTTPMiddleware

+ type Limiter struct

+ func NewLimiter() *Limiter

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

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

+ func (l *Limiter) Close()

+ type LimiterBucket struct

+ func (b *LimiterBucket) Close()

+ func (b *LimiterBucket) Inc() bool

type Logger

+ Debug func(v ...interface{})

+ Errorf func(format string, v ...interface{})

+ type PCMChannelsConverter struct

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

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

+ func (c *PCMChannelsConverter) Reset()

+ type PCMSampleFunc func(s int) error

+ type PCMSampleRateConverter struct

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

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

+ func (c *PCMSampleRateConverter) Reset()

+ type PCMSilenceDetector struct

+ func NewPCMSilenceDetector(o PCMSilenceDetectorOptions) (d *PCMSilenceDetector)

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

+ func (d *PCMSilenceDetector) Reset()

+ type PCMSilenceDetectorOptions struct

+ MaxSilenceLevel float64

+ MinSilenceDuration time.Duration

+ SampleRate int

+ StepDuration time.Duration

+ type Templater struct

+ func NewTemplater() *Templater

+ func (t *Templater) AddLayout(c string)

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

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

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

+ func (t *Templater) DelTemplate(path string)

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

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

+ type WorkerOptions struct

+ Logger Logger

+ type WriterAdapter struct

+ func NewWriterAdapter(o WriterAdapterOptions) *WriterAdapter

+ func (w *WriterAdapter) Close()

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

+ type WriterAdapterOptions struct

+ Callback func(i []byte)

+ Split []byte

Dec 23, 2019

Changes in this version

+ const ExecStatusCrashed

+ const ExecStatusRunning

+ const ExecStatusStopped

+ func ServeHTTP(w *Worker, o ServeHTTPOptions)

+ type ExecCmdOptions struct

+ Args []string

+ CmdAdapter func(cmd *exec.Cmd, h *ExecHandler) error

+ Name string

+ StopFunc func(cmd *exec.Cmd) error

+ type ExecHandler struct

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

+ func (h *ExecHandler) Status() string

+ func (h *ExecHandler) Stop()

+ type Logger interface

+ Debugf func(format string, v ...interface{})

+ Error func(v ...interface{})

+ Info func(v ...interface{})

+ Infof func(format string, v ...interface{})

+ type ServeHTTPOptions struct

+ Addr string

+ Handler http.Handler

+ type SignalHandler func(s os.Signal)

+ func TermSignalHandler(f func()) SignalHandler

+ type Task struct

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

+ func (t *Task) Done()

+ func (t *Task) NewSubTask() *Task

+ func (t *Task) Wait()

+ type TaskFunc func() *Task

+ type Worker struct

+ func NewWorker(l Logger) (w *Worker)

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

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

+ func (w *Worker) Logger() Logger

+ func (w *Worker) NewTask() *Task

+ func (w *Worker) Stop()

+ func (w *Worker) Wait()

Dec 23, 2019

Changes in this version

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

+ type Timestamp struct

+ func NewTimestamp(t time.Time) *Timestamp

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

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

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

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