util

Documentation

Index

• func NewSaltingWriter(w io.Writer, salt []byte) io.Writer
• func SaltXOR(data, salt []byte) []byte
• func SaltXOROffset(data, salt []byte, off int) (result []byte)
• type SyncWorkerPool
  • func (SyncWorkerPool) Submit(fn func()) error
• type WorkerPool

Functions

func NewSaltingWriter

func NewSaltingWriter(w io.Writer, salt []byte) io.Writer

NewSaltingWriter returns io.Writer instance that applies salt to written data and write the result to w.

func SaltXOR

func SaltXOR(data, salt []byte) []byte

SaltXOR xors bits of data with salt repeating salt if necessary.

func SaltXOROffset

func SaltXOROffset(data, salt []byte, off int) (result []byte)

SaltXOROffset xors bits of data with salt starting from off byte repeating salt if necessary.

Types

type SyncWorkerPool

type SyncWorkerPool struct{}

SyncWorkerPool represents synchronous worker pool.

func (SyncWorkerPool) Submit

func (SyncWorkerPool) Submit(fn func()) error

Submit executes passed function immediately.

Always returns nil.

type WorkerPool

type WorkerPool interface {
	// Submit queues a function for execution
	// in a separate routine.
	//
	// Implementation must return any error encountered
	// that prevented the function from being queued.
	Submit(func()) error
}

WorkerPool represents the tool for control the execution of go-routine pool.