cluster

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 16, 2020 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetArgs 

func GetArgs() map[string]string

GetArgs gets the cluster arguments

func GetArgsAsEnv 

func GetArgsAsEnv(args map[string]string) map[string]string

GetArgsAsEnv returns the given arguments as an environment variable map

func SetArg 

func SetArg(name, value string)

SetArg sets the value of an argument

func SetArgs 

func SetArgs(args map[string]string)

SetArgs sets the cluster arguments

Types

type App 

type App struct {
	*Service
}

App provides methods for adding and modifying applications

type Apps 

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

Apps provides methods for adding and modifying applications

func (*Apps) Get 

func (s *Apps) Get(name string) *App

Get gets an app by name

func (*Apps) List 

func (s *Apps) List() []*App

List lists the networks in the cluster

func (*Apps) New 

func (s *Apps) New() *App

New returns a new app

type Arg 

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

Arg is a cluster argument

func GetArg 

func GetArg(names ...string) *Arg

GetArg gets the value of an argument

func (*Arg) Bool 

func (a *Arg) Bool(def bool) bool

Bool returns the argument as a bool

func (*Arg) Int 

func (a *Arg) Int(def int) int

Int returns the argument as an int

func (*Arg) String 

func (a *Arg) String(def string) string

String returns the argument as a string

type Atomix 

type Atomix struct {
	*Deployment
}

Atomix provides methods for managing the Atomix controller

func (*Atomix) Setup 

func (s *Atomix) Setup() error

Setup sets up the Atomix controller and associated resources

type CLI 

type CLI struct {
	*Deployment
	// contains filtered or unexported fields
}

CLI provides methods for managing the onos-cli service

func (*CLI) AwaitReady 

func (c *CLI) AwaitReady() error

AwaitReady waits for the onos-cli pods to complete startup

func (*CLI) Enabled 

func (c *CLI) Enabled() bool

Enabled indicates whether the CLI is enabled

func (*CLI) SetEnabled 

func (c *CLI) SetEnabled(enabled bool)

SetEnabled sets whether the CLI is enabled

func (*CLI) Setup 

func (c *CLI) Setup() error

Setup sets up the CLI subsystem

type Cluster 

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

Cluster facilitates modifying subsystems in Kubernetes

func New 

func New(kube kube.API) *Cluster

New returns a new onit Env

func (*Cluster) Apps 

func (c *Cluster) Apps() *Apps

Apps returns the cluster applications

func (*Cluster) Atomix 

func (c *Cluster) Atomix() *Atomix

Atomix returns the Atomix service

func (*Cluster) CLI 

func (c *Cluster) CLI() *CLI

CLI returns the CLI service

func (*Cluster) Config 

func (c *Cluster) Config() *Config

Config returns the configuration service

func (*Cluster) Database 

func (c *Cluster) Database() *Storage

Database returns the database service

func (*Cluster) History 

func (c *Cluster) History() *History

History returns the cluster history

func (*Cluster) Networks 

func (c *Cluster) Networks() *Networks

Networks returns the cluster networks

func (*Cluster) RIC 

func (c *Cluster) RIC() *RIC

RIC returns the ran service

func (*Cluster) Simulators 

func (c *Cluster) Simulators() *Simulators

Simulators returns the cluster simulators

func (*Cluster) Topo 

func (c *Cluster) Topo() *Topo

Topo returns the topo service

type Config 

type Config struct {
	*Service
}

Config provides methods for managing the onos-config service

type Database 

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

Database provides methods for adding and modifying a database

func (*Database) AwaitReady 

func (s *Database) AwaitReady() error

AwaitReady waits for database to complete startup

func (*Database) Connect 

func (s *Database) Connect() (*atomix.Database, error)

Connect connects to the database

func (*Database) NOPaxos 

func (s *Database) NOPaxos() *NOPaxosDatabase

NOPaxos returns new NOPaxosDatabase

func (*Database) Name 

func (s *Database) Name() string

Name returns the database name

func (*Database) Partition 

func (s *Database) Partition(name string) *Partition

Partition gets a partition by name

func (*Database) Partitions 

func (s *Database) Partitions() []*Partition

Partitions lists the partitions in the database

func (*Database) Raft 

func (s *Database) Raft() *RaftDatabase

Raft returns new RaftDatabase

func (*Database) Setup 

func (s *Database) Setup() error

