spawn

Documentation

Index

• Variables
• type Daemon
• type KubernetesSpawner
  • func NewKubernetes() *KubernetesSpawner
  • func (s *KubernetesSpawner) Get(regionid string, daemonid string) (daemon *Daemon, err error)
  • func (s *KubernetesSpawner) List(regionid string) (daemons []*Daemon, err error)
  • func (s *KubernetesSpawner) Regions() []string
  • func (s *KubernetesSpawner) Shutdown(regionid string, daemonid string) error
  • func (s *KubernetesSpawner) Spawn(d *Daemon) error
• type LocalSpawner
  • func NewLocal(endpoint string) (s *LocalSpawner)
  • func (s *LocalSpawner) Get(regionid string, daemonid string) (*Daemon, error)
  • func (s *LocalSpawner) List(regionid string) ([]*Daemon, error)
  • func (s *LocalSpawner) Regions() []string
  • func (s *LocalSpawner) Shutdown(regionid string, daemonid string) error
  • func (s *LocalSpawner) Spawn(d *Daemon) error
• type Spawner
• type Wallet

Variables

var (
	RegionNotFound = errors.New("region not found")
	DaemonNotFound = errors.New("daemon not found")
)

Types

type Daemon

type Daemon struct {
	Id               string   `json:"id,omitempty"`
	Region           string   `json:"region,omitempty"`
	Tags             []string `json:"tags,omitempty"`
	Workers          int      `json:"workers,omitempty"`
	MinFil           big.Int  `json:"minfil,omitempty"`
	MinCap           big.Int  `json:"mincap,omitempty"`
	DockerRepo       string   `json:"dockerrepo,omitempty"`
	DockerTag        string   `json:"dockerrtag,omitempty"`
	HelmChartVersion string   `json:"helmchartversion,omitempty"`
	HelmChartRepoUrl string   `json:"helmchartrepourl,omitempty"`
	LotusDockerRepo  string   `json:"lotusdockerrepo,omitempty"`
	LotusDockerTag   string   `json:"lotusdockertag,omitempty"`
	Wallet           *Wallet  `json:"wallet,omitempty"`
}

type KubernetesSpawner

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

func NewKubernetes

func NewKubernetes() *KubernetesSpawner

func (*KubernetesSpawner) Get

func (s *KubernetesSpawner) Get(regionid string, daemonid string) (daemon *Daemon, err error)

func (*KubernetesSpawner) List

func (s *KubernetesSpawner) List(regionid string) (daemons []*Daemon, err error)

func (*KubernetesSpawner) Regions

func (s *KubernetesSpawner) Regions() []string

func (*KubernetesSpawner) Shutdown

func (s *KubernetesSpawner) Shutdown(regionid string, daemonid string) error

func (*KubernetesSpawner) Spawn

func (s *KubernetesSpawner) Spawn(d *Daemon) error

type LocalSpawner

type LocalSpawner struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Start dealbot daemons locally

func NewLocal

func NewLocal(endpoint string) (s *LocalSpawner)

func (*LocalSpawner) Get

func (s *LocalSpawner) Get(regionid string, daemonid string) (*Daemon, error)

func (*LocalSpawner) List

func (s *LocalSpawner) List(regionid string) ([]*Daemon, error)

func (*LocalSpawner) Regions

func (s *LocalSpawner) Regions() []string

func (*LocalSpawner) Shutdown

func (s *LocalSpawner) Shutdown(regionid string, daemonid string) error

func (*LocalSpawner) Spawn

func (s *LocalSpawner) Spawn(d *Daemon) error

type Spawner

type Spawner interface {
	Spawn(*Daemon) error
	Get(string, string) (*Daemon, error)
	Shutdown(string, string) error
	List(string) ([]*Daemon, error)
	Regions() []string
}

type Wallet

type Wallet struct {
	Address  string `json:"address,omitempty"`
	Exported string `json:"exported,omitempty"`
}