govppmux

Documentation

Overview

Package govppmux implements the GoVPPMux plugin that allows multiple plugins to share a single connection to VPP.

Index

• Variables
• func NewStatsAdapter(socketName string) adapter.StatsAPI
• func NewVppAdapter(addr string, useShm bool) adapter.VppAPI
• type API
• type Config
• type Deps
• type Option
  • func UseDeps(cb func(*Deps)) Option
• type Plugin
  • func NewPlugin(opts ...Option) *Plugin
  • func (p *Plugin) AfterInit() error
  • func (p *Plugin) Close() error
  • func (p *Plugin) DumpStats(prefixes ...string) ([]*adapter.StatEntry, error)
  • func (p *Plugin) GetBufferStats() (*govppapi.BufferStats, error)
  • func (p *Plugin) GetErrorStats(names ...string) (*govppapi.ErrorStats, error)
  • func (p *Plugin) GetInterfaceStats() (*govppapi.InterfaceStats, error)
  • func (p *Plugin) GetNodeStats() (*govppapi.NodeStats, error)
  • func (p *Plugin) GetSystemStats() (*govppapi.SystemStats, error)
  • func (p *Plugin) GetTrace() *apitrace.Trace
  • func (p *Plugin) Init() error
  • func (p *Plugin) ListStats(prefixes ...string) ([]string, error)
  • func (p *Plugin) NewAPIChannel() (govppapi.Channel, error)
  • func (p *Plugin) NewAPIChannelBuffered(reqChanBufSize, replyChanBufSize int) (govppapi.Channel, error)
  • func (p *Plugin) VPPInfo() (VPPInfo, error)
• type Stats
  • func GetStats() *Stats
• type StatsAPI
• type VPPInfo
  • func (vpp VPPInfo) GetReleaseVersion() string

Variables

var DefaultPlugin = *NewPlugin()

DefaultPlugin is default instance of Plugin

Functions

func NewStatsAdapter

func NewStatsAdapter(socketName string) adapter.StatsAPI

NewStatsAdapter returns stats vpp api adapter, used for reading statistics with vppapiclient library.

func NewVppAdapter

func NewVppAdapter(addr string, useShm bool) adapter.VppAPI

NewVppAdapter returns real vpp api adapter, used for building with vppapiclient library.

Types

type API

type API interface {
	// VPPInfo returns VPP information which is retrieved immediatelly after connecting to VPP.
	VPPInfo() (VPPInfo, error)

	govppapi.ChannelProvider
}

API for other plugins to get connectivity to VPP.

type Config

type Config struct {
	TraceEnabled             bool          `json:"trace-enabled"`
	ReconnectResync          bool          `json:"resync-after-reconnect"`
	HealthCheckProbeInterval time.Duration `json:"health-check-probe-interval"`
	HealthCheckReplyTimeout  time.Duration `json:"health-check-reply-timeout"`
	HealthCheckThreshold     int           `json:"health-check-threshold"`
	ReplyTimeout             time.Duration `json:"reply-timeout"`
	// Connect to VPP for configuration requests via the shared memory instead of through the socket.
	ConnectViaShm bool `json:"connect-via-shm"`
	// The prefix prepended to the name used for shared memory (SHM) segments. If not set,
	// shared memory segments are created directly in the SHM directory /dev/shm.
	ShmPrefix        string `json:"shm-prefix"`
	BinAPISocketPath string `json:"binapi-socket-path"`
	StatsSocketPath  string `json:"stats-socket-path"`
	// How many times can be request resent in case vpp is suddenly disconnected.
	RetryRequestCount int `json:"retry-request-count"`
	// Time between request resend attempts. Default is 500ms.
	RetryRequestTimeout time.Duration `json:"retry-request-timeout"`
	// How many times can be connection request resent in case the vpp is not reachable.
	RetryConnectCount int `json:"retry-connect-count"`
	// Time between connection request resend attempts. Default is 1s.
	RetryConnectTimeout time.Duration `json:"retry-connect-timeout"`
}

Config groups the configurable parameter of GoVpp.

type Deps

type Deps struct {
	infra.PluginDeps
	StatusCheck statuscheck.PluginStatusWriter
	Resync      *resync.Plugin
}

