umak

Documentation

Index

• Variables
• type Application
• type Umak
  • func New(db db.DBClient, k kamu.Kamu, c *cron.Cron) Umak

Variables

var (
	APPLICATION_PREFIX []byte = []byte("APPLICATION")
	DEFAULT_LOGGER            = log.New(os.Stdout, "umak ", log.LstdFlags)
)

Types

type Application

type Application struct {
	Number   string    `json:"number"`
	Queue    string    `json:"queue,omitempty"`
	LastSync time.Time `json:"last_sync,omitempty"`
	Crons    []string  `json:"crons,omitempty"`
	ErrMsg   string    `json:"err_msg,omitempty"`
	JobIds   []int     `json:"job_ids"`

	LastSyncDurable time.Duration `json:"last_sync_durable,omitempty"`
}

type Umak

type Umak interface {
	AddNewDiaryNumber(txn db.Txn, diaryNumber string, crons []string) (*Application, error)
	GetApplication(txn db.Txn, diaryNumber string) (*Application, error)
	GetApplications(txn db.Txn) ([]Application, error)
	SyncQueue(txn db.Txn, app *Application) error
	InitCronJobs(txn db.Txn) error
	DeleteApplication(txn db.Txn, app *Application) error
}

func New

func New(db db.DBClient, k kamu.Kamu, c *cron.Cron) Umak