Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChunkRunner ¶
type ChunkRunner struct {
// contains filtered or unexported fields
}
ChunkRunner executes Chunk tasks
func NewChunkRunner ¶
func NewChunkRunner( handlerName string, clientset versioned.Interface, sharedInformerFactory externalversions.SharedInformerFactory, ) *ChunkRunner
NewChunkRunner creates a new Runner instance
func (*ChunkRunner) Release ¶
func (r *ChunkRunner) Release(ctx context.Context) error
Release releases the current held chunk
type ReadCount ¶
type ReadCount struct {
// contains filtered or unexported fields
}
ReadCount tracks the number of bytes read through an io.Reader
func NewReadCount ¶
NewReadCount returns a new ReadCount that wraps the given reader
Source Files
Click to show internal directories.
Click to hide internal directories.