trench

Documentation

Index

• type ConduitWatcher
  • func NewConduitWatcher(ctx context.Context, nspConn *grpc.ClientConn, trenchName string, ...) (*ConduitWatcher, error)
  • func (cw *ConduitWatcher) Start()
• type Trench
  • func New(ctx context.Context, prefix types.Prefix, store types.Storage, ...) (*Trench, error)
  • func (t *Trench) AddConduit(ctx context.Context, name string) (types.Conduit, error)
  • func (t *Trench) GetConduit(ctx context.Context, name string) (types.Conduit, error)
  • func (t *Trench) RemoveConduit(ctx context.Context, name string) error
• type TrenchWatcher

Types

type ConduitWatcher

type ConduitWatcher struct {
	Ctx                        context.Context
	TrenchWatchers             []TrenchWatcher
	TrenchName                 string
	ConfigurationManagerClient nspAPI.ConfigurationManagerClient
	// contains filtered or unexported fields
}

func NewConduitWatcher

func NewConduitWatcher(ctx context.Context, nspConn *grpc.ClientConn, trenchName string, trenchWatchers []TrenchWatcher) (*ConduitWatcher, error)

func (*ConduitWatcher) Start

func (cw *ConduitWatcher) Start()

type Trench

type Trench struct {
	types.Prefix
	Store         types.Storage
	PrefixLengths *types.PrefixLengths
}

func New

func New(ctx context.Context, prefix types.Prefix, store types.Storage, prefixLengths *types.PrefixLengths) (*Trench, error)

New is the constructor for the Trench struct The constructor registers the trench to the store if not already registered in. prefix - prefix of the Trench store - storage for the prefix and its childs (conduit) prefixLengths - prefix length used to allocate the childs (conduit)

func (*Trench) AddConduit

func (t *Trench) AddConduit(ctx context.Context, name string) (types.Conduit, error)

AddConduit returns the conduit with the name in parameter and with as parent the current trench. If not existing, a new one will be created and returned.

func (*Trench) GetConduit

func (t *Trench) GetConduit(ctx context.Context, name string) (types.Conduit, error)

GetNode returns the node with the name in parameter and with as parent the current conduit. If not existing, a nil value is returned.

func (*Trench) RemoveConduit

func (t *Trench) RemoveConduit(ctx context.Context, name string) error

RemoveConduit removes the conduit with the name in parameter and with as parent the current node. no error is returned if the conduit does not exist.

type TrenchWatcher

type TrenchWatcher interface {
	AddConduit(ctx context.Context, name string) (types.Conduit, error)
	RemoveConduit(ctx context.Context, name string) error
}