stream

Documentation

Index

• type Option
  • func WithCallbackParallel(parallel int) Option
  • func WithFlushBatchSize(size int) Option
  • func WithFlushDelayTime(d time.Duration) Option
• type PendingID
• type PendingTask
• type Scheduler
  • func NewScheduler(e engine.Interface, opts ...Option) Scheduler
• type Stream

Types

type Option

type Option func(*config)

func WithCallbackParallel

func WithCallbackParallel(parallel int) Option

func WithFlushBatchSize

func WithFlushBatchSize(size int) Option

func WithFlushDelayTime

func WithFlushDelayTime(d time.Duration) Option

type PendingID

type PendingID interface{}

type PendingTask

type PendingTask interface {
	OnTimeout(pid PendingID)
}

type Scheduler

type Scheduler interface {
	Close()

	Register(z zone.Interface, wo int64, direct bool) Stream
	Unregister(s Stream)
}

func NewScheduler

func NewScheduler(e engine.Interface, opts ...Option) Scheduler

type Stream

type Stream interface {
	// Zone() zone.Interface
	WriteOffset() int64

	Append(r stdio.Reader, cb io.WriteCallback)
	Sync()
}