aqdispatch

Aug 14, 2023

Changes in this version

type Config

+ RequestKeyBlob string

+ ResponseKeyBlob string

+ type DoFunc func(context.Context, io.Writer, *Task) (io.Reader, error)

May 24, 2022

Changes in this version

type Config

+ Correlation string

Mar 4, 2022

Changes in this version

type Dispatcher

+ func (di *Dispatcher) PurgeExpired(ctx context.Context) error

Aug 19, 2021

retracted

Changes in this version

+ var ErrAnswer = errors.New("answer send error")

May 5, 2021

Changes in this version

type Dispatcher

+ func (di *Dispatcher) Run(ctx context.Context, taskNames []string) error

May 5, 2021

Changes in this version

+ var ErrEmpty = errors.New("empty")

+ var ErrExit = errors.New("exit")

+ var ErrSkipResponse = errors.New("skip response")

+ var ErrUnknownCommand = errors.New("unknown command")

+ type Config struct

+ Concurrency int

+ Debug log.Logger

+ DisQMaxFileSize int64

+ DisQMaxMsgSize int32

+ DisQMinMsgSize int32

+ DisQPath string

+ DisQPrefix string

+ DisQSyncEvery int64

+ DisQSyncTimeout time.Duration

+ Enc encoding.Encoding

+ PipeTimeout time.Duration

+ QueueCount int

+ RequestKeyName string

+ RequestKeyPayload string

+ ResponseKeyErrMsg string

+ ResponseKeyPayload string

+ Timeout time.Duration

+ type Dispatcher struct

+ Timezone *time.Location

+ func New(db *sql.DB, conf Config, inQName, inQType string, ...) (*Dispatcher, error)

+ func (di *Dispatcher) Batch(ctx context.Context) error

+ func (di *Dispatcher) Close() error

+ func (di *Dispatcher) Consume(ctx context.Context, nm string) error

+ func (di *Dispatcher) Decode(p []byte) string

+ func (di *Dispatcher) Encode(s string) string

+ func (di *Dispatcher) Log(keyvals ...interface{}) error

+ type Task = pb.Task