Versions in this module Expand all Collapse all v0 v0.0.2 Mar 30, 2021 Changes in this version + func Run(ctx context.Context) error + type ClientConfig struct + Endpoint string + GjsonConnectionsPath string + GjsonDefaultPath string + Identifier string + Password string + Username string + type CtxKeyType string + const CtxKeyConfig + const CtxKeyOpts + type Device struct + SBI SouthboundInterface + Transport Transport + UUID uuid.UUID + func NewDevice(sbi SouthboundInterface, opts TransportOptions) (*Device, error) + func (d *Device) ID() uuid.UUID + type ErrAlreadyExists struct + func (e *ErrAlreadyExists) Error() string + type ErrInvalidParameters struct + func (e ErrInvalidParameters) Error() string + type ErrInvalidTransportOptions struct + func (e ErrInvalidTransportOptions) Error() string + type ErrInvalidTypeAssertion struct + func (e ErrInvalidTypeAssertion) Error() string + type ErrNil struct + func (e *ErrNil) Error() string + type ErrNilClient struct + func (e *ErrNilClient) Error() string + type ErrNotFound struct + func (e *ErrNotFound) Error() string + type ErrNotYetImplemented struct + func (e ErrNotYetImplemented) Error() string + type ErrUnsupportedPath struct + func (e ErrUnsupportedPath) Error() string + type Gnmi struct + Options *GnmiTransportOptions + RespChan chan *gpb.SubscribeResponse + SetNode func(schema *yang.Entry, root interface{}, path *gpb.Path, val interface{}, ...) error + Unmarshal func([]byte, []string, interface{}, ...ytypes.UnmarshalOpt) error + func NewGnmiTransport(opts *GnmiTransportOptions) (*Gnmi, error) + func (g *Gnmi) Capabilities(ctx context.Context) (interface{}, error) + func (g *Gnmi) Close() error + func (g *Gnmi) Get(ctx context.Context, params ...string) (interface{}, error) + func (g *Gnmi) GetOptions() interface{} + func (g *Gnmi) ProcessResponse(resp interface{}, root interface{}, s *ytypes.Schema) error + func (g *Gnmi) Set(ctx context.Context, args ...interface{}) (interface{}, error) + func (g *Gnmi) SetOptions(to TransportOptions) + func (g *Gnmi) Subscribe(ctx context.Context, params ...string) error + func (g *Gnmi) Type() string + type GnmiTransportOptions struct + RespChan chan *gpb.SubscribeResponse + SetNode func(schema *yang.Entry, root interface{}, path *gpb.Path, val interface{}, ...) error + Unmarshal func([]byte, []string, interface{}, ...ytypes.UnmarshalOpt) error + func (gto *GnmiTransportOptions) GetAddress() string + func (gto *GnmiTransportOptions) GetPassword() string + func (gto *GnmiTransportOptions) GetUsername() string + func (gto *GnmiTransportOptions) IsTransportOption() + type OpenConfig struct + func (oc *OpenConfig) ID() uuid.UUID + func (oc *OpenConfig) SbiIdentifier() string + func (oc *OpenConfig) Schema() *ytypes.Schema + func (oc *OpenConfig) SetNode() ... + func (oc *OpenConfig) Unmarshal() func([]byte, []string, interface{}, ...ytypes.UnmarshalOpt) error + type PrincipalNetworkDomain interface + AddDevice func(interface{}) error + AddSbi func(interface{}) error + ContainsDevice func(uuid.UUID) bool + Destroy func() error + GetDescription func() string + GetName func() string + GetSBIs func() interface{} + ID func() uuid.UUID + MarshalDevice func(uuid.UUID) (string, error) + RemoveDevice func(uuid.UUID) error + RemoveSbi func(uuid.UUID) error + Request func(uuid.UUID, string) error + RequestAll func(string) error + func NewPND(name, description string, id uuid.UUID, sbi SouthboundInterface) (PrincipalNetworkDomain, error) + type Restconf struct + func (r Restconf) Get(ctx context.Context, params ...string) (interface{}, error) + func (r Restconf) ProcessResponse(resp interface{}, root interface{}, models *ytypes.Schema) error + func (r Restconf) Set(ctx context.Context, params ...string) (interface{}, error) + func (r Restconf) Subscribe(ctx context.Context, params ...string) error + func (r Restconf) Type() string + type SouthboundInterface interface + ID func() uuid.UUID + SbiIdentifier func() string + Schema func() *ytypes.Schema + SetNode func() ... + type Storable interface + ID func() uuid.UUID + type Tapi struct + type Transport interface + Get func(ctx context.Context, params ...string) (interface{}, error) + GetOptions func() interface{} + ProcessResponse func(resp interface{}, root interface{}, models *ytypes.Schema) error + Set func(ctx context.Context, params ...interface{}) (interface{}, error) + Subscribe func(ctx context.Context, params ...string) error + Type func() string + type TransportOptions interface + GetAddress func() string + GetPassword func() string + GetUsername func() string + IsTransportOption func() + type YANGConsumer struct + Data *bytes.Buffer + func (yc YANGConsumer) Consume(reader io.Reader, _ interface{}) error v0.0.1 Oct 19, 2020 Changes in this version + func StartAndRun(socket, filename string, IsRunningChannel chan bool) + type Core struct + IsRunning chan bool + func (c *Core) AttachDatabase() + func (c *Core) Init(socket, configFileController, configFileClient string, ...) + func (c *Core) Shutdown()
Go to main page