rpc

package
v1.8.0-alpha Latest Latest
Warning

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

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

Documentation

Overview

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

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

func (*DataRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *DataRequest) XXX_DiscardUnknown()

func (*DataRequest) XXX_Marshal added in v1.8.1 

func (m *DataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataRequest) XXX_Merge added in v1.8.1 

func (dst *DataRequest) XXX_Merge(src proto.Message)

func (*DataRequest) XXX_Size added in v1.8.1 

func (m *DataRequest) XXX_Size() int

func (*DataRequest) XXX_Unmarshal added in v1.8.1 

func (m *DataRequest) XXX_Unmarshal(b []byte) error

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*DelResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *DelResponse) XXX_DiscardUnknown()

func (*DelResponse) XXX_Marshal added in v1.8.1 

func (m *DelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelResponse) XXX_Merge added in v1.8.1 

func (dst *DelResponse) XXX_Merge(src proto.Message)

func (*DelResponse) XXX_Size added in v1.8.1 

func (m *DelResponse) XXX_Size() int

func (*DelResponse) XXX_Unmarshal added in v1.8.1 

func (m *DelResponse) XXX_Unmarshal(b []byte) error

type NotificationRequest 

type NotificationRequest struct {
	Idx                  uint32   `protobuf:"varint,1,opt,name=idx,proto3" json:"idx,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*NotificationRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *NotificationRequest) XXX_DiscardUnknown()

func (*NotificationRequest) XXX_Marshal added in v1.8.1 

func (m *NotificationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotificationRequest) XXX_Merge added in v1.8.1 

func (dst *NotificationRequest) XXX_Merge(src proto.Message)

func (*NotificationRequest) XXX_Size added in v1.8.1 

func (m *NotificationRequest) XXX_Size() int

func (*NotificationRequest) XXX_Unmarshal added in v1.8.1 

func (m *NotificationRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

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

func (*NotificationsResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *NotificationsResponse) XXX_DiscardUnknown()

func (*NotificationsResponse) XXX_Marshal added in v1.8.1 

func (m *NotificationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotificationsResponse) XXX_Merge added in v1.8.1 

func (dst *NotificationsResponse) XXX_Merge(src proto.Message)

func (*NotificationsResponse) XXX_Size added in v1.8.1 

func (m *NotificationsResponse) XXX_Size() int

func (*NotificationsResponse) XXX_Unmarshal added in v1.8.1 

func (m *NotificationsResponse) XXX_Unmarshal(b []byte) error

type PutResponse 

type PutResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*PutResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal added in v1.8.1 

func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutResponse) XXX_Merge added in v1.8.1 

func (dst *PutResponse) XXX_Merge(src proto.Message)

func (*PutResponse) XXX_Size added in v1.8.1 

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal added in v1.8.1 

func (m *PutResponse) XXX_Unmarshal(b []byte) error

type ResyncResponse 

type ResyncResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ResyncResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *ResyncResponse) XXX_DiscardUnknown()

func (*ResyncResponse) XXX_Marshal added in v1.8.1 

func (m *ResyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResyncResponse) XXX_Merge added in v1.8.1 

func (dst *ResyncResponse) XXX_Merge(src proto.Message)

func (*ResyncResponse) XXX_Size added in v1.8.1 

func (m *ResyncResponse) XXX_Size() int

func (*ResyncResponse) XXX_Unmarshal added in v1.8.1 

func (m *ResyncResponse) XXX_Unmarshal(b []byte) error

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.