stream

Documentation

Index

• func NewChunker(ctx context.Context, source Source, setters ...Option) chunker.Chunker
• type Option
  • func Size(s int) Option
• type Options
• type Source
• type Stream
  • func (c *Stream) Read() <-chan []byte

Functions

func NewChunker

func NewChunker(ctx context.Context, source Source, setters ...Option) chunker.Chunker

NewChunker initializes a Chunker with default values.

Types

type Option

type Option func(*Options)

Option is the functional option func.

func Size

func Size(s int) Option

Size sets the chunk size of the Chunker.

type Options

type Options struct {
	Size int
}

Options is the functional options struct.

type Source

type Source interface {
	io.ReadCloser
}

Source is an interface describing the source of a Stream.

type Stream

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

Stream is a conecrete type that implements the chunker.Chunker interface.

func (*Stream) Read

func (c *Stream) Read() <-chan []byte

Read implements ChunkReader.