Setup sets up a database

type Deployment 

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

Deployment is a collection of nodes

func (*Deployment) AwaitReady 

func (d *Deployment) AwaitReady() error

AwaitReady waits for the nodes to become ready

func (*Deployment) Execute 

func (d *Deployment) Execute(command ...string) ([]string, int, error)

Execute executes the given command on one of the service nodes

func (*Deployment) Image 

func (d *Deployment) Image() string

Image returns the image for the service

func (*Deployment) Name 

func (d *Deployment) Name() string

Name returns the deployment name

func (*Deployment) Node 

func (d *Deployment) Node(name string) (*Node, error)

Node gets a node by name

func (*Deployment) Nodes 

func (d *Deployment) Nodes() ([]*Node, error)

Nodes returns a list of nodes in the service

func (*Deployment) PullPolicy 

func (d *Deployment) PullPolicy() corev1.PullPolicy

PullPolicy returns the image pull policy for the service

func (*Deployment) SetCluster 

func (d *Deployment) SetCluster(cluster *Cluster)

SetCluster sets the cluster for the service

func (*Deployment) SetImage 

func (d *Deployment) SetImage(image string)

SetImage sets the image for the service

func (*Deployment) SetLabels 

func (d *Deployment) SetLabels(labels map[string]string)

SetLabels sets the labels for the service

func (*Deployment) SetName 

func (d *Deployment) SetName(name string)

SetName sets the name for the service

func (*Deployment) SetPullPolicy 

func (d *Deployment) SetPullPolicy(pullPolicy corev1.PullPolicy)

SetPullPolicy sets the image pull policy for the service

type History 

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

History provides methods for retrieving history of tests and benchmarks

func (*History) GetBenchmarksMap 

func (h *History) GetBenchmarksMap() map[string]JobInfo

GetBenchmarksMap gets a maps of benchmarks

func (*History) GetTestsMap 

func (h *History) GetTestsMap() map[string]JobInfo

GetTestsMap gets a map of test jobs

func (*History) ListBenchmarks 

func (h *History) ListBenchmarks() []JobInfo

ListBenchmarks gets list of all benchmarks

func (*History) ListTests 

func (h *History) ListTests() []JobInfo

ListTests gets list of all tests

func (*History) New 

func (h *History) New() *History

New returns a new history

type JobInfo 

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

JobInfo k8s job info

func (*JobInfo) GetEnvVar 

func (j *JobInfo) GetEnvVar() map[string]string

GetEnvVar gets the job environment variables

func (*JobInfo) GetJobImage 

func (j *JobInfo) GetJobImage() string

GetJobImage gets job image

func (*JobInfo) GetJobName 

func (j *JobInfo) GetJobName() string

GetJobName gets job name

func (*JobInfo) GetJobStatus 

func (j *JobInfo) GetJobStatus() string

GetJobStatus gets job status

func (*JobInfo) GetJobType 

func (j *JobInfo) GetJobType() string

GetJobType gets job type

type NOPaxosDatabase 

type NOPaxosDatabase struct {
	*Database
	// contains filtered or unexported fields
}

NOPaxosDatabase provides methods for adding and modifying NOPaxos partitions

func (*NOPaxosDatabase) AwaitReady 

func (s *NOPaxosDatabase) AwaitReady() error

AwaitReady waits for partitions to complete startup

func (*NOPaxosDatabase) Connect 

func (s *NOPaxosDatabase) Connect() (*atomix.PartitionGroup, error)

Connect connects to the partition group

func (*NOPaxosDatabase) NumPartitions 

func (s *NOPaxosDatabase) NumPartitions() int

NumPartitions returns the number of partitions

func (*NOPaxosDatabase) ReplicaImage 

func (s *NOPaxosDatabase) ReplicaImage() string

ReplicaImage returns the image for the partition group

func (*NOPaxosDatabase) ReplicaPullPolicy 

func (s *NOPaxosDatabase) ReplicaPullPolicy() corev1.PullPolicy

ReplicaPullPolicy returns the image pull policy for the partition group

func (*NOPaxosDatabase) Replicas 

func (s *NOPaxosDatabase) Replicas() int

Replicas returns the number of replicas in each partition

func (*NOPaxosDatabase) SequencerImage 

func (s *NOPaxosDatabase) SequencerImage() string

SequencerImage returns the image for the partition group

