model

README

Data Model

Documentation

Index

• Constants
• type Job
  • func NewJobStore(db driver.Database) *Job
  • func (j *Job) CountServiceJobs(serviceID, status string) (int, error)
  • func (j *Job) CreateRecord(record JobRecord) error
  • func (j *Job) DeleteRecord(serviceID, jobID string) (bool, error)
  • func (j *Job) GetRecord(serviceID, jobID string) (*JobRecord, error)
  • func (j *Job) GetServiceJobs(serviceID string) ([]*JobRecord, error)
  • func (j *Job) UpdateRecord(record JobRecord) error
• type JobRecord
• type Metric
  • func (m *Metric) ConvertToJSON() (string, error)
  • func (m *Metric) GetValueAsFloat() (float64, error)
  • func (m *Metric) LabelKeys() []string
  • func (m *Metric) LabelValues() []string
  • func (m *Metric) LoadFromJSON(data []byte) (bool, error)
• type Option
  • func NewOptionStore(db driver.Database) *Option
  • func (o *Option) CreateOption(option OptionData) error
  • func (o *Option) DeleteOptionByKey(key string) (bool, error)
  • func (o *Option) GetOptionByKey(key string) (*OptionData, error)
  • func (o *Option) UpdateOptionByKey(option OptionData) error
  • func (o *Option) UpdateOptions(options []OptionData) error
• type OptionData
• type Service
  • func NewServiceStore(db driver.Database) *Service
  • func (s *Service) CreateRecord(record ServiceRecord) error
  • func (s *Service) DeleteRecord(serviceID string) (bool, error)
  • func (s *Service) GetRecord(serviceID string) (*ServiceRecord, error)
  • func (s *Service) UpdateRecord(record ServiceRecord) error
• type ServiceRecord
  • func (s *ServiceRecord) GetConfig(key, def string) string

Constants

const (
	// PendingStatus constant
	PendingStatus = "@pending"

	// FailedStatus constant
	FailedStatus = "@failed"

	// SuccessStatus constant
	SuccessStatus = "@success"

	// DeployJob constant
	DeployJob = "@deployService"

	// DestroyJob constant
	DestroyJob = "@destroyService"
)

const (
	// COUNTER is a Prometheus COUNTER metric
	COUNTER string = "counter"
	// GAUGE is a Prometheus GAUGE metric
	GAUGE string = "gauge"
	// HISTOGRAM is a Prometheus HISTOGRAM metric
	HISTOGRAM string = "histogram"
	// SUMMARY is a Prometheus SUMMARY metric
	SUMMARY string = "summary"
)

const (
	// RedisService constant
	RedisService = "REDIS_SERVICE"
)

Types

type Job

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

Job type

func NewJobStore

func NewJobStore(db driver.Database) *Job

NewJobStore creates a new instance

func (*Job) CountServiceJobs

func (j *Job) CountServiceJobs(serviceID, status string) (int, error)

CountServiceJobs counts service jobs

func (*Job) CreateRecord

func (j *Job) CreateRecord(record JobRecord) error

CreateRecord stores a job record

func (*Job) DeleteRecord

func (j *Job) DeleteRecord(serviceID, jobID string) (bool, error)

DeleteRecord deletes a job record

func (*Job) GetRecord

func (j *Job) GetRecord(serviceID, jobID string) (*JobRecord, error)

GetRecord gets job record data

func (*Job) GetServiceJobs

func (j *Job) GetServiceJobs(serviceID string) ([]*JobRecord, error)

GetServiceJobs get jobs for a service

func (*Job) UpdateRecord

func (j *Job) UpdateRecord(record JobRecord) error

UpdateRecord updates a job record

type JobRecord

type JobRecord struct {
	ID        string        `json:"id"`
	Action    string        `json:"action"`
	Service   ServiceRecord `json:"service"`
	Status    string        `json:"status"`
	CreatedAt int64         `json:"createdAt"`
	UpdatedAt int64         `json:"updatedAt"`
}

JobRecord type

type Metric

type Metric struct {
	Type    string            `json:"type"`
	Name    string            `json:"name"`
	Help    string            `json:"help"`
	Method  string            `json:"method"`
	Value   string            `json:"value"`
	Labels  prometheus.Labels `json:"labels"`
	Buckets []float64         `json:"buckets"`
}

Metric struct

func (*Metric) ConvertToJSON

func (m *Metric) ConvertToJSON() (string, error)

ConvertToJSON convert object to json

func (*Metric) GetValueAsFloat

func (m *Metric) GetValueAsFloat() (float64, error)

GetValueAsFloat gets a list of label values

func (*Metric) LabelKeys

func (m *Metric) LabelKeys() []string

LabelKeys gets a list of label keys

func (*Metric) LabelValues

func (m *Metric) LabelValues() []string

LabelValues gets a list of label values

func (*Metric) LoadFromJSON

func (m *Metric) LoadFromJSON(data []byte) (bool, error)

LoadFromJSON update object from json

type Option

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

Option type

func NewOptionStore

func NewOptionStore(db driver.Database) *Option

NewOptionStore creates a new instance

func (*Option) CreateOption

func (o *Option) CreateOption(option OptionData) error

CreateOption stores an option

func (*Option) DeleteOptionByKey

func (o *Option) DeleteOptionByKey(key string) (bool, error)

DeleteOptionByKey deletes an option by a key

func (*Option) GetOptionByKey

func (o *Option) GetOptionByKey(key string) (*OptionData, error)

GetOptionByKey gets an option by a key

func (*Option) UpdateOptionByKey

func (o *Option) UpdateOptionByKey(option OptionData) error

UpdateOptionByKey updates an option by key

func (*Option) UpdateOptions

func (o *Option) UpdateOptions(options []OptionData) error

UpdateOptions update options

type OptionData

type OptionData struct {
	Key       string `json:"key"`
	Value     string `json:"value"`
	CreatedAt int64  `json:"createdAt"`
	UpdatedAt int64  `json:"updatedAt"`
}

OptionData struct

type Service

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

Service type

func NewServiceStore

func NewServiceStore(db driver.Database) *Service

NewServiceStore creates a new instance

func (*Service) CreateRecord

func (s *Service) CreateRecord(record ServiceRecord) error

CreateRecord stores a service record

func (*Service) DeleteRecord

func (s *Service) DeleteRecord(serviceID string) (bool, error)

DeleteRecord deletes a service record

func (*Service) GetRecord

func (s *Service) GetRecord(serviceID string) (*ServiceRecord, error)

GetRecord gets service record data

func (*Service) UpdateRecord

func (s *Service) UpdateRecord(record ServiceRecord) error

UpdateRecord updates a service record

type ServiceRecord

type ServiceRecord struct {
	ID          string            `json:"id"`
	Template    string            `json:"template"`
	Configs     map[string]string `json:"configs"`
	DeleteAfter string            `json:"deleteAfter"`
	CreatedAt   int64             `json:"createdAt"`
	UpdatedAt   int64             `json:"updatedAt"`
}

ServiceRecord type

func (*ServiceRecord) GetConfig

func (s *ServiceRecord) GetConfig(key, def string) string

GetConfig get a config value