cluster

Mar 19, 2024

Changes in this version

+ const RegionClusterTokenFileName

type Env

+ func (m *Env) Regions() []string

type Region

+ Cluster *string

+ type RegionIterator interface

+ ForEachRegion func(func(*Region) bool)

type Zone

+ func (z *Zone) ForEachRegion(fn func(*Region) bool)

Oct 31, 2023

Changes in this version

+ const ZoneRegionsFileName

type Cluster

+ func (m *Cluster) SyncAllRegions() error

type Region

+ func (r *Region) SyncRegions() error

type Zone

+ func (z *Zone) SyncRegions() error

Oct 30, 2023

Changes in this version

+ func SortRegions(regions []string) []string

type Cluster

+ func (m *Cluster) MkdirAll(name string, args ...any) error

+ func (m *Cluster) ReadLines(name string, args ...any) ([]string, error)

+ func (m *Cluster) RemoveFile(name string, args ...any) error

+ func (m *Cluster) SyncMkdirAll() error

+ func (m *Cluster) WriteStringFile(value string, name string, args ...any) error

type Machine

+ Inactive bool

+ func (m *Machine) IsActive() bool

+ func (m *Machine) MkdirAll(name string, args ...any) error

+ func (m *Machine) ReadLines(name string, args ...any) ([]string, error)

Sep 12, 2023

Changes in this version

type Cluster

+ func (m *Cluster) ForEachRegion(fn func(r *Region) bool)

type Region

+ func (r *Region) ForEachMachine(fn func(*Machine) bool)

+ func (r *Region) ForEachZone(fn func(*Zone) bool)

Sep 12, 2023

Changes in this version

type Cluster

+ Regions []Region

+ type Region struct

+ Name string

+ Regions []string

type Zone

+ Regions []string

Sep 11, 2023

Changes in this version

+ func DirFS(dir string) (fs.FS, error)

type Cluster

+ func NewFromConfig(filename string, opts ...ScanOption) (*Cluster, error)

Sep 11, 2023

Changes in this version

type Cluster

+ func (m *Cluster) WriteHosts() error

type Machine

+ func (p *Machine) WriteHosts() error

type Zone

+ func (z *Zone) Hosts() string

+ func (z *Zone) WriteHosts() error

Sep 11, 2023

Changes in this version

+ const MaxNodeID

+ const MaxZoneID

+ const RingOnePort

+ const RingZeroPort

+ const RingsCount

+ var ErrInvalidName = errors.New("invalid name")

+ var ErrInvalidNode = errors.New("invalid node")

+ var ErrUnknownNode = errors.New("node does not exist")

+ var RingOne = RingAddressEncoder

+ var RingZero = RingAddressEncoder

+ var Rings = [RingsCount]RingAddressEncoder

+ func DefaultLogger() slog.Logger

+ func DefaultLookuper() resolver.Lookuper

+ func ParseRingOneAddress(addr netip.Addr) (zoneID int, nodeID int, ok bool)

+ func ParseRingZeroAddress(addr netip.Addr) (zoneID int, nodeID int, ok bool)

+ func RingOneAddress(zoneID, nodeID int) (netip.Addr, bool)

+ func RingZeroAddress(zoneID, nodeID int) (netip.Addr, bool)

+ func ValidNodeID(nodeID int) bool

+ func ValidZoneID(zoneID int) bool

+ type Cluster struct

+ BaseDir string

+ CephFSID uuid.UUID

+ Domain string

+ Name string

+ Zones []*Zone

+ func NewFromDirectory(dir, domain string, opts ...ScanOption) (*Cluster, error)

+ func (m *Cluster) CreateFile(name string, args ...any) (io.WriteCloser, error)

+ func (m *Cluster) CreateTruncFile(name string, args ...any) (io.WriteCloser, error)

+ func (m *Cluster) Env(export bool) (*Env, error)

+ func (m *Cluster) ForEachMachine(fn func(*Machine) bool)

+ func (m *Cluster) ForEachZone(fn func(*Zone) bool)

+ func (m *Cluster) GenCephConfig() (*ceph.Config, error)

+ func (m *Cluster) GetCephConfig() (*ceph.Config, error)

+ func (m *Cluster) GetCephFSID() (uuid.UUID, error)

+ func (m *Cluster) GetMachineByName(name string) (*Machine, bool)

+ func (m *Cluster) OpenFile(name string, flags int, args ...any) (fs.File, error)

+ func (m *Cluster) PruneWireguardConfig(ring int) error

+ func (m *Cluster) ReadFile(name string, args ...any) ([]byte, error)

+ func (m *Cluster) SyncAll() error

+ func (m *Cluster) SyncAllCeph() error

+ func (m *Cluster) SyncAllWireguard() error

+ func (m *Cluster) SyncWireguardConfig(ring int) error

+ func (m *Cluster) WriteCephConfig(cfg *ceph.Config) error

