topo

package

v0.0.0-...-45f8ed2 Latest Latest Go to latest Published: Feb 15, 2024 License: Apache-2.0 Imports: 40 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/drivenets/kne

Documentation ¶

Index ¶

func Load(path string) (*tpb.Topology, error)
type Manager
- func New(topo *tpb.Topology, opts ...Option) (*Manager, error)
type Option
type Resources

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

Types ¶

type Manager ¶

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

Manager is a topology manager for a cluster instance.

func New ¶

func New(topo *tpb.Topology, opts ...Option) (*Manager, error)

New creates a new Manager based on the provided topology. The cluster config passed from the WithClusterConfig option overrides the determined in-cluster config. If neither of these configurations can be used then the kubecfg passed from the WithKubecfg option will be used to determine the cluster config.

func (*Manager) ConfigPush ¶

func (m *Manager) ConfigPush(ctx context.Context, nodeName string, r io.Reader) error

ConfigPush will push config to the provided node. If the node does not fulfill ConfigPusher then status.Unimplemented error will be returned.

func (*Manager) Create ¶

func (m *Manager) Create(ctx context.Context, timeout time.Duration) (rerr error)

Create creates the topology in the cluster.

func (*Manager) Delete ¶

func (m *Manager) Delete(ctx context.Context) error

Delete deletes the topology from the cluster.

func (*Manager) GenerateSelfSigned ¶

func (m *Manager) GenerateSelfSigned(ctx context.Context, nodeName string) error

GenerateSelfSigned will create self signed certs on the provided node. If the node does not have cert info then it is a noop. If the node does not fulfill Certer then status.Unimplemented error will be returned.

func (*Manager) Nodes ¶

func (m *Manager) Nodes() map[string]node.Node

Nodes returns a map of node names to implementations in the current topology.

func (*Manager) ResetCfg ¶

func (m *Manager) ResetCfg(ctx context.Context, nodeName string) error

ResetCfg will reset the config for the provided node. If the node does not fulfill Resetter then status.Unimplemented error will be returned.

func (*Manager) Resources ¶

func (m *Manager) Resources(ctx context.Context) (*Resources, error)

Resources gets the currently configured resources from the topology.

func (*Manager) Show ¶

func (m *Manager) Show(ctx context.Context) (*cpb.ShowTopologyResponse, error)

Show returns the topology information including services and node health.

func (*Manager) Watch ¶

func (m *Manager) Watch(ctx context.Context) error

type Option ¶

type Option func(m *Manager)

func WithBasePath ¶

func WithBasePath(s string) Option

func WithClusterConfig ¶

func WithClusterConfig(r *rest.Config) Option

func WithKubeClient ¶

func WithKubeClient(c kubernetes.Interface) Option

func WithKubecfg ¶

func WithKubecfg(k string) Option

func WithProgress ¶

func WithProgress(b bool) Option

WithProgress returns a Manager Option where true causes pod progress to be displayed.

func WithSkipDeleteWait ¶

func WithSkipDeleteWait(b bool) Option

WithSkipDeleteWait will not wait for resources to be cleaned up before Delete returns.

func WithTopoClient ¶

func WithTopoClient(c topologyclientv1.Interface) Option

func WithUsageReporting ¶

func WithUsageReporting(b bool, project, topic string) Option

WithUsageReporting writes anonymous usage metrics.

type Resources ¶

type Resources struct {
	Services   map[string][]*corev1.Service
	Pods       map[string][]*corev1.Pod
	ConfigMaps map[string]*corev1.ConfigMap
	Topologies map[string]*topologyv1.Topology
}

Source Files ¶

View all Source files

topo.go

Directories ¶

Path	Synopsis
node
alpine
arista
cisco
drivenets Package drivenets implmements node definitions for nodes from the Drivenets vendor.	Package drivenets implmements node definitions for nodes from the Drivenets vendor.
gobgp
host
juniper
keysight
nokia
openconfig Package openconfig implmements node definitions for nodes from the OpenConfig vendor.	Package openconfig implmements node definitions for nodes from the OpenConfig vendor.

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