driver

type Cfg interface {
	Driver() string
}

type Conn interface {
	Apply(ctx context.Context, key string, mut Mutation) error
	Drain(ctx context.Context, keys []string, sink Sink) error
}

type Driver interface {
	Open(name string, cfg Cfg) (Conn, error)
}

type Mutation func(window.State) error

type ReadWriter interface {
	DelSpan(s window.Span) error
	PutSpan(s window.Span, vs []interface{}) error
	Windows() (map[window.Span][]interface{}, error)
}

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

type Sink func(ctx context.Context, span window.Span, key string, vs []interface{}) error