k8s

Documentation

Index

• type Kubernetes
  • func (k8s *Kubernetes) AddToDiscovery() error
  • func (k8s *Kubernetes) DeleteELKDNSRecords() error
  • func (k8s *Kubernetes) DeleteMiner(minerNumber string) error
  • func (k8s *Kubernetes) DeleteSpacemeshWatch() error
  • func (k8s *Kubernetes) DeleteWSDNSRecords() error
  • func (k8s *Kubernetes) DeployChaosMesh() error
  • func (k8s *Kubernetes) DeployELK() error
  • func (k8s *Kubernetes) DeployFilebeatForWS() error
  • func (k8s *Kubernetes) DeployMiner(bootstrapNode bool, minerNumber string, configJSON string, selectedNode string, ...)
  • func (k8s *Kubernetes) DeployPoet(initialDuration string, poetNumber string, configFile string, ...)
  • func (k8s *Kubernetes) DeployPyroscope() error
  • func (k8s *Kubernetes) DeploySpacemeshWatch() error
  • func (k8s *Kubernetes) DeployWS() error
  • func (k8s *Kubernetes) DisablePodRescheduling() error
  • func (k8s *Kubernetes) GetESURL() (string, error)
  • func (k8s *Kubernetes) GetExternalIP() (string, error)
  • func (k8s *Kubernetes) GetExternalPort(serviceId string, portName string) (string, error)
  • func (k8s *Kubernetes) GetKibanaPassword() (string, error)
  • func (k8s *Kubernetes) GetKibanaURL() (string, error)
  • func (k8s *Kubernetes) GetMinerImage(name string) (string, error)
  • func (k8s *Kubernetes) GetMiners() ([]string, error)
  • func (k8s *Kubernetes) GetPVCs() ([]string, error)
  • func (k8s *Kubernetes) GetPyroscopeURL() (string, error)
  • func (k8s *Kubernetes) GetSecret(name string, dataName string) (string, error)
  • func (k8s *Kubernetes) MinerAccounts() ([]string, error)
  • func (k8s *Kubernetes) NextMinerName() (string, error)
  • func (k8s *Kubernetes) NextNode() (string, error)
  • func (k8s *Kubernetes) RemoveFromDiscovery() error
  • func (k8s *Kubernetes) SetupLogDeletionPolicy() error
  • func (k8s *Kubernetes) SetupLogDeletionPolicyForWS() error
  • func (k8s *Kubernetes) UpdateImageOfMiners(name string) error
• type MinerChannel
• type MinerDeploymentData
• type Network
• type PoetChannel
• type PoetDeploymentData

Types

type Kubernetes

type Kubernetes struct {
	Client      *kubernetes.Clientset
	RestConfig  *restclient.Config
	CurrentNode int

	Password string
	// contains filtered or unexported fields
}

func (*Kubernetes) AddToDiscovery

func (k8s *Kubernetes) AddToDiscovery() error

func (*Kubernetes) DeleteELKDNSRecords

func (k8s *Kubernetes) DeleteELKDNSRecords() error

func (*Kubernetes) DeleteMiner

func (k8s *Kubernetes) DeleteMiner(minerNumber string) error

func (*Kubernetes) DeleteSpacemeshWatch

func (k8s *Kubernetes) DeleteSpacemeshWatch() error

func (*Kubernetes) DeleteWSDNSRecords

func (k8s *Kubernetes) DeleteWSDNSRecords() error

func (*Kubernetes) DeployChaosMesh

func (k8s *Kubernetes) DeployChaosMesh() error

func (*Kubernetes) DeployELK

func (k8s *Kubernetes) DeployELK() error

func (*Kubernetes) DeployFilebeatForWS

func (k8s *Kubernetes) DeployFilebeatForWS() error

func (*Kubernetes) DeployMiner

func (k8s *Kubernetes) DeployMiner(bootstrapNode bool, minerNumber string, configJSON string, selectedNode string, channel *MinerChannel)

func (*Kubernetes) DeployPoet

func (k8s *Kubernetes) DeployPoet(initialDuration string, poetNumber string, configFile string, channel *PoetChannel)

