workloads

package

Go to main page

Versions in this module

v0

v0.6.1

Apr 26, 2022

v0.6.0

Jun 8, 2021

Changes in this version

type K8S

+ CustomSize K8SCustomSize

+ type K8SCustomSize struct

+ CRU int64

+ MRU float64

+ SRU float64

+ type VMCustomSize struct

+ CRU int64

+ MRU float64

+ SRU float64

+ type VirtualMachine struct

+ CustomSize VMCustomSize

+ Ipaddress net.IP

+ Name string

+ NetworkId string

+ PublicIP schema.ID

+ Size int64

+ SshKeys []string

+ func (k *VirtualMachine) GetRSU() (RSU, error)

+ func (vm *VirtualMachine) SignatureChallenge() ([]byte, error)

type WorkloadTypeEnum

+ const WorkloadTypeVirtualMachine

v0.5.0

Mar 11, 2021

Changes in this version

+ var GatewayTypes = []WorkloadTypeEnum

+ var ZeroOSTypes = []WorkloadTypeEnum

type K8S

+ DatastoreEndpoint string

+ DisableDefaultIngress bool

type WorkloadTypeEnum

+ func (t WorkloadTypeEnum) Any(types ...WorkloadTypeEnum) bool

v0.4.9

Jan 19, 2021

v0.4.8

Dec 21, 2020

Changes in this version

type K8S

+ PublicIP schema.ID

+ type PublicIP struct

+ IPaddress schema.IPCidr

+ func (z *PublicIP) GetRSU() (RSU, error)

+ func (z *PublicIP) SignatureChallenge() ([]byte, error)

type RSU

+ IPV4U float64

type ReservationData

+ PublicIPs []PublicIP

type WorkloadTypeEnum

+ const WorkloadTypePublicIP

v0.4.2

Dec 7, 2020

Changes in this version

type Container

+ Stats []Stats

type ContainerCapacity

+ func (c ContainerCapacity) SigningEncode(w io.Writer) error

type ContainerMount

+ func (c ContainerMount) SigningEncode(w io.Writer) error

type Logs

+ func (c Logs) SigningEncode(w io.Writer) error

type LogsRedis

+ SecretStderr string

+ SecretStdout string

+ func (l LogsRedis) SigningEncode(w io.Writer) error

type NetworkConnection

+ func (n NetworkConnection) SigningEncode(w io.Writer) error

type ReservationInfo

+ Version int

+ func (i *ReservationInfo) GetVersion() int

+ func (i *ReservationInfo) SetVersion(version int)

+ type Stats struct

+ Data json.RawMessage

+ Type string

+ func (s Stats) SigningEncode(w io.Writer) error

type StatsAggregator

+ func (s StatsAggregator) SigningEncode(w io.Writer) error

type WireguardPeer

+ func (p *WireguardPeer) SigningEncode(w io.Writer) error

type Workloader

+ GetVersion func() int

+ SetVersion func(version int)

v0.4.1-rc1

Nov 12, 2020

v0.4.1-rc0

Nov 12, 2020

v0.4.0

Sep 18, 2020

Changes in this version

+ var WorkloadTypes = map[WorkloadTypeEnum]string

+ type Capaciter interface

+ GetRSU func() RSU

+ type Container struct

+ Capacity ContainerCapacity

+ Entrypoint string

+ Environment map[string]string

+ Flist string

+ HubUrl string

+ Interactive bool

+ Logs []Logs

+ NetworkConnection []NetworkConnection

+ SecretEnvironment map[string]string

+ StatsAggregator []StatsAggregator

+ Volumes []ContainerMount

+ func (c *Container) GetRSU() RSU

+ func (c *Container) SignatureChallenge() ([]byte, error)

+ type ContainerCapacity struct

+ Cpu int64

+ DiskSize uint64

+ DiskType DiskTypeEnum

+ Memory int64

+ func (c ContainerCapacity) GetRSU() RSU

+ func (c ContainerCapacity) SigingEncode(w io.Writer) error

+ type ContainerMount struct

+ Mountpoint string

+ VolumeId string

+ func (c ContainerMount) SigingEncode(w io.Writer) error

+ type DiskTypeEnum uint8

