taskdb

Jul 3, 2022

Changes in this version

type KVTaskDB

+ func (tdb *KVTaskDB) Close() error

type MemoryTaskDB

+ func (MemoryTaskDB) Close() error

type TaskDB

+ Close func() error

Jun 5, 2022

Changes in this version

+ var ErrStateNotFound = errors.New("state not found")

+ type KVAttachIterator struct

+ func (ai *KVAttachIterator) Next() ([]*TaskDBTaskState, error)

+ type KVDrainIterator struct

+ func (di *KVDrainIterator) Next() ([]*DrainTask, error)

+ type KVTaskDB struct

+ func NewKVTaskDB(partition string) (*KVTaskDB, error)

+ func (tdb *KVTaskDB) Attach() AttachIterator

+ func (tdb *KVTaskDB) Delete(topicName, taskID string) WriteResult

+ func (tdb *KVTaskDB) Drain() DrainIterator

+ func (tdb *KVTaskDB) GetPayload(topicName, taskID string) (payload string, err error)

+ func (tdb *KVTaskDB) PutPayload(topicName, taskID string, payload string) WriteResult

+ func (tdb *KVTaskDB) PutState(state *TaskDBTaskState) WriteResult

+ type KVWriteResult struct

+ func (wr KVWriteResult) Get() error

Jun 5, 2022

Changes in this version

+ type BadgerTaskStateWithID struct

+ ID []byte

+ Payload string

+ State *TaskDBTaskState

Jun 2, 2022

Changes in this version

type DrainTask

+ Priority int32

Jun 1, 2022

Changes in this version

+ var ErrAttachEnded = errors.New("attach ended")

+ type BadgerAttachIterator struct

+ func (ai *BadgerAttachIterator) Next() ([]*TaskDBTaskState, error)

+ type BadgerDrainIterator struct

+ func (di *BadgerDrainIterator) Next() ([]*DrainTask, error)

+ type BadgerTaskDB struct

+ func NewBadgerTaskDB() (*BadgerTaskDB, error)

+ func (tdb *BadgerTaskDB) Attach() AttachIterator

+ func (tdb *BadgerTaskDB) Delete(topicName, taskID string) WriteResult

+ func (tdb *BadgerTaskDB) Drain() DrainIterator

+ func (tdb *BadgerTaskDB) GetPayload(topicName, taskID string) (payload string, err error)

+ func (tdb *BadgerTaskDB) PutPayload(topicName, taskID string, payload string) WriteResult

+ func (tdb *BadgerTaskDB) PutState(state *TaskDBTaskState) WriteResult

+ type BadgerWriteResult struct

+ func (wr BadgerWriteResult) Get() error

May 28, 2022

Changes in this version

+ var ErrPayloadNotFound = errors.New("payload not found")

+ type FakeAttachIterator struct

+ func (fai *FakeAttachIterator) Next() ([]*TaskDBTaskState, error)

+ type MemoryDrainIterator struct

+ func (mdi *MemoryDrainIterator) Next() ([]*DrainTask, error)

+ type MemoryTaskDB struct

+ func NewMemoryTaskDB() (*MemoryTaskDB, error)

+ func (mtdb *MemoryTaskDB) Attach() AttachIterator

+ func (mtdb *MemoryTaskDB) Delete(topicName, taskID string) WriteResult

+ func (mtdb *MemoryTaskDB) Drain() DrainIterator

+ func (mtdb *MemoryTaskDB) GetPayload(topicName, taskID string) ([]byte, error)

+ func (mtdb *MemoryTaskDB) NewMemoryTaskDB() (*MemoryTaskDB, error)

+ func (mtdb *MemoryTaskDB) PutPayload(topicName, taskID string, payload []byte) WriteResult

+ func (mtdb *MemoryTaskDB) PutState(state *TaskDBTaskState) WriteResult

+ type MemoryWriteResult struct

+ func (mwr MemoryWriteResult) Get() error

type TaskDB

+ PutPayload func(topicName, taskID string, payload []byte) WriteResult

type TaskState

+ const TASK_STATE_ENQUEUED

May 27, 2022

Changes in this version

+ type AttachIterator interface

+ Next func() ([]*TaskDBTaskState, error)

+ type DrainIterator interface

+ Next func() ([]*DrainTask, error)

+ type DrainTask struct

+ ID string

+ Payload []byte

+ Topic string

+ type TaskDB interface

+ Attach func() AttachIterator

+ Delete func(topicName, taskID string) WriteResult

+ Drain func() DrainIterator

+ Enqueue func(state *TaskDBTaskState, payload []byte) WriteResult

+ GetPayload func(topicName, taskID string) ([]byte, error)

+ PutState func(state *TaskDBTaskState) WriteResult

+ type TaskDBTaskState struct

+ CreatedAt time.Time

+ DeliveryAttempts int

+ ID string

+ Partition string

+ Priority int

+ State TaskState

+ Topic string

+ Version int

+ func NewTaskDBTaskState(partition, topicName, taskID string, state TaskState, ...) *TaskDBTaskState

+ type TaskState int

+ const TASK_STATE_ACKED

+ const TASK_STATE_DELAYED

+ const TASK_STATE_INFLIGHT

+ const TASK_STATE_NACKED

+ const TASK_STATE_QUEUED

+ func (ts TaskState) String() string

+ type WriteResult interface

+ Get func() error