func (*Kubernetes) DeployPyroscope

func (k8s *Kubernetes) DeployPyroscope() error

func (*Kubernetes) DeploySpacemeshWatch

func (k8s *Kubernetes) DeploySpacemeshWatch() error

func (*Kubernetes) DeployWS

func (k8s *Kubernetes) DeployWS() error

func (*Kubernetes) DisablePodRescheduling

func (k8s *Kubernetes) DisablePodRescheduling() error

func (*Kubernetes) GetESURL

func (k8s *Kubernetes) GetESURL() (string, error)

func (*Kubernetes) GetExternalIP

func (k8s *Kubernetes) GetExternalIP() (string, error)

func (*Kubernetes) GetExternalPort

func (k8s *Kubernetes) GetExternalPort(serviceId string, portName string) (string, error)

func (*Kubernetes) GetKibanaPassword

func (k8s *Kubernetes) GetKibanaPassword() (string, error)

func (*Kubernetes) GetKibanaURL

func (k8s *Kubernetes) GetKibanaURL() (string, error)

func (*Kubernetes) GetMinerImage

func (k8s *Kubernetes) GetMinerImage(name string) (string, error)

func (*Kubernetes) GetMiners

func (k8s *Kubernetes) GetMiners() ([]string, error)

func (*Kubernetes) GetPVCs

func (k8s *Kubernetes) GetPVCs() ([]string, error)

func (*Kubernetes) GetPyroscopeURL

func (k8s *Kubernetes) GetPyroscopeURL() (string, error)

func (*Kubernetes) GetSecret

func (k8s *Kubernetes) GetSecret(name string, dataName string) (string, error)

func (*Kubernetes) MinerAccounts

func (k8s *Kubernetes) MinerAccounts() ([]string, error)

func (*Kubernetes) NextMinerName

func (k8s *Kubernetes) NextMinerName() (string, error)

func (*Kubernetes) NextNode

func (k8s *Kubernetes) NextNode() (string, error)

func (*Kubernetes) RemoveFromDiscovery

func (k8s *Kubernetes) RemoveFromDiscovery() error

func (*Kubernetes) SetupLogDeletionPolicy

func (k8s *Kubernetes) SetupLogDeletionPolicy() error

func (*Kubernetes) SetupLogDeletionPolicyForWS

func (k8s *Kubernetes) SetupLogDeletionPolicyForWS() error

func (*Kubernetes) UpdateImageOfMiners

func (k8s *Kubernetes) UpdateImageOfMiners(name string) error

type MinerChannel

type MinerChannel struct {
	Err  chan error
	Done chan *MinerDeploymentData
}

type MinerDeploymentData

type MinerDeploymentData struct {
	TcpURL  string
	GrpcURL string
}

type Network

type Network struct {
	NetName              string  `json:"netName"`
	NetID                float64 `json:"netID"`
	Conf                 string  `json:"conf"`
	GrpcApi              string  `json:"grpcAPI"`
	JsonApi              string  `json:"jsonAPI"`
	Explorer             string  `json:"explorer"`
	ExplorerAPI          string  `json:"explorerAPI"`
	ExplorerVersion      string  `json:"explorerVersion"`
	ExplorerConf         string  `json:"explorerConf"`
	Dash                 string  `json:"dash"`
	DashApi              string  `json:"dashAPI"`
	DashVersion          string  `json:"dashVersion"`
	Repository           string  `json:"repository"`
	MinNodeVersion       string  `json:"minNodeVersion"`
	MaxNodeVersion       string  `json:"maxNodeVersion"`
	MinSmappRelease      string  `json:"minSmappRelease"`
	LatestSmappRelease   string  `json:"latestSmappRelease"`
	SmappBaseDownloadUrl string  `json:"smappBaseDownloadUrl"`
	NodeBaseDownloadUrl  string  `json:"nodeBaseDownloadUrl"`
}

type PoetChannel

type PoetChannel struct {
	Err  chan error
	Done chan *PoetDeploymentData
}

type PoetDeploymentData

type PoetDeploymentData struct {
	RestURL string
}