Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChangeVppSvc ¶
type ChangeVppSvc struct {
// contains filtered or unexported fields
}
ChangeVppSvc forwards GRPC request to the localclient.
func (*ChangeVppSvc) Del ¶
func (svc *ChangeVppSvc) Del(ctx context.Context, data *rpc.DataRequest) (*rpc.DelResponse, error)
Del removes configuration data present in data request from the VPP/linux
func (*ChangeVppSvc) Put ¶
func (svc *ChangeVppSvc) Put(ctx context.Context, data *rpc.DataRequest) (*rpc.PutResponse, error)
Put adds configuration data present in data request to the VPP/Linux
type GRPCService ¶
type GRPCService interface {
// updateNotification stores VPP notifications/statistic data. The notification can be read by any client
// connected to the notification service server
// todo make type independent
UpdateNotifications(ctx context.Context, notification *interfaces.InterfaceNotification)
}
GRPCService allows to send VPP notifications to external GRPC endpoints
type GRPCSvcPlugin ¶
type GRPCSvcPlugin struct {
Deps GRPCSvcPluginDeps
// contains filtered or unexported fields
}
GRPCSvcPlugin registers VPP GRPC services in *grpc.Server.
func (*GRPCSvcPlugin) AfterInit ¶
func (plugin *GRPCSvcPlugin) AfterInit() error
AfterInit registers all GRPC services in vppscv package (be sure that defaultvppplugins are completely initialized).
func (*GRPCSvcPlugin) Init ¶
func (plugin *GRPCSvcPlugin) Init() error
Init sets plugin child loggers for changeVppSvc & resyncVppSvc.
func (*GRPCSvcPlugin) UpdateNotifications ¶
func (plugin *GRPCSvcPlugin) UpdateNotifications(ctx context.Context, notification *interfaces.InterfaceNotification)
UpdateNotifications stores new notification data
type GRPCSvcPluginDeps ¶
type GRPCSvcPluginDeps struct {
local.PluginLogDeps
GRPCServer grpc.Server
}
GRPCSvcPluginDeps - dependencies of GRPCSvcPlugin
type NotificationSvc ¶
type NotificationSvc struct {
// contains filtered or unexported fields
}
NotificationSvc forwards GRPC messages to external servers.
func (*NotificationSvc) Get ¶
func (svc *NotificationSvc) Get(from *rpc.NotificationRequest, server rpc.NotificationService_GetServer) error
Get returns all required VPP notifications (or those available in the buffer) in the same order as they were received
type ResyncVppSvc ¶
type ResyncVppSvc struct {
// contains filtered or unexported fields
}
ResyncVppSvc forwards GRPC request to the localclient.
func (*ResyncVppSvc) Resync ¶
func (svc *ResyncVppSvc) Resync(ctx context.Context, data *rpc.DataRequest) (*rpc.ResyncResponse, error)
Resync creates a resync request which adds data tp the VPP/linux
Source Files