window

Documentation

Index

• type Acceptor
• type CountAggregator
  • func (ca *CountAggregator) Accept(ctx context.Context, input interface{}) (err error)
  • func (ca *CountAggregator) Reset(whiteboard Whiteboard)
• type DurationTrigger
  • func (trigger *DurationTrigger) Accept(ctx context.Context, input interface{}) (err error)
  • func (trigger *DurationTrigger) Reset(whiteboard Whiteboard)
• type EmptyAggregator
  • func (agg EmptyAggregator) Accept(ctx context.Context, input interface{}) (err error)
  • func (agg EmptyAggregator) Materialize(ctx context.Context) error
  • func (agg EmptyAggregator) Reset(whiteboard Whiteboard)
• type Materializer
• type MaterializerWrapper
• type Trigger
  • func (tm *Trigger) ResetTrigger()
  • func (tm *Trigger) Trigger()
  • func (tm *Trigger) Triggered() bool
• type Whiteboard
• type Window
  • func New(ag Acceptor, materializer Materializer, wraps ...Wrapper) *Window
  • func (w *Window) Accept(ctx context.Context, input interface{}) error
  • func (w *Window) CloseWithContext(ctx context.Context) error
  • func (w *Window) Closed() <-chan struct{}
  • func (w *Window) Current(ctx context.Context) (Whiteboard, bool)
  • func (w *Window) WaitUntilOk(ctx context.Context) error
• type Wrapper
  • func CounterWrapper(maxCount uint64) Wrapper
  • func DurationWrapper(duration time.Duration) Wrapper

Types

type Acceptor

type Acceptor interface {
	Accept(ctx context.Context, input interface{}) (err error)
	Reset(whiteboard Whiteboard)
}

type CountAggregator

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

func (*CountAggregator) Accept

func (ca *CountAggregator) Accept(ctx context.Context, input interface{}) (err error)

func (*CountAggregator) Reset

func (ca *CountAggregator) Reset(whiteboard Whiteboard)

type DurationTrigger

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

func (*DurationTrigger) Accept

func (trigger *DurationTrigger) Accept(ctx context.Context, input interface{}) (err error)

func (*DurationTrigger) Reset

func (trigger *DurationTrigger) Reset(whiteboard Whiteboard)

type EmptyAggregator

type EmptyAggregator struct{}

func (EmptyAggregator) Accept

func (agg EmptyAggregator) Accept(ctx context.Context, input interface{}) (err error)

func (EmptyAggregator) Materialize

func (agg EmptyAggregator) Materialize(ctx context.Context) error

func (EmptyAggregator) Reset

func (agg EmptyAggregator) Reset(whiteboard Whiteboard)

type Materializer

type Materializer interface {
	Materialize(ctx context.Context) error
}

type MaterializerWrapper

type MaterializerWrapper func(Materializer) Materializer

type Trigger

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

func (*Trigger) ResetTrigger

func (tm *Trigger) ResetTrigger()

func (*Trigger) Trigger

func (tm *Trigger) Trigger()

func (*Trigger) Triggered

func (tm *Trigger) Triggered() bool

type Whiteboard

type Whiteboard struct {
	StartTime time.Time
	Seq       uint64
	Trigger   *Trigger
	Err       error
	// contains filtered or unexported fields
}

type Window

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

func New

func New(ag Acceptor, materializer Materializer, wraps ...Wrapper) *Window

func (*Window) Accept

func (w *Window) Accept(ctx context.Context, input interface{}) error

func (*Window) CloseWithContext

func (w *Window) CloseWithContext(ctx context.Context) error

func (*Window) Closed

func (w *Window) Closed() <-chan struct{}

func (*Window) Current

func (w *Window) Current(ctx context.Context) (Whiteboard, bool)

func (*Window) WaitUntilOk

func (w *Window) WaitUntilOk(ctx context.Context) error

type Wrapper

type Wrapper func(Acceptor) Acceptor

func CounterWrapper

func CounterWrapper(maxCount uint64) Wrapper

func DurationWrapper

func DurationWrapper(duration time.Duration) Wrapper