rpc

package
v1.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 23, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package model is the parent for packages defining various GRPC services generated from protobuf data models.

Package rpc is a generated protocol buffer package.

It is generated from these files: 

rpc.proto

It has these top-level messages: 

DataRequest
NotificationRequest
PutResponse
DelResponse
ResyncResponse
NotificationsResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDataChangeServiceServer 

func RegisterDataChangeServiceServer(s *grpc.Server, srv DataChangeServiceServer)

func RegisterDataResyncServiceServer 

func RegisterDataResyncServiceServer(s *grpc.Server, srv DataResyncServiceServer)

func RegisterNotificationServiceServer 

func RegisterNotificationServiceServer(s *grpc.Server, srv NotificationServiceServer)

Types

type DataChangeServiceClient 

type DataChangeServiceClient interface {
	// Creates or updates one or multiple configuration items
	Put(ctx context.Context, in *DataRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// Removes one or multiple configuration items
	Del(ctx context.Context, in *DataRequest, opts ...grpc.CallOption) (*DelResponse, error)
}

func NewDataChangeServiceClient 

func NewDataChangeServiceClient(cc *grpc.ClientConn) DataChangeServiceClient

type DataChangeServiceServer 

type DataChangeServiceServer interface {
	// Creates or updates one or multiple configuration items
	Put(context.Context, *DataRequest) (*PutResponse, error)
	// Removes one or multiple configuration items
	Del(context.Context, *DataRequest) (*DelResponse, error)
}

type DataRequest 

type DataRequest struct {
	// vppplugin
	AccessLists           []*acl.AccessLists_Acl                 `protobuf:"bytes,10,rep,name=AccessLists" json:"AccessLists,omitempty"`
	Interfaces            []*interfaces.Interfaces_Interface     `protobuf:"bytes,20,rep,name=Interfaces" json:"Interfaces,omitempty"`
	BfdSessions           []*bfd.SingleHopBFD_Session            `protobuf:"bytes,30,rep,name=BfdSessions" json:"BfdSessions,omitempty"`
	BfdAuthKeys           []*bfd.SingleHopBFD_Key                `protobuf:"bytes,31,rep,name=BfdAuthKeys" json:"BfdAuthKeys,omitempty"`
	BfdEchoFunction       *bfd.SingleHopBFD_EchoFunction         `protobuf:"bytes,32,opt,name=BfdEchoFunction" json:"BfdEchoFunction,omitempty"`
	BridgeDomains         []*l2.BridgeDomains_BridgeDomain       `protobuf:"bytes,40,rep,name=BridgeDomains" json:"BridgeDomains,omitempty"`
	FIBs                  []*l2.FibTable_FibEntry                `protobuf:"bytes,41,rep,name=FIBs" json:"FIBs,omitempty"`
	XCons                 []*l2.XConnectPairs_XConnectPair       `protobuf:"bytes,42,rep,name=XCons" json:"XCons,omitempty"`
	StaticRoutes          []*l3.StaticRoutes_Route               `protobuf:"bytes,50,rep,name=StaticRoutes" json:"StaticRoutes,omitempty"`
	ArpEntries            []*l3.ArpTable_ArpEntry                `protobuf:"bytes,51,rep,name=ArpEntries" json:"ArpEntries,omitempty"`
	ProxyArpInterfaces    []*l3.ProxyArpInterfaces_InterfaceList `protobuf:"bytes,52,rep,name=ProxyArpInterfaces" json:"ProxyArpInterfaces,omitempty"`
	ProxyArpRanges        []*l3.ProxyArpRanges_RangeList         `protobuf:"bytes,53,rep,name=ProxyArpRanges" json:"ProxyArpRanges,omitempty"`
	L4Feature             *l4.L4Features                         `protobuf:"bytes,60,opt,name=L4Feature" json:"L4Feature,omitempty"`
	ApplicationNamespaces []*l4.AppNamespaces_AppNamespace       `protobuf:"bytes,61,rep,name=ApplicationNamespaces" json:"ApplicationNamespaces,omitempty"`
	StnRules              []*stn.STN_Rule                        `protobuf:"bytes,70,rep,name=StnRules" json:"StnRules,omitempty"`
	NatGlobal             *nat.Nat44Global                       `protobuf:"bytes,71,opt,name=NatGlobal" json:"NatGlobal,omitempty"`
	DNATs                 []*nat.Nat44DNat_DNatConfig            `protobuf:"bytes,72,rep,name=DNATs" json:"DNATs,omitempty"`
	// Linuxplugin
	LinuxInterfaces []*interfaces1.LinuxInterfaces_Interface `protobuf:"bytes,80,rep,name=LinuxInterfaces" json:"LinuxInterfaces,omitempty"`
	LinuxArpEntries []*l31.LinuxStaticArpEntries_ArpEntry    `protobuf:"bytes,90,rep,name=LinuxArpEntries" json:"LinuxArpEntries,omitempty"`
	LinuxRoutes     []*l31.LinuxStaticRoutes_Route           `protobuf:"bytes,91,rep,name=LinuxRoutes" json:"LinuxRoutes,omitempty"`
}

Data request is an inventory of supported data types with one or multiple items of every type. Universal type for every data change/resync request

func (*DataRequest) Descriptor 

func (*DataRequest) Descriptor() ([]byte, []int)

func (*DataRequest) GetAccessLists 

func (m *DataRequest) GetAccessLists() []*acl.AccessLists_Acl

func (*DataRequest) GetApplicationNamespaces 

func (m *DataRequest) GetApplicationNamespaces() []*l4.AppNamespaces_AppNamespace

func (*DataRequest) GetArpEntries 

func (m *DataRequest) GetArpEntries() []*l3.ArpTable_ArpEntry

func (*DataRequest) GetBfdAuthKeys 

func (m *DataRequest) GetBfdAuthKeys() []*bfd.SingleHopBFD_Key

func (*DataRequest) GetBfdEchoFunction 

func (m *DataRequest) GetBfdEchoFunction() *bfd.SingleHopBFD_EchoFunction

func (*DataRequest) GetBfdSessions 

func (m *DataRequest) GetBfdSessions() []*bfd.SingleHopBFD_Session

func (*DataRequest) GetBridgeDomains 

func (m *DataRequest) GetBridgeDomains() []*l2.BridgeDomains_BridgeDomain

func (*DataRequest) GetDNATs 

func (m *DataRequest) GetDNATs() []*nat.Nat44DNat_DNatConfig

func (*DataRequest) GetFIBs 

func (m *DataRequest) GetFIBs() []*l2.FibTable_FibEntry

func (*DataRequest) GetInterfaces 

func (m *DataRequest) GetInterfaces() []*interfaces.Interfaces_Interface

func (*DataRequest) GetL4Feature 

func (m *DataRequest) GetL4Feature() *l4.L4Features

func (*DataRequest) GetLinuxArpEntries 

func (m *DataRequest) GetLinuxArpEntries() []*l31.LinuxStaticArpEntries_ArpEntry

func (*DataRequest) GetLinuxInterfaces 

func (m *DataRequest) GetLinuxInterfaces() []*interfaces1.LinuxInterfaces_Interface

func (*DataRequest) GetLinuxRoutes 

func (m *DataRequest) GetLinuxRoutes() []*l31.LinuxStaticRoutes_Route

func (*DataRequest) GetNatGlobal 

func (m *DataRequest) GetNatGlobal() *nat.Nat44Global

func (*DataRequest) GetProxyArpInterfaces 

func (m *DataRequest) GetProxyArpInterfaces() []*l3.ProxyArpInterfaces_InterfaceList

func (*DataRequest) GetProxyArpRanges 

func (m *DataRequest) GetProxyArpRanges() []*l3.ProxyArpRanges_RangeList

func (*DataRequest) GetStaticRoutes 

func (m *DataRequest) GetStaticRoutes() []*l3.StaticRoutes_Route

func (*DataRequest) GetStnRules 

func (m *DataRequest) GetStnRules() []*stn.STN_Rule

func (*DataRequest) GetXCons 

func (m *DataRequest) GetXCons() []*l2.XConnectPairs_XConnectPair

func (*DataRequest) ProtoMessage 

func (*DataRequest) ProtoMessage()

func (*DataRequest) Reset 

func (m *DataRequest) Reset()

func (*DataRequest) String 

func (m *DataRequest) String() string

type DataResyncServiceClient 

type DataResyncServiceClient interface {
	// Calls vpp-agent resync
	Resync(ctx context.Context, in *DataRequest, opts ...grpc.CallOption) (*ResyncResponse, error)
}

func NewDataResyncServiceClient 

func NewDataResyncServiceClient(cc *grpc.ClientConn) DataResyncServiceClient

type DataResyncServiceServer 

type DataResyncServiceServer interface {
	// Calls vpp-agent resync
	Resync(context.Context, *DataRequest) (*ResyncResponse, error)
}

type DelResponse 

type DelResponse struct {
}

Response to data change 'del'

func (*DelResponse) Descriptor 

func (*DelResponse) Descriptor() ([]byte, []int)

func (*DelResponse) ProtoMessage 

func (*DelResponse) ProtoMessage()

func (*DelResponse) Reset 

func (m *DelResponse) Reset()

func (*DelResponse) String 

func (m *DelResponse) String() string

type NotificationRequest 

type NotificationRequest struct {
	Idx uint32 `protobuf:"varint,1,opt,name=idx,proto3" json:"idx,omitempty"`
}

NotificationRequest represent a notification request which contains index of next required message

func (*NotificationRequest) Descriptor 

func (*NotificationRequest) Descriptor() ([]byte, []int)

func (*NotificationRequest) GetIdx 

func (m *NotificationRequest) GetIdx() uint32

func (*NotificationRequest) ProtoMessage 

func (*NotificationRequest) ProtoMessage()

func (*NotificationRequest) Reset 

func (m *NotificationRequest) Reset()

func (*NotificationRequest) String 

func (m *NotificationRequest) String() string

type NotificationServiceClient 

type NotificationServiceClient interface {
	// Get notification stack
	Get(ctx context.Context, in *NotificationRequest, opts ...grpc.CallOption) (NotificationService_GetClient, error)
}

func NewNotificationServiceClient 

func NewNotificationServiceClient(cc *grpc.ClientConn) NotificationServiceClient

type NotificationServiceServer 

type NotificationServiceServer interface {
	// Get notification stack
	Get(*NotificationRequest, NotificationService_GetServer) error
}

type NotificationService_GetClient 

type NotificationService_GetClient interface {
	Recv() (*NotificationsResponse, error)
	grpc.ClientStream
}

type NotificationService_GetServer 

type NotificationService_GetServer interface {
	Send(*NotificationsResponse) error
	grpc.ServerStream
}

type NotificationsResponse 

type NotificationsResponse struct {
	// Index of following notification
	NextIdx uint32 `protobuf:"varint,1,opt,name=nextIdx,proto3" json:"nextIdx,omitempty"`
	// Notification data
	NIf *interfaces.InterfaceNotification `protobuf:"bytes,2,opt,name=nIf" json:"nIf,omitempty"`
}

Response to notification request 'get'. Returns indexed notification.

func (*NotificationsResponse) Descriptor 

func (*NotificationsResponse) Descriptor() ([]byte, []int)

func (*NotificationsResponse) GetNIf 

func (m *NotificationsResponse) GetNIf() *interfaces.InterfaceNotification

func (*NotificationsResponse) GetNextIdx 

func (m *NotificationsResponse) GetNextIdx() uint32

func (*NotificationsResponse) ProtoMessage 

func (*NotificationsResponse) ProtoMessage()

func (*NotificationsResponse) Reset 

func (m *NotificationsResponse) Reset()

func (*NotificationsResponse) String 

func (m *NotificationsResponse) String() string

type PutResponse 

type PutResponse struct {
}

Response to data change 'put'

func (*PutResponse) Descriptor 

func (*PutResponse) Descriptor() ([]byte, []int)

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) String 

func (m *PutResponse) String() string

type ResyncResponse 

type ResyncResponse struct {
}

Response to data resync

func (*ResyncResponse) Descriptor 

func (*ResyncResponse) Descriptor() ([]byte, []int)

func (*ResyncResponse) ProtoMessage 

func (*ResyncResponse) ProtoMessage()

func (*ResyncResponse) Reset 

func (m *ResyncResponse) Reset()

func (*ResyncResponse) String 

func (m *ResyncResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.