func (*NOPaxosDatabase) SequencerPullPolicy 

func (s *NOPaxosDatabase) SequencerPullPolicy() corev1.PullPolicy

SequencerPullPolicy returns the image pull policy for the partition group

func (*NOPaxosDatabase) SetPartitions 

func (s *NOPaxosDatabase) SetPartitions(partitions int)

SetPartitions sets the number of partitions in the group

func (*NOPaxosDatabase) SetReplicaImage 

func (s *NOPaxosDatabase) SetReplicaImage(image string)

SetReplicaImage sets the image for the partition group replicas

func (*NOPaxosDatabase) SetReplicaPullPolicy 

func (s *NOPaxosDatabase) SetReplicaPullPolicy(pullPolicy corev1.PullPolicy)

SetReplicaPullPolicy sets the image pull policy for the partition group

func (*NOPaxosDatabase) SetReplicas 

func (s *NOPaxosDatabase) SetReplicas(replicas int)

SetReplicas sets the number of nodes in each partition

func (*NOPaxosDatabase) SetSequencerImage 

func (s *NOPaxosDatabase) SetSequencerImage(image string)

SetSequencerImage sets the image for the partition group sequencer

func (*NOPaxosDatabase) SetSequencerPullPolicy 

func (s *NOPaxosDatabase) SetSequencerPullPolicy(pullPolicy corev1.PullPolicy)

SetSequencerPullPolicy sets the image pull policy for the partition group

func (*NOPaxosDatabase) Setup 

func (s *NOPaxosDatabase) Setup() error

Setup sets up a NOPaxos database

type Network 

type Network struct {
	// TODO: Network should be a Service with a Node per device
	*Node
	// contains filtered or unexported fields
}

Network is an implementation of the Network interface

func (*Network) AddDevices 

func (s *Network) AddDevices() bool

AddDevices returns whether to add the devices to the topo service

func (*Network) DeviceTimeout 

func (s *Network) DeviceTimeout() *time.Duration

DeviceTimeout returns the device timeout

func (*Network) DeviceType 

func (s *Network) DeviceType() string

DeviceType returns the device type

func (*Network) DeviceVersion 

func (s *Network) DeviceVersion() string

DeviceVersion returns the device version

func (*Network) Devices 

func (s *Network) Devices() ([]*Node, error)

Devices returns a list of devices in the network

func (*Network) SetAddDevices 

func (s *Network) SetAddDevices(add bool)

SetAddDevices sets whether to add the devices to the topo service

func (*Network) SetDeviceTimeout 

func (s *Network) SetDeviceTimeout(timeout time.Duration)

SetDeviceTimeout sets the device timeout

func (*Network) SetDeviceType 

func (s *Network) SetDeviceType(deviceType string)

SetDeviceType sets the device type

func (*Network) SetDeviceVersion 

func (s *Network) SetDeviceVersion(version string)

SetDeviceVersion sets the device version

func (*Network) SetLinear 

func (s *Network) SetLinear(devices int) *Network

SetLinear sets the network to a linear topology

func (*Network) SetSingle 

func (s *Network) SetSingle() *Network

SetSingle sets the network topology to single

func (*Network) SetTopo 

func (s *Network) SetTopo(topo string, devices int) *Network

SetTopo sets the network topology

func (*Network) Setup 

func (s *Network) Setup() error

Setup sets up the network

func (*Network) TearDown 

func (s *Network) TearDown() error

TearDown removes the network from the cluster

type Networks 

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

Networks provides methods for adding and modifying networks

func (*Networks) Get 

func (s *Networks) Get(name string) *Network

Get gets a network by name

func (*Networks) List 

func (s *Networks) List() []*Network

List lists the networks in the cluster

func (*Networks) New 

func (s *Networks) New() *Network

New returns a new network

type Node 

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

Node provides the environment for a single node

func (*Node) Address 

func (n *Node) Address() string

Address returns the service address

func (*Node) AwaitReady 

func (n *Node) AwaitReady() error

AwaitReady waits for the node to become ready

func (*Node) Connect 

func (n *Node) Connect() (*grpc.ClientConn, error)

Connect creates a gRPC client connection to the node

func (*Node) Credentials 

func (n *Node) Credentials() (*tls.Config, error)

Credentials returns the TLS credentials

func (*Node) Delete 

func (n *Node) Delete() error

