serializer

package
v1.5.3 Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2019 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// NoRetry always returns false independently of the number of retries.
	NoRetry = func(int) bool { return false }
)

Functions

This section is empty.

Types

type FunctionQueue

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

func NewFunctionQueue

func NewFunctionQueue(queueSize uint) *FunctionQueue

NewFunctionQueue returns a FunctionQueue that will be used to execute functions in the same order they are enqueued.

func (*FunctionQueue) Enqueue

func (fq *