rpc

Documentation

Index

• Variables
• type ChangeSvc
  • func (svc *ChangeSvc) Del(ctx context.Context, data *rpc.DataRequest) (*rpc.DelResponse, error)
  • func (svc *ChangeSvc) Put(ctx context.Context, data *rpc.DataRequest) (*rpc.PutResponse, error)
• type Deps
• type Option
  • func UseDeps(cb func(*Deps)) Option
• type Plugin
  • func NewPlugin(opts ...Option) *Plugin
  • func (p *Plugin) Close() error
  • func (p *Plugin) GetConfigSnapshot() (controller.KeyValuePairs, error)
  • func (p *Plugin) Init() error
• type ResyncSvc
  • func (svc *ResyncSvc) Resync(ctx context.Context, data *rpc.DataRequest) (*rpc.ResyncResponse, error)

Variables

var DefaultPlugin = *NewPlugin()

DefaultPlugin is default instance of Plugin

Types

type ChangeSvc

type ChangeSvc struct {
	// contains filtered or unexported fields
}

ChangeSvc implements DataChangeService.

func (*ChangeSvc) Del

func (svc *ChangeSvc) Del(ctx context.Context, data *rpc.DataRequest) (*rpc.DelResponse, error)

Del propagates request from GRPC client to remove some external configuration items.

func (*ChangeSvc) Put

func (svc *ChangeSvc) Put(ctx context.Context, data *rpc.DataRequest) (*rpc.PutResponse, error)

Put propagates request from GRPC client to add/modify some external configuration items.

type Deps

type Deps struct {
	infra.PluginDeps
	GRPCServer grpc.Server
	EventLoop  controller.EventLoop
	LocalDB    keyval.KvProtoPlugin
}

Deps - dependencies of Plugin

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 GRPC access to Contiv's VPP-agent.

func NewPlugin

func NewPlugin(opts ...Option) *Plugin

NewPlugin creates a new Plugin with the provides Options

func (*Plugin) Close

func (p *Plugin) Close() error

Close does nothing.

func (*Plugin) GetConfigSnapshot

func (p *Plugin) GetConfigSnapshot() (controller.KeyValuePairs, error)

GetConfigSnapshot returns full configuration snapshot that is currently required by the GRPC client to be applied.

func (*Plugin) Init

func (p *Plugin) Init() error

Init registers GRPC services.

type ResyncSvc

type ResyncSvc struct {
	// contains filtered or unexported fields
}

ResyncSvc implements DataResyncService.

func (*ResyncSvc) Resync

func (svc *ResyncSvc) Resync(ctx context.Context, data *rpc.DataRequest) (*rpc.ResyncResponse, error)

Resync re-synchronizes configuration between the GRPC client and vpp-agent.