Delete deletes the node

func (*Node) Execute 

func (n *Node) Execute(command ...string) ([]string, int, error)

Execute executes the given command on the node

func (*Node) Image 

func (n *Node) Image() string

Image returns the image configured for the node

func (*Node) Name 

func (n *Node) Name() string

Name returns the node name

func (*Node) Port 

func (n *Node) Port() int

Port returns the node port

func (*Node) PullPolicy 

func (n *Node) PullPolicy() corev1.PullPolicy

PullPolicy returns the image pull policy configured for the node

func (*Node) SetImage 

func (n *Node) SetImage(image string)

SetImage sets the node image

func (*Node) SetName 

func (n *Node) SetName(name string)

SetName sets the node name

func (*Node) SetPort 

func (n *Node) SetPort(port int)

SetPort sets the node port

func (*Node) SetPullPolicy 

func (n *Node) SetPullPolicy(pullPolicy corev1.PullPolicy)

SetPullPolicy sets the image pull policy for the node

type Partition 

type Partition struct {
	*Deployment
}

Partition provides methods for querying a database partition

type Port 

type Port struct {
	Name string
	Port int
}

Port is a service port

type RIC 

type RIC struct {
	*Service
	// contains filtered or unexported fields
}

RIC provides methods for managing the onos-ric service

func (*RIC) Enabled 

func (c *RIC) Enabled() bool

Enabled indicates whether the Ric is enabled

func (*RIC) SetEnabled 

func (c *RIC) SetEnabled(enabled bool)

SetEnabled sets whether the Ric is enabled

type RaftDatabase 

type RaftDatabase struct {
	*Database
	// contains filtered or unexported fields
}

RaftDatabase provides methods for adding and modifying Raft partitions

func (*RaftDatabase) AwaitReady 

func (s *RaftDatabase) AwaitReady() error

AwaitReady waits for partitions to complete startup

func (*RaftDatabase) Clusters 

func (s *RaftDatabase) Clusters() int

Clusters returns the number of clusters in each partition

func (*RaftDatabase) Connect 

func (s *RaftDatabase) Connect() (*atomix.PartitionGroup, error)

Connect connects to the partition group

func (*RaftDatabase) Image 

func (s *RaftDatabase) Image() string

Image returns the image for the partition group

func (*RaftDatabase) NumPartitions 

func (s *RaftDatabase) NumPartitions() int

NumPartitions returns the number of partitions

func (*RaftDatabase) PullPolicy 

func (s *RaftDatabase) PullPolicy() corev1.PullPolicy

PullPolicy returns the image pull policy for the partition group

func (*RaftDatabase) Replicas 

func (s *RaftDatabase) Replicas() int

Replicas returns the number of replicas in each partition

func (*RaftDatabase) SetClusters 

func (s *RaftDatabase) SetClusters(clusters int)

SetClusters sets the number of clusters in each partition

func (*RaftDatabase) SetImage 

func (s *RaftDatabase) SetImage(image string)

SetImage sets the image for the partition group

func (*RaftDatabase) SetPartitions 

func (s *RaftDatabase) SetPartitions(partitions int)

SetPartitions sets the number of partitions in the group

func (*RaftDatabase) SetPullPolicy 

func (s *RaftDatabase) SetPullPolicy(pullPolicy corev1.PullPolicy)

SetPullPolicy sets the image pull policy for the partition group

func (*RaftDatabase) SetReplicas 

func (s *RaftDatabase) SetReplicas(replicas int)

SetReplicas sets the number of nodes in each partition

func (*RaftDatabase) Setup 

func (s *RaftDatabase) Setup() error

Setup sets up a database

type Service 

type Service struct {
	*Deployment
	// contains filtered or unexported fields
}

Service is the base type for multi-node services

func (*Service) AddEnv 

func (s *Service) AddEnv(name, value string)

AddEnv adds an environment variable

func (*Service) AddPort 

func (s *Service) AddPort(name string, port int)

AddPort adds a port to the service

func (*Service) AddSecret 

func (s *Service) AddSecret(name, secret string)

AddSecret adds a secret to the service

func (*Service) Address 

func (s *Service) Address(port string) string

Address returns the service address for the given port

func (*Service) Args 

func (s *Service) Args() []string

Args returns the service arguments

func (*Service) AwaitReady 

func (s *Service) AwaitReady() error