Deps groups injected dependencies of plugin so that they do not mix with other plugin fields.

type Option

type Option func(*Plugin)

Option is a function that acts on a Plugin to inject Dependencies or configuration

func UseDeps

func UseDeps(cb func(*Deps)) Option

UseDeps returns Option that can inject custom dependencies.

type Plugin

type Plugin struct {
	Deps
	// contains filtered or unexported fields
}

Plugin implements the govppmux plugin interface.

func NewPlugin

func NewPlugin(opts ...Option) *Plugin

NewPlugin creates a new Plugin with the provides Options

func (*Plugin) AfterInit

func (p *Plugin) AfterInit() error

AfterInit reports status check.

func (*Plugin) Close

func (p *Plugin) Close() error

Close cleans up the resources allocated by the govppmux plugin.

func (*Plugin) DumpStats

func (p *Plugin) DumpStats(prefixes ...string) ([]*adapter.StatEntry, error)

DumpStats returns all stats with name, type and value

func (*Plugin) GetBufferStats

func (p *Plugin) GetBufferStats() (*govppapi.BufferStats, error)

GetErrorStats retrieves VPP error counters

func (*Plugin) GetErrorStats

func (p *Plugin) GetErrorStats(names ...string) (*govppapi.ErrorStats, error)

GetErrorStats retrieves VPP error counters

func (*Plugin) GetInterfaceStats

func (p *Plugin) GetInterfaceStats() (*govppapi.InterfaceStats, error)

GetInterfaceStats retrieves all counters related to the VPP interfaces

func (*Plugin) GetNodeStats

func (p *Plugin) GetNodeStats() (*govppapi.NodeStats, error)

GetNodeStats retrieves a list of Node VPP counters (vectors, clocks, ...)

func (*Plugin) GetSystemStats

func (p *Plugin) GetSystemStats() (*govppapi.SystemStats, error)

GetSystemStats retrieves system statistics of the connected VPP instance like Vector rate, Input rate, etc.

func (*Plugin) GetTrace

func (p *Plugin) GetTrace() *apitrace.Trace

GetTrace returns all trace entries measured so far

func (*Plugin) Init

func (p *Plugin) Init() error

Init is the entry point called by Agent Core. A single binary-API connection to VPP is established.

func (*Plugin) ListStats

func (p *Plugin) ListStats(prefixes ...string) ([]string, error)

ListStats returns all stats names

func (*Plugin) NewAPIChannel

func (p *Plugin) NewAPIChannel() (govppapi.Channel, error)

NewAPIChannel returns a new API channel for communication with VPP via govpp core. It uses default buffer sizes for the request and reply Go channels.

Example of binary API call from some plugin using GOVPP:

ch, _ := govpp_mux.NewAPIChannel()
ch.SendRequest(req).ReceiveReply

func (*Plugin) NewAPIChannelBuffered

func (p *Plugin) NewAPIChannelBuffered(reqChanBufSize, replyChanBufSize int) (govppapi.Channel, error)

NewAPIChannelBuffered returns a new API channel for communication with VPP via govpp core. It allows to specify custom buffer sizes for the request and reply Go channels.

Example of binary API call from some plugin using GOVPP:

ch, _ := govpp_mux.NewAPIChannelBuffered(100, 100)
ch.SendRequest(req).ReceiveReply

func (*Plugin) VPPInfo

func (p *Plugin) VPPInfo() (VPPInfo, error)

VPPInfo returns information about VPP session.

type Stats

type Stats struct {
	ChannelsCreated uint64
	ChannelsOpen    uint64
	RequestsSent    uint64
	RequestsFailed  uint64
	AllMessages     metrics.CallStats
	Messages        metrics.Calls
}

func GetStats

func GetStats() *Stats

type StatsAPI

type StatsAPI interface {
	API

	govppapi.StatsProvider
}

StatsAPI is extended API with ability to get VPP stats data

type VPPInfo

type VPPInfo struct {
	Connected bool
	vppcalls.VersionInfo
	vppcalls.VpeInfo
}

VPPInfo defines retrieved information about the connected VPP instance.

func (VPPInfo) GetReleaseVersion

func (vpp VPPInfo) GetReleaseVersion() string

GetReleaseVersion returns VPP release version (XX.YY), which is normalized from VersionInfo.