gnmi

Feb 14, 2022

Changes in this version

type ConnManager

+ GetByTarget func(ctx context.Context, targetID topoapi.ID) (Client, error)

Feb 3, 2022

Changes in this version

type ConnManager

+ Disconnect func(ctx context.Context, targetID topoapi.ID) error

Jan 12, 2022

Changes in this version

+ func WithClient(client *client) func(conn *conn)

+ func WithClientConn(clientConn *grpc.ClientConn) func(conn *conn)

+ func WithTargetID(targetID topoapi.ID) func(conn *conn)

type Conn

+ Connect func()

+ State func() connectivity.State

+ TargetID func() topoapi.ID

+ WatchState func(ctx context.Context, ch chan<- connectivity.State) error

+ type ConnEvent struct

+ Conn Conn

+ EventType ConnEventType

+ type ConnEventType int

+ const Connected

+ const Disconnected

+ const None

+ func (e ConnEventType) String() string

type ConnManager

+ Close func(ctx context.Context, targetID topoapi.ID) error

Jan 3, 2022

Changes in this version

+ type Client interface

+ Capabilities func(ctx context.Context, r *gpb.CapabilityRequest) (*gpb.CapabilityResponse, error)

+ CapabilitiesWithString func(ctx context.Context, request string) (*gpb.CapabilityResponse, error)

+ Get func(ctx context.Context, r *gpb.GetRequest) (*gpb.GetResponse, error)

+ GetWithString func(ctx context.Context, request string) (*gpb.GetResponse, error)

+ Set func(ctx context.Context, r *gpb.SetRequest) (*gpb.SetResponse, error)

+ SetWithString func(ctx context.Context, request string) (*gpb.SetResponse, error)

+ Subscribe func(ctx context.Context, q baseClient.Query) error

+ type Conn interface

+ ID func() ConnID

+ type ConnID string

+ type ConnManager interface

+ Connect func(ctx context.Context, target *topoapi.Object) (Conn, error)

+ Get func(ctx context.Context, targetID topoapi.ID) (Conn, error)

+ List func(ctx context.Context) ([]Conn, error)

+ Watch func(ctx context.Context, ch chan<- Conn) error

+ func NewConnManager() ConnManager

+ type Subscription struct

+ HeartbeatInterval uint64

+ Mode string

+ Origin string

+ Paths [][]string

+ Prefix string

+ SampleInterval uint64

+ StreamMode string

+ UpdatesOnly bool

+ func (s *Subscription) Build() (*gnmipb.SubscribeRequest, error)