AwaitReady waits for the service to complete startup

func (*Service) CPULimit 

func (s *Service) CPULimit() string

CPULimit returns cpu limit for a deployment container

func (*Service) CPURequest 

func (s *Service) CPURequest() string

CPURequest returns the cpu request for a deployment container

func (*Service) Connect 

func (s *Service) Connect(port string) (*grpc.ClientConn, error)

Connect creates a gRPC client connection to the service

func (*Service) Credentials 

func (s *Service) Credentials() (*tls.Config, error)

Credentials returns the TLS credentials

func (*Service) Debug 

func (s *Service) Debug() bool

Debug returns whether debug is enabled

func (*Service) Env 

func (s *Service) Env() map[string]string

Env returns the service environment

func (*Service) MemoryLimit 

func (s *Service) MemoryLimit() string

MemoryLimit returns the memory limit for a deployment container

func (*Service) MemoryRequest 

func (s *Service) MemoryRequest() string

MemoryRequest returns the memory request for a deployment container

func (*Service) Ports 

func (s *Service) Ports() []Port

Ports returns the service ports

func (*Service) Privileged 

func (s *Service) Privileged() bool

Privileged returns whether to run the service in privileged mode

func (*Service) Replicas 

func (s *Service) Replicas() int

Replicas returns the number of nodes in the service

func (*Service) Secrets 

func (s *Service) Secrets() map[string]string

Secrets returns the service secrets

func (*Service) SetArgs 

func (s *Service) SetArgs(args ...string)

SetArgs sets the service arguments

func (*Service) SetCPULimit 

func (s *Service) SetCPULimit(cpuLimit string)

SetCPULimit sets cpu limit for a deployment container

func (*Service) SetCPURequest 

func (s *Service) SetCPURequest(cpuRequest string)

SetCPURequest sets cpu request for a deployment container

func (*Service) SetDebug 

func (s *Service) SetDebug(debug bool)

SetDebug sets whether debug is enabled

func (*Service) SetEnv 

func (s *Service) SetEnv(env map[string]string)

SetEnv sets the service environment

func (*Service) SetMemoryLimit 

func (s *Service) SetMemoryLimit(memoryLimit string)

SetMemoryLimit sets memory limit for a deployment container

func (*Service) SetMemoryRequest 

func (s *Service) SetMemoryRequest(memoryRequest string)

SetMemoryRequest sets memory request for a deployment container

func (*Service) SetPorts 

func (s *Service) SetPorts(ports []Port)

SetPorts sets the service ports

func (*Service) SetPrivileged 

func (s *Service) SetPrivileged(privileged bool)

SetPrivileged sets whether to run the service in privileged mode

func (*Service) SetReplicas 

func (s *Service) SetReplicas(replicas int)

SetReplicas sets the number of nodes in the service

func (*Service) SetSecrets 

func (s *Service) SetSecrets(secrets map[string]string)

SetSecrets sets the service secrets

func (*Service) SetSidecars 

func (s *Service) SetSidecars(sidecars []*Sidecar)

SetSidecars sets the service sidecars

func (*Service) SetUser 

func (s *Service) SetUser(user int)

SetUser sets the user with which to run the service

func (*Service) SetVolume 

func (s *Service) SetVolume(volume ...corev1.VolumeMount)

SetVolume sets service volumes

func (*Service) Setup 

func (s *Service) Setup() error

Setup sets up the service

func (*Service) Sidecars 

func (s *Service) Sidecars() []*Sidecar

Sidecars returns the service sidecars

func (*Service) TearDown 

func (s *Service) TearDown() error

TearDown removes the service from the cluster

func (*Service) User 

func (s *Service) User() *int

User returns the user with which to run the service

func (*Service) Volume 

func (s *Service) Volume() []corev1.VolumeMount

Volume returns the service volume

type Sidecar 

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

Sidecar provides methods for adding sidecar containers to a deployment

func (*Sidecar) AddEnv 

func (s *Sidecar) AddEnv(name, value string)

AddEnv adds an environment variable

func (*Sidecar) Args 

func (s *Sidecar) Args() []string

Args returns the container arguments

func (*Sidecar) Command 

func (s *Sidecar) Command() []string

Command returns the sidecar container command

func (*Sidecar) Env 

func (s *Sidecar) Env() map[string]string

Env returns the sidecar container environment variables

