rpc

package
v0.0.0-...-2d08fe4 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

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)

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)
}

DataChangeServiceClient is the client API for DataChangeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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)
}

DataChangeServiceServer is the server API for DataChangeService service.

type DataRequest 

type DataRequest struct {
	AccessLists          []*acl.ACL                      `protobuf:"bytes,10,rep,name=AccessLists,proto3" json:"AccessLists,omitempty"`
	Forwardings          []*abf.ABF                      `protobuf:"bytes,15,rep,name=Forwardings,proto3" json:"Forwardings,omitempty"`
	Interfaces           []*interfaces.Interface         `protobuf:"bytes,20,rep,name=Interfaces,proto3" json:"Interfaces,omitempty"`
	Spans                []*interfaces.Span              `protobuf:"bytes,21,rep,name=Spans,proto3" json:"Spans,omitempty"`
	RuleChains           []*iptables.RuleChain           `protobuf:"bytes,22,rep,name=RuleChains,proto3" json:"RuleChains,omitempty"`
	VrfTables            []*l3.VrfTable                  `protobuf:"bytes,23,rep,name=VrfTables,proto3" json:"VrfTables,omitempty"`
	Nat44Interfaces      []*nat.Nat44Interface           `protobuf:"bytes,24,rep,name=Nat44Interfaces,proto3" json:"Nat44Interfaces,omitempty"`
	Nat44AddressPools    []*nat.Nat44AddressPool         `protobuf:"bytes,25,rep,name=Nat44AddressPools,proto3" json:"Nat44AddressPools,omitempty"`
	BridgeDomains        []*l2.BridgeDomain              `protobuf:"bytes,40,rep,name=BridgeDomains,proto3" json:"BridgeDomains,omitempty"`
	FIBs                 []*l2.FIBEntry                  `protobuf:"bytes,41,rep,name=FIBs,proto3" json:"FIBs,omitempty"`
	XCons                []*l2.XConnectPair              `protobuf:"bytes,42,rep,name=XCons,proto3" json:"XCons,omitempty"`
	StaticRoutes         []*l3.Route                     `protobuf:"bytes,50,rep,name=StaticRoutes,proto3" json:"StaticRoutes,omitempty"`
	ArpEntries           []*l3.ARPEntry                  `protobuf:"bytes,51,rep,name=ArpEntries,proto3" json:"ArpEntries,omitempty"`
	ProxyArp             *l3.ProxyARP                    `protobuf:"bytes,52,opt,name=ProxyArp,proto3" json:"ProxyArp,omitempty"`
	IPScanNeighbor       *l3.IPScanNeighbor              `protobuf:"bytes,53,opt,name=IPScanNeighbor,proto3" json:"IPScanNeighbor,omitempty"`
	SPDs                 []*ipsec.SecurityPolicyDatabase `protobuf:"bytes,60,rep,name=SPDs,proto3" json:"SPDs,omitempty"`
	SAs                  []*ipsec.SecurityAssociation    `protobuf:"bytes,61,rep,name=SAs,proto3" json:"SAs,omitempty"`
	IPRedirectPunts      []*punt.IPRedirect              `protobuf:"bytes,65,rep,name=IPRedirectPunts,proto3" json:"IPRedirectPunts,omitempty"`
	ToHostPunts          []*punt.ToHost                  `protobuf:"bytes,66,rep,name=ToHostPunts,proto3" json:"ToHostPunts,omitempty"`
	Exceptions           []*punt.Exception               `protobuf:"bytes,67,rep,name=Exceptions,proto3" json:"Exceptions,omitempty"`
	NatGlobal            *nat.Nat44Global                `protobuf:"bytes,71,opt,name=NatGlobal,proto3" json:"NatGlobal,omitempty"`
	DNATs                []*nat.DNat44                   `protobuf:"bytes,72,rep,name=DNATs,proto3" json:"DNATs,omitempty"`
	LinuxInterfaces      []*interfaces1.Interface        `protobuf:"bytes,80,rep,name=LinuxInterfaces,proto3" json:"LinuxInterfaces,omitempty"`
	LinuxArpEntries      []*l31.ARPEntry                 `protobuf:"bytes,90,rep,name=LinuxArpEntries,proto3" json:"LinuxArpEntries,omitempty"`
	LinuxRoutes          []*l31.Route                    `protobuf:"bytes,91,rep,name=LinuxRoutes,proto3" 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.ACL

func (*DataRequest) GetArpEntries 

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

func (*DataRequest) GetBridgeDomains 

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

func (*DataRequest) GetDNATs 

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

func (*DataRequest) GetExceptions 

func (m *DataRequest) GetExceptions() []*punt.Exception

func (*DataRequest) GetFIBs 

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

func (*DataRequest) GetForwardings 

func (m *DataRequest) GetForwardings() []*abf.ABF

func (*DataRequest) GetIPRedirectPunts 

func (m *DataRequest) GetIPRedirectPunts() []*punt.IPRedirect

func (*DataRequest) GetIPScanNeighbor 

func (m *DataRequest) GetIPScanNeighbor() *l3.IPScanNeighbor

func (*DataRequest) GetInterfaces 

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

func (*DataRequest) GetLinuxArpEntries 

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

func (*DataRequest) GetLinuxInterfaces 

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

func (*DataRequest) GetLinuxRoutes 

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

func (*DataRequest) GetNat44AddressPools 

func (m *DataRequest) GetNat44AddressPools() []*nat.Nat44AddressPool

func (*DataRequest) GetNat44Interfaces 

func (m *DataRequest) GetNat44Interfaces() []*nat.Nat44Interface

func (*DataRequest) GetNatGlobal 

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

func (*DataRequest) GetProxyArp 

func (m *DataRequest) GetProxyArp() *l3.ProxyARP

func (*DataRequest) GetRuleChains 

func (m *DataRequest) GetRuleChains() []*iptables.RuleChain

func (*DataRequest) GetSAs 

func (m *DataRequest) GetSAs() []*ipsec.SecurityAssociation

func (*DataRequest) GetSPDs 

func (m *DataRequest) GetSPDs() []*ipsec.SecurityPolicyDatabase

func (*DataRequest) GetSpans 

func (m *DataRequest) GetSpans() []*interfaces.Span

func (*DataRequest) GetStaticRoutes 

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

func (*DataRequest) GetToHostPunts 

func (m *DataRequest) GetToHostPunts() []*punt.ToHost

func (*DataRequest) GetVrfTables 

func (m *DataRequest) GetVrfTables() []*l3.VrfTable

func (*DataRequest) GetXCons 

func (m *DataRequest) GetXCons() []*l2.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 

func (m *DataRequest) XXX_DiscardUnknown()

func (*DataRequest) XXX_Marshal 

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

func (*DataRequest) XXX_Merge 

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

func (*DataRequest) XXX_Size 

func (m *DataRequest) XXX_Size() int

func (*DataRequest) XXX_Unmarshal 

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)
}

DataResyncServiceClient is the client API for DataResyncService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDataResyncServiceClient 

func NewDataResyncServiceClient(cc *grpc.ClientConn) DataResyncServiceClient

type DataResyncServiceServer 

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

DataResyncServiceServer is the server API for DataResyncService service.

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 

func (m *DelResponse) XXX_DiscardUnknown()

func (*DelResponse) XXX_Marshal 

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

func (*DelResponse) XXX_Merge 

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

func (*DelResponse) XXX_Size 

func (m *DelResponse) XXX_Size() int

func (*DelResponse) XXX_Unmarshal 

func (m *DelResponse) 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 

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal 

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

func (*PutResponse) XXX_Merge 

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

func (*PutResponse) XXX_Size 

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal 

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 

func (m *ResyncResponse) XXX_DiscardUnknown()

func (*ResyncResponse) XXX_Marshal 

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

func (*ResyncResponse) XXX_Merge 

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

func (*ResyncResponse) XXX_Size 

func (m *ResyncResponse) XXX_Size() int

func (*ResyncResponse) XXX_Unmarshal 

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

type UnimplementedDataChangeServiceServer 

type UnimplementedDataChangeServiceServer struct {
}

UnimplementedDataChangeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataChangeServiceServer) Del 

func (*UnimplementedDataChangeServiceServer) Del(ctx context.Context, req *DataRequest) (*DelResponse, error)

func (*UnimplementedDataChangeServiceServer) Put 

func (*UnimplementedDataChangeServiceServer) Put(ctx context.Context, req *DataRequest) (*PutResponse, error)

type UnimplementedDataResyncServiceServer 

type UnimplementedDataResyncServiceServer struct {
}

UnimplementedDataResyncServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataResyncServiceServer) Resync 

func (*UnimplementedDataResyncServiceServer) Resync(ctx context.Context, req *DataRequest) (*ResyncResponse, 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.