virtbuf

README

these are .proto files. first stab. may be inaccurate writes out config files as protojson and prototext todo: lots of stuff

Documentation

Index

• func ConfigWriteJSON(a any, filename string) error
• func ConfigWriteTEXT(a any, filename string) error
• func FormatDuration(d time.Duration) string
• func HumanFormatBytes(b int64) string
• func SetGB(gb int) int64
• func SetMB(mb int) int64
• type Cluster
  • func CreateSampleCluster(total int) *Cluster
  • func InitCluster() *Cluster
  • func (c *Cluster) AddDroplet(newd *Droplet) bool
  • func (c *Cluster) AddDropletLocal(name string, hypername string) *Droplet
  • func (c *Cluster) AddDropletSimple(uuid string, hostname string, cpus int, mem int) *Droplet
  • func (c *Cluster) AddEvent(e *Event)
  • func (c *Cluster) AddHypervisor(hostname string, cpus int, mem int) *Hypervisor
  • func (c *Cluster) BlankFields()
  • func (c *Cluster) ChangeDropletState(d *Droplet, newState DropletState) error
  • func (c *Cluster) ClusterStable() (bool, string)
  • func (c *Cluster) ConfigLoad() error
  • func (c *Cluster) ConfigSave() error
  • func (c *Cluster) DropletMoved(d *Droplet, newh *Hypervisor) error
  • func (c *Cluster) DropletReady(d *Droplet) (bool, string)
  • func (c *Cluster) DropletsAll() *DropletIterator
  • func (c *Cluster) DumpDroplet(w http.ResponseWriter, r *http.Request) (string, error)
  • func (c *Cluster) FindDropletByName(name string) *Droplet
  • func (c *Cluster) FindHypervisorByName(name string) *Hypervisor
  • func (c *Cluster) GetDropletIterator() *DropletIterator
  • func (c *Cluster) SelectDropletAll() []*Droplet
  • func (c *Cluster) SelectDropletPointers() []*Droplet
• type DropletIterator
  • func NewDropletIterator(droplets []*Droplet) *DropletIterator
  • func (it *DropletIterator) Droplet() *Droplet
  • func (it *DropletIterator) Scan() bool

Functions

func ConfigWriteJSON

func ConfigWriteJSON(a any, filename string) error

func ConfigWriteTEXT

func ConfigWriteTEXT(a any, filename string) error

func FormatDuration

func FormatDuration(d time.Duration) string

func HumanFormatBytes

func HumanFormatBytes(b int64) string

This isn't for the marketing department so this isn't going to use 'MiB' and 'GiB'

func SetGB

func SetGB(gb int) int64

can the json protobuf output use a string and have a type handler to convert it back to int64?

func SetMB

func SetMB(mb int) int64

Types

type Cluster

type Cluster struct {
	sync.RWMutex

	Dirs []string

	H *Hypervisors

	Unstable        *timestamppb.Timestamp
	UnstableTimeout *durationpb.Duration
	// contains filtered or unexported fields
}

func CreateSampleCluster

func CreateSampleCluster(total int) *Cluster

func InitCluster

func InitCluster() *Cluster

func (*Cluster) AddDroplet

func (c *Cluster) AddDroplet(newd *Droplet) bool

adds a new droplet. enforce unique hostnames

func (*Cluster) AddDropletLocal

func (c *Cluster) AddDropletLocal(name string, hypername string) *Droplet

This isn't for the marketing department

func (*Cluster) AddDropletSimple

func (c *Cluster) AddDropletSimple(uuid string, hostname string, cpus int, mem int) *Droplet

func (*Cluster) AddEvent

func (c *Cluster) AddEvent(e *Event)

func (*Cluster) AddHypervisor

func (c *Cluster) AddHypervisor(hostname string, cpus int, mem int) *Hypervisor

func (*Cluster) BlankFields

func (c *Cluster) BlankFields()

func (*Cluster) ChangeDropletState

func (c *Cluster) ChangeDropletState(d *Droplet, newState DropletState) error

records an event that the droplet changed state (aka turned on, turned off, etc)

func (*Cluster) ClusterStable

func (c *Cluster) ClusterStable() (bool, string)

func (*Cluster) ConfigLoad

func (c *Cluster) ConfigLoad() error

func (*Cluster) ConfigSave

func (c *Cluster) ConfigSave() error

writes out the cluster information it seperate files to make it humanly possible to hand edit things as needed

func (*Cluster) DropletMoved

func (c *Cluster) DropletMoved(d *Droplet, newh *Hypervisor) error

records an event that the droplet migrated to another hypervisor

func (*Cluster) DropletReady

func (c *Cluster) DropletReady(d *Droplet) (bool, string)

check the cluster and droplet to make sure it's ready to start

func (*Cluster) DropletsAll

func (c *Cluster) DropletsAll() *DropletIterator

func (*Cluster) DumpDroplet

func (c *Cluster) DumpDroplet(w http.ResponseWriter, r *http.Request) (string, error)

func (*Cluster) FindDropletByName

func (c *Cluster) FindDropletByName(name string) *Droplet

func (*Cluster) FindHypervisorByName

func (c *Cluster) FindHypervisorByName(name string) *Hypervisor

func (*Cluster) GetDropletIterator

func (c *Cluster) GetDropletIterator() *DropletIterator

Use Scan() in a loop, similar to a while loop

for iterator.Scan() {
	d := iterator.Droplet()
	fmt.Println("Droplet UUID:", d.Uuid)
}

func (*Cluster) SelectDropletAll

func (c *Cluster) SelectDropletAll() []*Droplet

SelectDropletPointers safely returns a slice of pointers to Droplet records.

func (*Cluster) SelectDropletPointers

func (c *Cluster) SelectDropletPointers() []*Droplet

SelectDropletPointers safely returns a slice of pointers to Droplet records.

type DropletIterator

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

func NewDropletIterator

func NewDropletIterator(droplets []*Droplet) *DropletIterator

NewDropletIterator initializes a new iterator.

func (*DropletIterator) Droplet

func (it *DropletIterator) Droplet() *Droplet

Droplet returns the current droplet.

func (*DropletIterator) Scan

func (it *DropletIterator) Scan() bool

Scan moves to the next element and returns false if there are no more droplets.