func (*Sidecar) Image 

func (s *Sidecar) Image() string

Image returns the image for the sidecar container

func (*Sidecar) Name 

func (s *Sidecar) Name() string

Name returns the sidecar container name

func (*Sidecar) PullPolicy 

func (s *Sidecar) PullPolicy() corev1.PullPolicy

PullPolicy returns the image pull policy for the container

func (*Sidecar) SetArgs 

func (s *Sidecar) SetArgs(args ...string)

SetArgs sets the sidecar container arguments

func (*Sidecar) SetCommand 

func (s *Sidecar) SetCommand(command ...string)

SetCommand sets the sidecar container command

func (*Sidecar) SetEnv 

func (s *Sidecar) SetEnv(env map[string]string)

SetEnv sets the sidecar container environment variables

func (*Sidecar) SetImage 

func (s *Sidecar) SetImage(image string)

SetImage sets the container image

func (*Sidecar) SetName 

func (s *Sidecar) SetName(name string)

SetName sets the container name

func (*Sidecar) SetPullPolicy 

func (s *Sidecar) SetPullPolicy(pullPolicy corev1.PullPolicy)

SetPullPolicy sets the image pull policy for the container

func (*Sidecar) SetVolume 

func (s *Sidecar) SetVolume(volume ...corev1.VolumeMount)

SetVolume sets sidecar containers volumes

func (*Sidecar) Volume 

func (s *Sidecar) Volume() []corev1.VolumeMount

Volume returns the sidecar container volume

type Simulator 

type Simulator struct {
	*Node
	// contains filtered or unexported fields
}

Simulator provides methods for adding and modifying simulators

func (*Simulator) AddDevice 

func (s *Simulator) AddDevice() bool

AddDevice returns whether to add the device to the topo service

func (*Simulator) AwaitDevicePredicate 

func (s *Simulator) AwaitDevicePredicate(predicate func(*device.Device) bool, timeout time.Duration) error

AwaitDevicePredicate waits for the given device predicate

func (*Simulator) DeviceTimeout 

func (s *Simulator) DeviceTimeout() *time.Duration

DeviceTimeout returns the device timeout

func (*Simulator) DeviceType 

func (s *Simulator) DeviceType() string

DeviceType returns the device type

func (*Simulator) DeviceVersion 

func (s *Simulator) DeviceVersion() string

DeviceVersion returns the device version

func (*Simulator) SetAddDevice 

func (s *Simulator) SetAddDevice(add bool)

SetAddDevice sets whether to add the device to the topo service

func (*Simulator) SetDeviceTimeout 

func (s *Simulator) SetDeviceTimeout(timeout time.Duration)

SetDeviceTimeout sets the device timeout

func (*Simulator) SetDeviceType 

func (s *Simulator) SetDeviceType(deviceType string)

SetDeviceType sets the device type

func (*Simulator) SetDeviceVersion 

func (s *Simulator) SetDeviceVersion(version string)

SetDeviceVersion sets the device version

func (*Simulator) Setup 

func (s *Simulator) Setup() error

Setup adds the simulator to the cluster

func (*Simulator) TearDown 

func (s *Simulator) TearDown() error

TearDown removes the simulator from the cluster

type Simulators 

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

Simulators provides methods for adding and modifying simulators

func (*Simulators) Get 

func (s *Simulators) Get(name string) *Simulator

Get gets a simulator by name

func (*Simulators) List 

func (s *Simulators) List() []*Simulator

List lists the simulators in the cluster

func (*Simulators) New 

func (s *Simulators) New() *Simulator

New returns a new simulator

type Status 

type Status int

Status job status 

const (
	// Succeeded status
	Succeeded Status = iota
	// Failed status
	Failed
	// Running status
	Running
	// Pending status
	Pending
	// Unknown status
	Unknown
)

func (Status) String 

func (s Status) String() string

type Storage 

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

Storage provides methods for managing Atomix storage

func (*Storage) Database 

func (s *Storage) Database(name string) *Database

Database returns a database by name

type Topo 

type Topo struct {
	*Service
}

Topo provides methods for managing the onos-topo service

type TopoType 

type TopoType int

TopoType topology type 

const (
	// Single node topology
	Single TopoType = iota
	// Linear linear topology type
	Linear
	// Custom topology type
	Custom
)

func (TopoType) String 

func (d TopoType) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.