Documentation ¶
Index ¶
- func AristaBGPUpdate() *gnmi.Notification
- func AristaUpdate() *gnmi.Notification
- func CiscoXRInterface() *gnmi.Notification
- func JuniperBGPSample() *jpb.OpenConfigData
- func JuniperFakeDuplicateLabel() *gnmi.Notification
- func JuniperFakeKeyLabel() *gnmi.Notification
- func JuniperJTILo0InterfaceSample() *jpb.OpenConfigData
- func JuniperJTIMix() *jpb.OpenConfigData
- func JuniperUpdate() *gnmi.Notification
- func MDTInterface() *telemetry.Telemetry
- func MDTInterfaceII() *telemetry.Telemetry
- func StartGNMIServer(addr string, resp Response) (net.Listener, error)
- func StartJTIServer(addr string, resp JTIResponse) (net.Listener, error)
- type GNMIServer
- func (*GNMIServer) Capabilities(context.Context, *gnmi.CapabilityRequest) (*gnmi.CapabilityResponse, error)
- func (*GNMIServer) Get(context.Context, *gnmi.GetRequest) (*gnmi.GetResponse, error)
- func (*GNMIServer) Set(context.Context, *gnmi.SetRequest) (*gnmi.SetResponse, error)
- func (g *GNMIServer) Subscribe(server gnmi.GNMI_SubscribeServer) error
- type JTIResponse
- type OpenConfigTelemetryServer
- func (*OpenConfigTelemetryServer) CancelTelemetrySubscription(context.Context, *jpb.CancelSubscriptionRequest) (*jpb.CancelSubscriptionReply, error)
- func (*OpenConfigTelemetryServer) GetDataEncodings(context.Context, *jpb.DataEncodingRequest) (*jpb.DataEncodingReply, error)
- func (*OpenConfigTelemetryServer) GetTelemetryOperationalState(context.Context, *jpb.GetOperationalStateRequest) (*jpb.GetOperationalStateReply, error)
- func (*OpenConfigTelemetryServer) GetTelemetrySubscriptions(context.Context, *jpb.GetSubscriptionsRequest) (*jpb.GetSubscriptionsReply, error)
- func (oc *OpenConfigTelemetryServer) TelemetrySubscribe(subReq *jpb.SubscriptionRequest, ...) error
- type Response
- type Update
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AristaBGPUpdate ¶
func AristaBGPUpdate() *gnmi.Notification
AristaBGPUpdate return gNMI notification included an Arista BGP update
func AristaUpdate ¶
func AristaUpdate() *gnmi.Notification
AristaUpdate returns gNMI notification included an Arista interface update
func CiscoXRInterface ¶
func CiscoXRInterface() *gnmi.Notification
CiscoXRInterface return a gNMI notification included a Cisco XR interface update
func JuniperBGPSample ¶
func JuniperBGPSample() *jpb.OpenConfigData
JuniperBGPSample returns JTI mock data included BGP metrics
func JuniperFakeDuplicateLabel ¶
func JuniperFakeDuplicateLabel() *gnmi.Notification
JuniperFakeDuplicateLabel returns gNMI update included a Juniper fake update
func JuniperFakeKeyLabel ¶
func JuniperFakeKeyLabel() *gnmi.Notification
JuniperFakeKeyLabel returns gNMI update included a Juniper fake update
func JuniperJTILo0InterfaceSample ¶
func JuniperJTILo0InterfaceSample() *jpb.OpenConfigData
JuniperJTILo0InterfaceSample returns JTI mock data included an interface metrics
func JuniperJTIMix ¶
func JuniperJTIMix() *jpb.OpenConfigData
JuniperJTIMix returns JTI mock data included fake metrics
func JuniperUpdate ¶
func JuniperUpdate() *gnmi.Notification
JuniperUpdate returns a gNMI notification included a Juniper interface update
func MDTInterface ¶
MDTInterface returns Cisco MDT mock data included two recursive sets
func MDTInterfaceII ¶
MDTInterfaceII returns Cisco MDT mock data included two recursive sets (interface counters)
func StartGNMIServer ¶
StartGNMIServer starts gNMI mock server
func StartJTIServer ¶
func StartJTIServer(addr string, resp JTIResponse) (net.Listener, error)
StartJTIServer starts JTI mock server
Types ¶
type GNMIServer ¶
type GNMIServer struct {
Resp Response
}
GNMIServer represents gNMI server
func (*GNMIServer) Capabilities ¶
func (*GNMIServer) Capabilities(context.Context, *gnmi.CapabilityRequest) (*gnmi.CapabilityResponse, error)
Capabilities is a capabilities mock method
func (*GNMIServer) Get ¶
func (*GNMIServer) Get(context.Context, *gnmi.GetRequest) (*gnmi.GetResponse, error)
Get is a get mock method
func (*GNMIServer) Set ¶
func (*GNMIServer) Set(context.Context, *gnmi.SetRequest) (*gnmi.SetResponse, error)
Set is a set mock method
func (*GNMIServer) Subscribe ¶
func (g *GNMIServer) Subscribe(server gnmi.GNMI_SubscribeServer) error
Subscribe is a mock subscribe method which it returns the notifications to the targets. it doesn't go through subscription procedures instead it returns the configured responses.
type JTIResponse ¶
type JTIResponse interface {
Run(*jpb.SubscriptionRequest, jpb.OpenConfigTelemetry_TelemetrySubscribeServer) error
}
JTIResponse represents mock JTI response
type OpenConfigTelemetryServer ¶
type OpenConfigTelemetryServer struct {
Resp JTIResponse
}
OpenConfigTelemetryServer represents OpenConfigTelemetry mock Server
func (*OpenConfigTelemetryServer) CancelTelemetrySubscription ¶
func (*OpenConfigTelemetryServer) CancelTelemetrySubscription(context.Context, *jpb.CancelSubscriptionRequest) (*jpb.CancelSubscriptionReply, error)
CancelTelemetrySubscription is mock CancelTelemetrySubscription method
func (*OpenConfigTelemetryServer) GetDataEncodings ¶
func (*OpenConfigTelemetryServer) GetDataEncodings(context.Context, *jpb.DataEncodingRequest) (*jpb.DataEncodingReply, error)
GetDataEncodings is mock GetDataEncodings method
func (*OpenConfigTelemetryServer) GetTelemetryOperationalState ¶
func (*OpenConfigTelemetryServer) GetTelemetryOperationalState(context.Context, *jpb.GetOperationalStateRequest) (*jpb.GetOperationalStateReply, error)
GetTelemetryOperationalState is mock GetTelemetryOperationalState method
func (*OpenConfigTelemetryServer) GetTelemetrySubscriptions ¶
func (*OpenConfigTelemetryServer) GetTelemetrySubscriptions(context.Context, *jpb.GetSubscriptionsRequest) (*jpb.GetSubscriptionsReply, error)
GetTelemetrySubscriptions is mock GetTelemetrySubscriptions method
func (*OpenConfigTelemetryServer) TelemetrySubscribe ¶
func (oc *OpenConfigTelemetryServer) TelemetrySubscribe(subReq *jpb.SubscriptionRequest, subServer jpb.OpenConfigTelemetry_TelemetrySubscribeServer) error
TelemetrySubscribe is mock TelemetrySubscribe method
type Response ¶
type Response interface {
Run(gnmi.GNMI_SubscribeServer) error
}
Response represents gNMI response