+ const DiskTypeHDD

+ const DiskTypeSSD

+ func (e DiskTypeEnum) String() string

+ type Gateway4To6 struct

+ PublicKey string

+ func (g *Gateway4To6) GetRSU() RSU

+ func (g *Gateway4To6) SignatureChallenge() ([]byte, error)

+ type GatewayDelegate struct

+ Domain string

+ func (d *GatewayDelegate) SignatureChallenge() ([]byte, error)

+ func (g *GatewayDelegate) GetRSU() RSU

+ type GatewayProxy struct

+ Addr string

+ Domain string

+ Port uint32

+ PortTLS uint32

+ func (g *GatewayProxy) GetRSU() RSU

+ func (p *GatewayProxy) SignatureChallenge() ([]byte, error)

+ type GatewayReverseProxy struct

+ Domain string

+ Secret string

+ func (g *GatewayReverseProxy) GetRSU() RSU

+ func (p *GatewayReverseProxy) SignatureChallenge() ([]byte, error)

+ type GatewaySubdomain struct

+ Domain string

+ IPs []string

+ func (g *GatewaySubdomain) GetRSU() RSU

+ func (s *GatewaySubdomain) SignatureChallenge() ([]byte, error)

+ type K8S struct

+ ClusterSecret string

+ Ipaddress net.IP

+ MasterIps []net.IP

+ NetworkId string

+ Size int64

+ SshKeys []string

+ StatsAggregator []StatsAggregator

+ func (k *K8S) GetRSU() RSU

+ func (k *K8S) SignatureChallenge() ([]byte, error)

+ type Logs struct

+ Data LogsRedis

+ Type string

+ func (c Logs) SigingEncode(w io.Writer) error

+ type LogsRedis struct

+ Stderr string

+ Stdout string

+ func (l LogsRedis) SigingEncode(w io.Writer) error

+ type Network struct

+ FarmerTid int64

+ Iprange schema.IPRange

+ Name string

+ NetworkResources []NetworkNetResource

+ StatsAggregator []StatsAggregator

+ WorkloadId int64

+ func (n Network) ToNetworkResources() []NetworkResource

+ func (n Network) WorkloadID() int64

+ type NetworkConnection struct

+ Ipaddress net.IP

+ NetworkId string

+ PublicIp6 bool

+ YggdrasilIP bool

+ func (n NetworkConnection) SigingEncode(w io.Writer) error

+ type NetworkNetResource struct

+ Iprange schema.IPRange

+ NodeId string

+ Peers []WireguardPeer

+ WireguardListenPort int64

+ WireguardPrivateKeyEncrypted string

+ WireguardPublicKey string

+ type NetworkResource struct

+ Iprange schema.IPRange

+ Name string

+ NetworkIprange schema.IPRange

+ Peers []WireguardPeer

+ StatsAggregator []StatsAggregator

+ WireguardListenPort int64

+ WireguardPrivateKeyEncrypted string

+ WireguardPublicKey string

+ func (n *NetworkResource) GetRSU() RSU

+ func (n *NetworkResource) SignatureChallenge() ([]byte, error)

+ type NextActionEnum uint8

+ const NextActionCreate

+ const NextActionDelete

+ const NextActionDeleted

+ const NextActionDeploy

+ const NextActionInvalid

+ const NextActionMigrated

+ const NextActionPay

+ const NextActionSign

+ func (e NextActionEnum) String() string

+ type RSU struct

+ CRU int64

+ HRU float64

+ MRU float64

+ SRU float64

+ type Reservation struct

+ CustomerSignature string

+ CustomerTid int64

+ DataReservation ReservationData

+ Epoch schema.Date

+ ID schema.ID

+ Json string

+ Metadata string

+ NextAction NextActionEnum

+ Results []Result

+ SignaturesDelete []SigningSignature

+ SignaturesFarmer []SigningSignature

+ SignaturesProvision []SigningSignature

+ type ReservationData struct

+ Containers []Container

+ Currencies []string

+ Description string

+ DomainDelegates []GatewayDelegate

+ ExpirationProvisioning schema.Date

+ ExpirationReservation schema.Date

+ Gateway4To6s []Gateway4To6

+ Kubernetes []K8S

