processor

package
v0.0.0-...-3cea427 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 2, 2021 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Processor

type Processor struct {
	OnQuery func(ctx context.Context, q *click.Query) (*click.Query, error)
	OnMeta  func(ctx context.Context, m click.QueryMeta) (click.QueryMeta, error)

	OnSendBlock func(ctx context.Context, b *click.Block) (*click.Block, error)
	OnRecvBlock func(ctx context.Context, b *click.Block) (*click.Block, error)
	// contains filtered or unexported fields
}

func New

func New(cl click.ClientPool) *Processor

func (*Processor) Close

func (p *Processor) Close() (err error)

func (*Processor) Get

func (p *Processor) Get(ctx context.Context, opts ...click.ClientOption) (_ click.Client, err error)

func (*Processor) Put

func (p *Processor) Put(ctx context.Context, cl click.Client, err error) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL