netconf

Nov 25, 2021

Changes in this version

+ type Callback func(Event)

+ type Dispatcher struct

+ func (d *Dispatcher) Dispatch(eventID string, eventType EventType, value interface{})

+ func (d *Dispatcher) Register(eventID string, callback Callback)

+ func (d *Dispatcher) Remove(eventID string)

+ func (d *Dispatcher) WaitForMessages()

+ type Event interface

+ EventID func() string

+ Notification func() *message.Notification

+ RPCReply func() *message.RPCReply

+ Value func() interface{}

+ type EventType uint16

+ func (t EventType) String() string

type Session

+ IsClosed bool

+ IsNotificationStreamCreated bool

+ Listener *Dispatcher

+ func (session *Session) AsyncRPC(operation message.RPCMethod, callback Callback) error

+ func (session *Session) CreateNotificationStream(stopTime string, startTime string, stream string, callback Callback) error

+ func (session *Session) SyncRPC(operation message.RPCMethod) (*message.RPCReply, error)

Nov 12, 2021

Changes in this version

type Session

+ func (s *Session) ReceiveHello() (*message.Hello, error)

+ func (s *Session) SendHello(hello *message.Hello) error

Oct 27, 2021

retracted

Changes in this version

type RPCReply

+ func (in *RPCReply) DeepCopy() *RPCReply

+ func (in *RPCReply) DeepCopyInto(out *RPCReply)

Feb 18, 2018

retracted

Changes in this version

+ func SetLog(l Logger)

+ type LogLevel int

+ const LogDebug

+ const LogError

+ const LogInfo

+ const LogWarn

+ type Logger interface

+ Debugf func(string, ...interface{})

+ Errorf func(string, ...interface{})

+ Fatalf func(string, ...interface{})

+ Infof func(string, ...interface{})

+ Panicf func(string, ...interface{})

+ Warnf func(string, ...interface{})

+ type NoopLog struct

+ func (l NoopLog) Debugf(format string, v ...interface{})

+ func (l NoopLog) Errorf(format string, v ...interface{})

+ func (l NoopLog) Fatalf(format string, v ...interface{})

+ func (l NoopLog) Infof(format string, v ...interface{})

+ func (l NoopLog) Panicf(format string, v ...interface{})

+ func (l NoopLog) Warnf(format string, v ...interface{})

type Session

+ func DialTelnet(target string, username string, password string, vendor VendorIOProc) (*Session, error)

+ type StdLog struct

+ func NewStdLog(l *stdlog.Logger, level LogLevel) *StdLog

+ func (l *StdLog) Debugf(format string, v ...interface{})

+ func (l *StdLog) Errorf(format string, v ...interface{})

+ func (l *StdLog) Fatalf(format string, v ...interface{})

+ func (l *StdLog) Infof(format string, v ...interface{})

+ func (l *StdLog) Panicf(format string, v ...interface{})

+ func (l *StdLog) Warnf(format string, v ...interface{})

+ type TransportTelnet struct

+ func (t *TransportTelnet) Dial(target string, username string, password string, vendor VendorIOProc) error

+ func (t *TransportTelnet) Receive() ([]byte, error)

+ func (t *TransportTelnet) ReceiveHello() (*HelloMessage, error)

+ func (t *TransportTelnet) Send(data []byte) error

+ func (t *TransportTelnet) SendHello(hello *HelloMessage) error

+ func (t *TransportTelnet) WaitForBytes(b []byte) ([]byte, error)

+ func (t *TransportTelnet) WaitForFunc(f func([]byte) (int, error)) ([]byte, error)

+ func (t *TransportTelnet) WaitForRegexp(re *regexp.Regexp) ([]byte, [][]byte, error)

+ func (t *TransportTelnet) WaitForString(s string) (string, error)

+ func (t *TransportTelnet) Writeln(b []byte) (int, error)

+ type VendorIOProc interface

+ Login func(*TransportTelnet, string, string) error

+ StartNetconf func(*TransportTelnet) error

Nov 5, 2021

retracted

Changes in this version

+ func SSHConfigPassword(user string, pass string) *ssh.ClientConfig

+ func SSHConfigPubKeyAgent(user string) (*ssh.ClientConfig, error)

+ type HelloMessage struct

+ Capabilities []string

+ SessionID int

+ XMLName xml.Name

+ type RPCError struct

+ Info string

+ Message string

+ Path string

+ Severity string

+ Tag string

+ Type string

+ func (re *RPCError) Error() string

+ type RPCMessage struct

+ MessageID string

+ Methods []RPCMethod

+ func NewRPCMessage(methods []RPCMethod) *RPCMessage

+ func (m *RPCMessage) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ type RPCMethod interface

+ MarshalMethod func() string

+ type RPCReply struct

+ Data string

+ Errors []RPCError

+ MessageID string

+ Ok bool

+ RawReply string

+ XMLName xml.Name

+ type RawMethod string

+ func MethodCommit() RawMethod

+ func MethodEditConfig(database string, dataXml string, operation string) RawMethod

+ func MethodGet(filterType string, dataXml string) RawMethod

+ func MethodGetConfig(source string) RawMethod

+ func MethodLock(target string) RawMethod

+ func MethodUnlock(target string) RawMethod

+ func MethodValidate(database string) RawMethod

+ func (r RawMethod) MarshalMethod() string

type Session

+ ErrOnWarning bool

+ ServerCapabilities []string

+ func NewSSHSession(conn net.Conn, config *ssh.ClientConfig) (*Session, error)

+ func (s *Session) Exec(methods ...RPCMethod) (*RPCReply, error)

Nov 10, 2021

retracted

Changes in this version

+ var DefaultCapabilities = []string

+ var ErrBadChunk = errors.New("bad chunk")

+ func SSHConfigPubKeyFile(user string, file string, passphrase string) (*ssh.ClientConfig, error)

+ func SplitChunked(endOfMessage func()) bufio.SplitFunc

+ type ReadWriteCloser struct

+ func NewReadWriteCloser(r io.Reader, w io.WriteCloser) *ReadWriteCloser

+ type Session struct

+ Capabilities []string

+ SessionID int

+ Transport Transport

+ func DialSSH(target string, config *ssh.ClientConfig) (*Session, error)

+ func DialSSHTimeout(target string, config *ssh.ClientConfig, timeout time.Duration) (*Session, error)

+ func NewSession(t Transport) *Session

+ func (s *Session) Close() error

+ func (s *Session) ExecRPC(operation interface{}) (*message.RPCReply, error)

+ type Transport interface

+ Close func() error

+ Receive func() ([]byte, error)

+ ReceiveHello func() (*message.Hello, error)

+ Send func([]byte) error

+ SendHello func(hello *message.Hello) error

+ SetVersion func(version string)

+ type TransportSSH struct

+ func (t *TransportSSH) Chunked(b []byte) ([]byte, error)

+ func (t *TransportSSH) Close() error

+ func (t *TransportSSH) Dial(target string, config *ssh.ClientConfig) error

+ func (t *TransportSSH) Receive() ([]byte, error)

+ func (t *TransportSSH) ReceiveHello() (*message.Hello, error)

+ func (t *TransportSSH) Send(data []byte) error

+ func (t *TransportSSH) SendHello(hello *message.Hello) error

+ func (t *TransportSSH) SetVersion(version string)

+ func (t *TransportSSH) WaitForBytes(b []byte) ([]byte, error)

+ func (t *TransportSSH) WaitForFunc(f func([]byte) (int, error)) ([]byte, error)

+ func (t *TransportSSH) WaitForRegexp(re *regexp.Regexp) ([]byte, [][]byte, error)

+ func (t *TransportSSH) WaitForString(s string) (string, error)

+ func (t *TransportSSH) Writeln(b []byte) (int, error)