db

Documentation

Index

• func Close()
• func Deserialize[T any](valueBytes []byte) T
• func Init()
• func Serialize(value any) []byte
• func ShutdownRequestDB()
• type RequestResult
• type RequestSchedulerDB
  • func NewRequestSchedulerDB() *RequestSchedulerDB
  • func (s *RequestSchedulerDB) Claim(id string) error
  • func (s *RequestSchedulerDB) CleanupDones(threshold time.Duration) error
  • func (s *RequestSchedulerDB) DeleteByID(id string) error
  • func (s *RequestSchedulerDB) FetchNext(amount int, within time.Duration) ([]*ScheduledRequest, error)
  • func (s *RequestSchedulerDB) GetByID(id string) (*ScheduledRequestEntry, error)
  • func (s *RequestSchedulerDB) Insert(req *ScheduledRequest) error
  • func (s *RequestSchedulerDB) RecoverStales(threshold time.Duration) error
  • func (s *RequestSchedulerDB) SetResponse(id string, e error, res RequestResult) error
  • func (s *RequestSchedulerDB) SetStatus(id string, status ScheduledRequestStatus) error
• type ScheduledRequest
• type ScheduledRequestEntry
• type ScheduledRequestStatus

Functions

func Close

func Close()

func Deserialize

func Deserialize[T any](valueBytes []byte) T

func Init

func Init()

func Serialize

func Serialize(value any) []byte

func ShutdownRequestDB

func ShutdownRequestDB()

Types

type RequestResult

type RequestResult struct {
	RunAt      time.Time
	FinishedAt *time.Time
	LastError  *string
	Status     *int
	Headers    *map[string][]string
	Body       *[]byte
}

type RequestSchedulerDB

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

func NewRequestSchedulerDB

func NewRequestSchedulerDB() *RequestSchedulerDB

func (*RequestSchedulerDB) Claim

func (s *RequestSchedulerDB) Claim(id string) error

func (*RequestSchedulerDB) CleanupDones

func (s *RequestSchedulerDB) CleanupDones(threshold time.Duration) error

func (*RequestSchedulerDB) DeleteByID

func (s *RequestSchedulerDB) DeleteByID(id string) error

func (*RequestSchedulerDB) FetchNext

func (s *RequestSchedulerDB) FetchNext(amount int, within time.Duration) ([]*ScheduledRequest, error)

func (*RequestSchedulerDB) GetByID

func (s *RequestSchedulerDB) GetByID(id string) (*ScheduledRequestEntry, error)

func (*RequestSchedulerDB) Insert

func (s *RequestSchedulerDB) Insert(req *ScheduledRequest) error

func (*RequestSchedulerDB) RecoverStales

func (s *RequestSchedulerDB) RecoverStales(threshold time.Duration) error

func (*RequestSchedulerDB) SetResponse

func (s *RequestSchedulerDB) SetResponse(id string, e error, res RequestResult) error

func (*RequestSchedulerDB) SetStatus

func (s *RequestSchedulerDB) SetStatus(id string, status ScheduledRequestStatus) error

type ScheduledRequest

type ScheduledRequest struct {
	ID        string
	Method    string
	URL       string
	Headers   map[string][]string
	Body      []byte
	RunAt     time.Time
	CreatedAt time.Time
}

type ScheduledRequestEntry

type ScheduledRequestEntry struct {
	Status    ScheduledRequestStatus
	ID        string
	Method    string
	URL       string
	Headers   map[string][]string
	Body      []byte
	RunAt     time.Time
	CreatedAt time.Time

	FinishedAt         *time.Time
	LastError          *string
	ResponseStatusCode *int
	ResponseBody       *[]byte
	ResponseHeaders    *map[string][]string
}

type ScheduledRequestStatus

type ScheduledRequestStatus string

const (
	STATUS_PENDING ScheduledRequestStatus = "pending"
	STATUS_QUEUED  ScheduledRequestStatus = "queued"
	STATUS_DONE    ScheduledRequestStatus = "done"
	STATUS_FAILED  ScheduledRequestStatus = "failed"
	STATUS_RUNNING ScheduledRequestStatus = "running"
)