models

Documentation

Index

• type Heartbeat
• type HmacKeys
  • func (hk *HmacKeys) GetLatestKey() string
• type Key
• type NewService
• type Service
  • func (s *Service) Print()
  • func (s *Service) RegisterAtGateway(gatewayUrl string) error
• type ServicePool
  • func (sp *ServicePool) AddService(s *Service)
  • func (sp *ServicePool) GetNextPeer() *Service
  • func (sp *ServicePool) HealthCheck()
  • func (sp *ServicePool) MarkServiceStatus(serviceID int, alive bool)
  • func (sp *ServicePool) Print()
• type ServicePoolStatus

Types

type Heartbeat

type Heartbeat struct {
	RequestID      string `json:"requestId"`
	DatabaseOnline bool   `json:"databaseOnline"`
	AppName        string `json:"appName"`
	ReleaseDate    string `json:"releaseCreatedAt"`
	ReleaseVersion string `json:"releaseVersion"`
	Slug           string `json:"slugCommit"`
	Message        string `json:"message"`
}

type HmacKeys

type HmacKeys struct {
	Name string `json:"name"`
	Keys []Key  `json:"keys"`
}

func (*HmacKeys) GetLatestKey

func (hk *HmacKeys) GetLatestKey() string

type Key

type Key struct {
	Created time.Time `json:"created"`
	Value   string    `json:"value"`
}

type NewService

type NewService struct {
	ServiceName     string                 `json:"service_name"`
	ServiceSummary  string                 `json:"service_summary"`
	ServiceOnline   bool                   `json:"service_online"`
	ServiceProtocol string                 `json:"service_protocol"`
	ServiceVersion  string                 `json:"service_version"`
	BaseURL         string                 `json:"base_url"`
	Routes          map[string]interface{} `json:"routes"`
}

Only used for documentation. Not used for database

type Service

type Service struct {
	ID              int            `json:"id"`
	CreatedAt       time.Time      `json:"created_at"`
	UpdatedAt       time.Time      `json:"update_at"`
	DeletedAt       time.Time      `json:"deleted_at"`
	ServiceName     string         `json:"service_name"`
	ServiceSummary  string         `json:"service_summary"`
	ServiceOnline   bool           `json:"service_online"`
	ServiceProtocol string         `json:"service_protocol"`
	ServiceVersion  string         `json:"service_version"`
	BaseURL         string         `json:"base_url"`
	Routes          datatypes.JSON `json:"routes"`
}

func (*Service) Print

func (s *Service) Print()

func (*Service) RegisterAtGateway

func (s *Service) RegisterAtGateway(gatewayUrl string) error

type ServicePool

type ServicePool struct {
	Services []*Service
	Current  uint64
}

func (*ServicePool) AddService

func (sp *ServicePool) AddService(s *Service)

func (*ServicePool) GetNextPeer

func (sp *ServicePool) GetNextPeer() *Service

func (*ServicePool) HealthCheck

func (sp *ServicePool) HealthCheck()

func (*ServicePool) MarkServiceStatus

func (sp *ServicePool) MarkServiceStatus(serviceID int, alive bool)

func (*ServicePool) Print

func (sp *ServicePool) Print()

type ServicePoolStatus

type ServicePoolStatus struct {
	RequestID string      `json:"requestId"`
	Services  []Heartbeat `json:"services"`
}