closing

Documentation

Index

• func NewSafeChanCloser() *safeChanCloser
• func NewShuffleOutCloser(minWaitDuration time.Duration, maxWaitDuration time.Duration, ...) (*shuffleOutCloser, error)
• type Closer
• type IntRandomizer

Functions

func NewSafeChanCloser

func NewSafeChanCloser() *safeChanCloser

NewSafeChanCloser returns a safe chan closer instance

func NewShuffleOutCloser

func NewShuffleOutCloser(
	minWaitDuration time.Duration,
	maxWaitDuration time.Duration,
	signalChan chan endProcess.ArgEndProcess,
	log core.Logger,
) (*shuffleOutCloser, error)

NewShuffleOutCloser creates a shuffle out component that is able to trigger a node restart and cancel that request if necessarily

Types

type Closer

type Closer interface {
	Close() error
}

Closer closes all stuff released by an object

type IntRandomizer

type IntRandomizer interface {
	Intn(n int) int
	IsInterfaceNil() bool
}

IntRandomizer interface provides functionality over generating integer numbers