manager

Documentation

Index

• type AsyncQueryMsg
• type Option
  • func WithRangeOpts(opts engine.RangeOpts) Option
  • func WithSingleOpts(opts engine.SingleOpts) Option
  • func WithWrite(write bool) Option
• type QueryManager
  • func New(ctx context.Context, eg engine.Engine, opts ...Option) QueryManager
  • func (x *QueryManager) Cancel()
  • func (x *QueryManager) Query(str string) func() tea.Msg

Types

type AsyncQueryMsg

type AsyncQueryMsg struct {
	StartedAt time.Time
	Buffer    buffer.StreamBuffer
}

type Option

type Option func(*QueryManager)

func WithRangeOpts

func WithRangeOpts(opts engine.RangeOpts) Option

func WithSingleOpts

func WithSingleOpts(opts engine.SingleOpts) Option

func WithWrite

func WithWrite(write bool) Option

type QueryManager

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

func New

func New(ctx context.Context, eg engine.Engine, opts ...Option) QueryManager

func (*QueryManager) Cancel

func (x *QueryManager) Cancel()

func (*QueryManager) Query

func (x *QueryManager) Query(str string) func() tea.Msg