host

Nov 6, 2025

Changes in this version

+ const UpdateStatusInterval

+ func Provide(i *do.Injector)

+ type Cohort struct

+ ControlAvailable bool

+ MemberID string

+ Type CohortType

+ type CohortType string

+ const CohortTypeSwarm

+ type Host struct

+ CPUs int

+ Cohort *Cohort

+ DataDir string

+ DefaultPgEdgeVersion *PgEdgeVersion

+ Hostname string

+ ID string

+ IPv4Address string

+ MemBytes uint64

+ Orchestrator config.Orchestrator

+ Status *HostStatus

+ SupportedPgEdgeVersions []*PgEdgeVersion

+ func (h *Host) Supports(pgEdgeVersion *PgEdgeVersion) bool

+ type HostState string

+ const HostStateDegraded

+ const HostStateHealthy

+ const HostStateUnknown

+ const HostStateUnreachable

+ type HostStatus struct

+ Components map[string]common.ComponentStatus

+ HostID string

+ State HostState

+ UpdatedAt time.Time

+ type HostStatusStore struct

+ func NewHostStatusStore(client *clientv3.Client, root string) *HostStatusStore

+ func (s *HostStatusStore) Create(item *StoredHostStatus) storage.PutOp[*StoredHostStatus]

+ func (s *HostStatusStore) DeleteByKey(hostID string) storage.DeleteOp

+ func (s *HostStatusStore) GetAll() storage.GetMultipleOp[*StoredHostStatus]

+ func (s *HostStatusStore) GetByKey(hostID string) storage.GetOp[*StoredHostStatus]

+ func (s *HostStatusStore) GetByKeys(hostIDs ...string) storage.GetMultipleOp[*StoredHostStatus]

+ func (s *HostStatusStore) Key(hostID string) string

+ func (s *HostStatusStore) Prefix() string

+ func (s *HostStatusStore) Put(item *StoredHostStatus) storage.PutOp[*StoredHostStatus]

+ type HostStore struct

+ func NewHostStore(client *clientv3.Client, root string) *HostStore

+ func (s *HostStore) Create(item *StoredHost) storage.PutOp[*StoredHost]

+ func (s *HostStore) DeleteByKey(hostID string) storage.DeleteOp

+ func (s *HostStore) GetAll() storage.GetMultipleOp[*StoredHost]

+ func (s *HostStore) GetByKey(hostID string) storage.GetOp[*StoredHost]

+ func (s *HostStore) GetByKeys(hostIDs ...string) storage.GetMultipleOp[*StoredHost]

+ func (s *HostStore) Key(hostID string) string

+ func (s *HostStore) Prefix() string

+ func (s *HostStore) Put(item *StoredHost) storage.PutOp[*StoredHost]

+ type Orchestrator interface

+ PopulateHost func(ctx context.Context, h *Host) error

+ PopulateHostStatus func(ctx context.Context, h *HostStatus) error

+ type PgEdgeVersion struct

+ PostgresVersion *Version

+ SpockVersion *Version

+ func GreatestCommonDefaultVersion(hosts ...*Host) (*PgEdgeVersion, error)

+ func MustPgEdgeVersion(postgresVersion, spockVersion string) *PgEdgeVersion

+ func NewPgEdgeVersion(postgresVersion, spockVersion string) (*PgEdgeVersion, error)

+ func (v *PgEdgeVersion) Clone() *PgEdgeVersion

+ func (v *PgEdgeVersion) Compare(other *PgEdgeVersion) int

+ func (v *PgEdgeVersion) Equals(other *PgEdgeVersion) bool

+ func (v *PgEdgeVersion) GreaterThan(other *PgEdgeVersion) bool

+ func (v *PgEdgeVersion) LessThan(other *PgEdgeVersion) bool

+ func (v *PgEdgeVersion) String() string

+ type Resources struct

+ CPUs int

+ MemBytes uint64

+ func DetectResources() (*Resources, error)

+ func (r Resources) NanoCPUs() int64

+ type Service struct

+ func NewService(cfg config.Config, etcd etcd.Etcd, store *Store, orchestrator Orchestrator) *Service

+ func (s *Service) GetAllHosts(ctx context.Context) ([]*Host, error)

+ func (s *Service) GetHost(ctx context.Context, hostID string) (*Host, error)

+ func (s *Service) GetHosts(ctx context.Context, hostIDs []string) ([]*Host, error)

+ func (s *Service) RemoveHost(ctx context.Context, hostID string) error

+ func (s *Service) UpdateHost(ctx context.Context) error

+ func (s *Service) UpdateHostStatus(ctx context.Context) error

+ type Store struct

+ Host *HostStore

+ HostStatus *HostStatusStore

+ func NewStore(client *clientv3.Client, root string) *Store

+ func (s *Store) Txn(ops ...storage.TxnOperation) storage.Txn

+ type StoredCohort struct

+ ControlAvailable bool

+ MemberID string

+ Type CohortType

+ type StoredHost struct

+ CPUs int

+ Cohort *StoredCohort

+ DataDir string

+ DefaultPgEdgeVersion *PgEdgeVersion

+ Hostname string

+ ID string

+ IPv4Address string

+ MemBytes uint64

+ Orchestrator config.Orchestrator

+ SupportedPgEdgeVersions []*PgEdgeVersion

+ type StoredHostStatus struct

+ Components map[string]common.ComponentStatus

+ HostID string

+ State HostState

+ UpdatedAt time.Time

+ type UpdateTicker struct

+ func NewUpdateTicker(logger zerolog.Logger, svc *Service) *UpdateTicker

+ func (u *UpdateTicker) Shutdown() error

+ func (u *UpdateTicker) Start(ctx context.Context)

+ type Version struct

+ Components []uint64

+ func ParseVersion(s string) (*Version, error)

+ func (v *Version) Clone() *Version

+ func (v *Version) Compare(other *Version) int

+ func (v *Version) Major() (uint64, bool)

+ func (v *Version) MarshalText() (data []byte, err error)

+ func (v *Version) String() string

+ func (v *Version) UnmarshalJSON(data []byte) error

+ func (v *Version) UnmarshalText(data []byte) error