+ func (m *Cluster) WriteWireguardConfig(ring int) error

+ func (m *Cluster) WriteWireguardKeys(ring int) error

+ type Env struct

+ func (m *Env) WriteTo(w io.Writer) (int64, error)

+ func (m *Env) Zones() []int

+ type Machine struct

+ CephMonitor bool

+ ID int

+ Name string

+ PublicAddresses []netip.Addr

+ Rings []*RingInfo

+ func (m *Machine) CreateFile(name string, args ...any) (io.WriteCloser, error)

+ func (m *Machine) CreateTruncFile(name string, args ...any) (io.WriteCloser, error)

+ func (m *Machine) FullName() string

+ func (m *Machine) GetWireguardConfig(ring int) (*wireguard.Config, error)

+ func (m *Machine) GetWireguardKeys(ring int) (wireguard.KeyPair, error)

+ func (m *Machine) IsGateway() bool

+ func (m *Machine) LookupNetIP(timeout time.Duration) ([]netip.Addr, error)

+ func (m *Machine) OpenFile(name string, flags int, args ...any) (fs.File, error)

+ func (m *Machine) PruneWireguardConfig(ring int) error

+ func (m *Machine) ReadFile(name string, args ...any) ([]byte, error)

+ func (m *Machine) RemoveFile(name string, args ...any) error

+ func (m *Machine) RemoveWireguardConfig(ring int) error

+ func (m *Machine) RemoveWireguardKeys(ring int) error

+ func (m *Machine) SetGateway(enabled bool) error

+ func (m *Machine) String() string

+ func (m *Machine) SyncWireguardConfig(ring int) error

+ func (m *Machine) UpdatePublicAddresses() error

+ func (m *Machine) WriteStringFile(value string, name string, args ...any) error

+ func (m *Machine) WriteWireguardConfig(ring int) error

+ func (m *Machine) WriteWireguardKeys(ring int) error

+ func (m *Machine) Zone() int

+ type MachineIterator interface

+ ForEachMachine func(func(*Machine) bool)

+ type Machines []*Machine

+ func FilterMachines(m MachineIterator, cond func(*Machine) bool) (Machines, int)

+ func (m Machines) ForEachMachine(fn func(*Machine) bool)

+ func (m Machines) Len() int

+ func (m Machines) Less(i, j int) bool

+ func (m Machines) Swap(i, j int)

+ type Ring struct

+ Peers []*RingPeer

+ func NewRing(z ZoneIterator, m MachineIterator, ring int) (*Ring, error)

+ func (r *Ring) AddPeer(p *Machine) bool

+ func (r *Ring) ExportConfig(p *Machine) (*wireguard.Config, error)

+ func (r *Ring) ForEachMachine(fn func(*Machine) bool)

+ type RingAddressEncoder struct

+ Decode func(addr netip.Addr) (zoneID, nodeID int, ok bool)

+ Encode func(zoneID, nodeID int) (netip.Addr, bool)

+ ID int

+ Port uint16

+ type RingInfo struct

+ Enabled bool

+ Keys wireguard.KeyPair

+ Ring int

+ func (ri *RingInfo) Merge(alter *RingInfo) error

+ type RingPeer struct

+ Address netip.Addr

+ Node *Machine

+ PeerConfig wireguard.PeerConfig

+ PrivateKey wireguard.PrivateKey

+ func (rp *RingPeer) AllowCIDR(addr netip.Addr, bits int)

+ type ScanOption func(*Cluster, *ScanOptions) error

+ func ResolvePublicAddresses(resolve bool) ScanOption

+ func WithLogger(log slog.Logger) ScanOption

+ func WithLookuper(h resolver.Lookuper) ScanOption

+ func WithResolver(h resolver.Resolver) ScanOption

+ type ScanOptions struct

+ DontResolvePublicAddresses bool

+ type WireguardConfigPruner interface

+ PruneWireguardConfig func(ring int) error

+ type WireguardConfigSyncer interface

+ SyncWireguardConfig func(ring int) error

+ type WireguardConfigWriter interface

+ WriteWireguardConfig func(ring int) error

+ type WireguardKeysWriter interface

+ WriteWireguardKeys func(ring int) error

+ type Zone struct

+ ID int

+ Name string

+ func (z *Zone) GatewayIDs() ([]int, int)

+ func (z *Zone) GetCephMonitors() Machines

+ func (z *Zone) GetGateway() (*Machine, bool, error)

+ func (z *Zone) PruneWireguardConfig(ring int) error

+ func (z *Zone) SetGateway(gatewayID int, enabled bool) error

+ func (z *Zone) String() string

+ func (z *Zone) SyncWireguardConfig(ring int) error

+ func (z *Zone) WriteWireguardConfig(ring int) error

+ func (z *Zone) WriteWireguardKeys(ring int) error

+ type ZoneIterator interface

+ ForEachZone func(func(*Zone) bool)