+ NetworkResources []NetworkResource

+ Networks []Network

+ Proxies []GatewayProxy

+ ReverseProxy []GatewayReverseProxy

+ SigningRequestDelete SigningRequest

+ SigningRequestProvision SigningRequest

+ Subdomains []GatewaySubdomain

+ Volumes []Volume

+ Zdbs []ZDB

+ type ReservationInfo struct

+ CustomerSignature string

+ CustomerTid int64

+ Description string

+ Epoch schema.Date

+ ID schema.ID

+ Json string

+ Metadata string

+ NextAction NextActionEnum

+ NodeId string

+ PoolId int64

+ Reference string

+ Result Result

+ SignatureFarmer SigningSignature

+ SignaturesDelete []SigningSignature

+ SignaturesProvision []SigningSignature

+ SigningRequestDelete SigningRequest

+ SigningRequestProvision SigningRequest

+ WorkloadId int64

+ WorkloadType WorkloadTypeEnum

+ func (i *ReservationInfo) GetCustomerSignature() string

+ func (i *ReservationInfo) GetCustomerTid() int64

+ func (i *ReservationInfo) GetDescription() string

+ func (i *ReservationInfo) GetEpoch() schema.Date

+ func (i *ReservationInfo) GetID() schema.ID

+ func (i *ReservationInfo) GetJson() string

+ func (i *ReservationInfo) GetMetadata() string

+ func (i *ReservationInfo) GetNextAction() NextActionEnum

+ func (i *ReservationInfo) GetNodeID() string

+ func (i *ReservationInfo) GetPoolID() int64

+ func (i *ReservationInfo) GetReference() string

+ func (i *ReservationInfo) GetResult() Result

+ func (i *ReservationInfo) GetSignatureFarmer() SigningSignature

+ func (i *ReservationInfo) GetSignaturesDelete() []SigningSignature

+ func (i *ReservationInfo) GetSignaturesProvision() []SigningSignature

+ func (i *ReservationInfo) GetSigningRequestDelete() SigningRequest

+ func (i *ReservationInfo) GetSigningRequestProvision() SigningRequest

+ func (i *ReservationInfo) GetWorkloadType() WorkloadTypeEnum

+ func (i *ReservationInfo) PushSignatureDelete(signature SigningSignature)

+ func (i *ReservationInfo) PushSignatureProvision(signature SigningSignature)

+ func (i *ReservationInfo) SetCustomerSignature(signature string)

+ func (i *ReservationInfo) SetCustomerTid(tid int64)

+ func (i *ReservationInfo) SetDescription(description string)

+ func (i *ReservationInfo) SetEpoch(date schema.Date)

+ func (i *ReservationInfo) SetID(id schema.ID)

+ func (i *ReservationInfo) SetJson(json string)

+ func (i *ReservationInfo) SetMetadata(metadata string)

+ func (i *ReservationInfo) SetNextAction(next NextActionEnum)

+ func (i *ReservationInfo) SetPoolID(poolID int64)

+ func (i *ReservationInfo) SetReference(ref string)

+ func (i *ReservationInfo) SetResult(result Result)

+ func (i *ReservationInfo) SetSignatureFarmer(signature SigningSignature)

+ func (i *ReservationInfo) SetSignaturesDelete(signatures []SigningSignature)

+ func (i *ReservationInfo) SetSignaturesProvision(signatures []SigningSignature)

+ func (i *ReservationInfo) SetSigningRequestDelete(request SigningRequest)

+ func (i *ReservationInfo) SetSigningRequestProvision(request SigningRequest)

+ func (i *ReservationInfo) SignatureChallenge() ([]byte, error)

+ func (i *ReservationInfo) UniqueWorkloadID() string

+ func (i *ReservationInfo) WorkloadID() int64

+ type ReservationWorkload struct

+ Content interface{}

+ Created schema.Date

+ Duration int64

+ PoolID int64

+ Signature string

+ ToDelete bool

+ Type WorkloadTypeEnum

+ User string

+ WorkloadId string

+ type Result struct

+ Category WorkloadTypeEnum

+ DataJson json.RawMessage

+ Epoch schema.Date

+ Message string

+ NodeId string

+ Signature string

