redistaskidempotency

Documentation

Index

• type DB
  • func New(adapter redis.Adapter, prefix string, exp time.Duration) DB
  • func (db DB) GetTaskStatusByID(ctx context.Context, taskID string) (taskentity.IntegrationDeliveryStatus, error)
  • func (db DB) SaveTaskStatus(ctx context.Context, taskID string, ...) error

Types

type DB

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

func New

func New(adapter redis.Adapter, prefix string, exp time.Duration) DB

func (DB) GetTaskStatusByID

func (db DB) GetTaskStatusByID(ctx context.Context, taskID string) (taskentity.IntegrationDeliveryStatus, error)

func (DB) SaveTaskStatus

func (db DB) SaveTaskStatus(ctx context.Context, taskID string, status taskentity.IntegrationDeliveryStatus) error