offline

Documentation

Index

• Constants
• func CountHeartbeats(filepath string) (int, error)
• func QueueFilepath() (string, error)
• func Sync(filepath string, syncLimit int) func(next heartbeat.Handle) error
• func WithQueue(filepath string, syncLimit int) (heartbeat.HandleOption, error)
• type ErrOfflineEnqueue
  • func (e ErrOfflineEnqueue) Error() string
• type Queue
  • func NewQueue(tx *bolt.Tx) *Queue
  • func (q *Queue) Count() (int, error)
  • func (q *Queue) PopMany(limit int) ([]heartbeat.Heartbeat, error)
  • func (q *Queue) PushMany(hh []heartbeat.Heartbeat) error

Constants

const (
	// SyncMaxDefault is the default maximum number of heartbeats from the
	// offline queue, which will be synced upon sending heartbeats to the API.
	SyncMaxDefault = 1000
)

Functions

func CountHeartbeats

func CountHeartbeats(filepath string) (int, error)

CountHeartbeats returns the total number of heartbeats in the offline db.

func QueueFilepath

func QueueFilepath() (string, error)

QueueFilepath returns the path for offline queue db file.

func Sync

func Sync(filepath string, syncLimit int) func(next heartbeat.Handle) error

Sync returns a function to send queued heartbeats to the WakaTime API.

func WithQueue

func WithQueue(filepath string, syncLimit int) (heartbeat.HandleOption, error)

WithQueue initializes and returns a heartbeat handle option, which can be used in a heartbeat processing pipeline for automatic handling of failures of heartbeat sending to the API. Upon inability to send due to missing or failing connection to API, failed sending or errors returned by API, the heartbeats will be temporarily stored in a DB and sending will be retried at next usages of the wakatime cli.

Types

type ErrOfflineEnqueue

type ErrOfflineEnqueue string

ErrOfflineEnqueue represents an enqueue to offline db error.

func (ErrOfflineEnqueue) Error

func (e ErrOfflineEnqueue) Error() string

Error method to implement error interface.

type Queue

type Queue struct {
	Bucket string
	// contains filtered or unexported fields
}

Queue is a db client to temporarily store heartbeats in bolt db, in case heartbeat sending to wakatime api is not possible. Transaction handling is left to the user via the passed in transaction.

func NewQueue

func NewQueue(tx *bolt.Tx) *Queue

NewQueue creates a new instance of Queue.

func (*Queue) Count

func (q *Queue) Count() (int, error)

Count returns the total number of heartbeats in the offline db.

func (*Queue) PopMany

func (q *Queue) PopMany(limit int) ([]heartbeat.Heartbeat, error)

PopMany retrieves heartbeats with the specified ids from db.

func (*Queue) PushMany

func (q *Queue) PushMany(hh []heartbeat.Heartbeat) error

PushMany stores the provided heartbeats in the db.