topo

Sep 21, 2023

Changes in this version

type Option

+ func WithSkipDeleteWait(b bool) Option

Jul 27, 2023

Changes in this version

type Option

+ func WithProgress(b bool) Option

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

Aug 18, 2022

Changes in this version

type Manager

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

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

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

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

type Option

+ func WithKubecfg(k string) Option

Jun 29, 2022

Changes in this version

+ func CreateTopology(ctx context.Context, params TopologyParams) error

+ func DeleteTopology(ctx context.Context, params TopologyParams) error

+ func GenerateSelfSigned(ctx context.Context, n node.Node) error

+ func GetTopologyServices(ctx context.Context, params TopologyParams) (*cpb.ShowTopologyResponse, error)

+ func Load(fName string) (*tpb.Topology, error)

+ type Manager struct

+ BasePath string

+ func (m *Manager) CheckNodeStatus(ctx context.Context, timeout time.Duration) error

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

+ func (m *Manager) CreateMeshnetTopologies(ctx context.Context) error

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

+ func (m *Manager) DeleteMeshnetTopologies(ctx context.Context) error

+ func (m *Manager) Load(ctx context.Context) error

+ func (m *Manager) Node(nodeName string) (node.Node, error)

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

+ func (m *Manager) Push(ctx context.Context) error

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

+ func (m *Manager) TopologyProto() *tpb.Topology

+ func (m *Manager) TopologyResources(ctx context.Context) ([]*topologyv1.Topology, error)

+ func (m *Manager) TopologySpecs(ctx context.Context) ([]*topologyv1.Topology, error)

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

+ type Option func(m *Manager)

+ func WithBasePath(s string) Option

+ func WithClusterConfig(r *rest.Config) Option

+ func WithKubeClient(c kubernetes.Interface) Option

+ func WithTopoClient(c topologyclientv1.Interface) Option

+ func WithTopology(t *tpb.Topology) Option

+ type Resources struct

+ ConfigMaps map[string]*corev1.ConfigMap

+ Pods map[string][]*corev1.Pod

+ Services map[string][]*corev1.Service

+ Topologies map[string]*topologyv1.Topology

+ type TopologyManager interface

+ CheckNodeStatus func(context.Context, time.Duration) error

+ ConfigPush func(context.Context, string, io.Reader) error

+ Delete func(context.Context) error

+ Load func(context.Context) error

+ Node func(string) (node.Node, error)

+ Nodes func() []node.Node

+ Push func(context.Context) error

+ Resources func(context.Context) (*Resources, error)

+ TopologyProto func() *tpb.Topology

+ TopologyResources func(ctx context.Context) ([]*topologyv1.Topology, error)

+ TopologySpecs func(context.Context) ([]*topologyv1.Topology, error)

+ Watch func(context.Context) error

+ func New(kubecfg string, pb *tpb.Topology, opts ...Option) (TopologyManager, error)

+ type TopologyParams struct

+ DryRun bool

+ Kubecfg string

+ Timeout time.Duration

+ TopoName string

+ TopoNewOptions []Option