scheduler

package

v1.3.2 Latest Latest Go to latest Published: Feb 13, 2026 License: MIT Imports: 18 Imported by: 0

Details

View Source

const (
	RetryLimit   = 5
	MaxQueueSize = 10 * 60 * 60 // 10 entries/second * 1h
)

View Source

const (
	MaxRetryTimeout = 3 * 24 * time.Hour
)

This section is empty.

func StartReporters(session *Session)

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

queue //

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

reporter //

func NewReporter(index int, session *Session) *Reporter

func (r *Reporter) Run()

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

var (
	Rqueue *RequestQueue
)

func (rq *RequestQueue) Delete(url string, data interface{}, priority int, due time.Time)

func (rq *RequestQueue) Patch(url string, data interface{}, priority int, due time.Time)

func (rq *RequestQueue) Post(url string, data interface{}, priority int, due time.Time)

func (rq *RequestQueue) Put(url string, data interface{}, priority int, due time.Time)

type Session struct {
	BaseURL       string
	Client        *http.Client
	Authorization string
}

func InitSession() *Session

func (session *Session) CheckSession(ctx context.Context) bool

func (session *Session) Delete(url string, rawBody interface{}, timeout time.Duration) ([]byte, int, error)

func (session *Session) Get(url string, timeout time.Duration) ([]byte, int, error)

func (session *Session) MultipartRequest(url string, body bytes.Buffer, contentType string, timeout time.Duration) ([]byte, int, error)

func (session *Session) Patch(url string, rawBody interface{}, timeout time.Duration) ([]byte, int, error)

func (session *Session) Post(url string, rawBody interface{}, timeout time.Duration) ([]byte, int, error)

func (session *Session) Put(url string, rawBody interface{}, timeout time.Duration) ([]byte, int, error)

func (session *Session) Request(method, url string, rawBody interface{}, timeout time.Duration) ([]byte, int, error)