encoder

Documentation

Index

• func NewHasher(c *models.Config, l interfaces.Logger, r interfaces.RequestQueue, ...) interfaces.Encoder
• func NewHasherFactory(p interfaces.ConfigProvider, l interfaces.Logger, r interfaces.RequestQueue, ...) interfaces.EncoderFactory
• type Hasher
  • func (e *Hasher) Start() error
• type HasherFactory
  • func (h *HasherFactory) GetNewEncoder() interfaces.Encoder

Functions

func NewHasher

func NewHasher(c *models.Config, l interfaces.Logger, r interfaces.RequestQueue, s interfaces.SubmissionQueue, cl interfaces.ClientStopQueue, w interfaces.Waiter, m *sync.Mutex) interfaces.Encoder

func NewHasherFactory

func NewHasherFactory(p interfaces.ConfigProvider, l interfaces.Logger, r interfaces.RequestQueue, s interfaces.SubmissionQueue, c interfaces.ClientStopQueue, w interfaces.Waiter) interfaces.EncoderFactory

Types

type Hasher

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

func (*Hasher) Start

func (e *Hasher) Start() error

type HasherFactory

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

func (*HasherFactory) GetNewEncoder

func (h *HasherFactory) GetNewEncoder() interfaces.Encoder