+ State ResultStateEnum

+ WorkloadId string

+ type ResultStateEnum uint8

+ const ResultStateDeleted

+ const ResultStateError

+ const ResultStateOK

+ func (e ResultStateEnum) String() string

+ type SigningRequest struct

+ QuorumMin int64

+ Signers []int64

+ type SigningSignature struct

+ Epoch schema.Date

+ Signature string

+ Tid int64

+ type StatsAggregator struct

+ Data StatsRedis

+ Type string

+ func (s StatsAggregator) SigingEncode(w io.Writer) error

+ type StatsRedis struct

+ Endpoint string

+ type Volume struct

+ Size int64

+ Type VolumeTypeEnum

+ func (v *Volume) GetRSU() RSU

+ func (v *Volume) SignatureChallenge() ([]byte, error)

+ type VolumeTypeEnum uint8

+ const VolumeTypeHDD

+ const VolumeTypeSSD

+ func (e VolumeTypeEnum) String() string

+ type WireguardPeer struct

+ AllowedIprange []schema.IPRange

+ Endpoint string

+ Iprange schema.IPRange

+ PublicKey string

+ func (p *WireguardPeer) SigingEncode(w io.Writer) error

+ type WorkloadTypeEnum uint8

+ const WorkloadTypeContainer

+ const WorkloadTypeDomainDelegate

+ const WorkloadTypeGateway4To6

+ const WorkloadTypeKubernetes

+ const WorkloadTypeNetwork

+ const WorkloadTypeNetworkResource

+ const WorkloadTypeProxy

+ const WorkloadTypeReverseProxy

+ const WorkloadTypeSubDomain

+ const WorkloadTypeVolume

+ const WorkloadTypeZDB

+ func (e WorkloadTypeEnum) String() string

+ type Workloader interface

+ GetCustomerSignature func() string

+ GetCustomerTid func() int64

+ GetDescription func() string

+ GetEpoch func() schema.Date

+ GetID func() schema.ID

+ GetJson func() string

+ GetMetadata func() string

+ GetNextAction func() NextActionEnum

+ GetNodeID func() string

+ GetPoolID func() int64

+ GetReference func() string

+ GetResult func() Result

+ GetSignatureFarmer func() SigningSignature

+ GetSignaturesDelete func() []SigningSignature

+ GetSignaturesProvision func() []SigningSignature

+ GetSigningRequestDelete func() SigningRequest

+ GetSigningRequestProvision func() SigningRequest

+ GetWorkloadType func() WorkloadTypeEnum

+ PushSignatureDelete func(signature SigningSignature)

+ PushSignatureProvision func(signature SigningSignature)

+ SetCustomerSignature func(signature string)

+ SetCustomerTid func(tid int64)

+ SetDescription func(description string)

+ SetEpoch func(date schema.Date)

+ SetID func(id schema.ID)

+ SetJson func(json string)

+ SetMetadata func(metadata string)

+ SetNextAction func(next NextActionEnum)

+ SetPoolID func(int64)

+ SetReference func(string)

+ SetResult func(result Result)

+ SetSignatureFarmer func(signature SigningSignature)

+ SetSignaturesDelete func(signatuers []SigningSignature)

+ SetSignaturesProvision func(signatures []SigningSignature)

+ SetSigningRequestDelete func(request SigningRequest)

+ SetSigningRequestProvision func(request SigningRequest)

+ SignatureChallenge func() ([]byte, error)

+ UniqueWorkloadID func() string

+ WorkloadID func() int64

+ func UnmarshalBSON(buffer []byte) (Workloader, error)

+ func UnmarshalJSON(buffer []byte) (Workloader, error)

+ type ZDB struct

+ DiskType DiskTypeEnum

+ Mode ZDBModeEnum

+ Password string

+ Public bool

+ Size int64

+ StatsAggregator []StatsAggregator

+ func (z *ZDB) GetRSU() RSU

+ func (z *ZDB) SignatureChallenge() ([]byte, error)

+ type ZDBModeEnum uint8

+ const ZDBModeSeq

+ const ZDBModeUser

+ func (e ZDBModeEnum) String() string

v0.3.1

Jun 3, 2020

v0.3.0

May 12, 2020

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL