mirror of
https://github.com/osrg/gobgp.git
synced 2024-05-11 05:55:10 +00:00
add grpc api to configure global as/router-id $ gobgp global as 65000 router-id 10.0.0.1 Signed-off-by: ISHIDA Wataru <[email protected]>
2798 lines
86 KiB
Go
2798 lines
86 KiB
Go
// Code generated by protoc-gen-go.
|
|
// source: gobgp.proto
|
|
// DO NOT EDIT!
|
|
|
|
/*
|
|
Package gobgpapi is a generated protocol buffer package.
|
|
|
|
It is generated from these files:
|
|
gobgp.proto
|
|
|
|
It has these top-level messages:
|
|
Error
|
|
Arguments
|
|
ModPathArguments
|
|
ModNeighborArguments
|
|
MrtArguments
|
|
ModVrfArguments
|
|
ModDefinedSetArguments
|
|
ModStatementArguments
|
|
ModPolicyArguments
|
|
ModPolicyAssignmentArguments
|
|
ModGlobalConfigArguments
|
|
Path
|
|
Destination
|
|
Peer
|
|
AddPaths
|
|
AfiSafis
|
|
AfiSafi
|
|
ApplyPolicy
|
|
AfiSafiGracefulRestart
|
|
LabelledUnicast
|
|
PrefixLimit
|
|
Unicast
|
|
Vpn
|
|
Prefixes
|
|
UseMultiplePaths
|
|
Ebgp
|
|
AsPathOptions
|
|
PeerConf
|
|
EbgpMultihop
|
|
ErrorHandling
|
|
PeerGracefulRestart
|
|
LoggingOptions
|
|
RouteReflector
|
|
PeerState
|
|
Messages
|
|
Message
|
|
Queues
|
|
Timers
|
|
TimersConfig
|
|
TimersState
|
|
Transport
|
|
RouteServer
|
|
Prefix
|
|
DefinedSet
|
|
MatchSet
|
|
AsPathLength
|
|
Conditions
|
|
CommunityAction
|
|
MedAction
|
|
AsPrependAction
|
|
Actions
|
|
Statement
|
|
Policy
|
|
PolicyAssignment
|
|
MrtMessage
|
|
RPKIConf
|
|
RPKIState
|
|
RPKI
|
|
ROA
|
|
Vrf
|
|
Global
|
|
*/
|
|
package gobgpapi
|
|
|
|
import proto "github.com/golang/protobuf/proto"
|
|
import fmt "fmt"
|
|
import math "math"
|
|
|
|
import (
|
|
context "golang.org/x/net/context"
|
|
grpc "google.golang.org/grpc"
|
|
)
|
|
|
|
// Reference imports to suppress errors if they are not otherwise used.
|
|
var _ = proto.Marshal
|
|
var _ = fmt.Errorf
|
|
var _ = math.Inf
|
|
|
|
type Resource int32
|
|
|
|
const (
|
|
Resource_GLOBAL Resource = 0
|
|
Resource_LOCAL Resource = 1
|
|
Resource_ADJ_IN Resource = 2
|
|
Resource_ADJ_OUT Resource = 3
|
|
Resource_VRF Resource = 4
|
|
)
|
|
|
|
var Resource_name = map[int32]string{
|
|
0: "GLOBAL",
|
|
1: "LOCAL",
|
|
2: "ADJ_IN",
|
|
3: "ADJ_OUT",
|
|
4: "VRF",
|
|
}
|
|
var Resource_value = map[string]int32{
|
|
"GLOBAL": 0,
|
|
"LOCAL": 1,
|
|
"ADJ_IN": 2,
|
|
"ADJ_OUT": 3,
|
|
"VRF": 4,
|
|
}
|
|
|
|
func (x Resource) String() string {
|
|
return proto.EnumName(Resource_name, int32(x))
|
|
}
|
|
|
|
type Operation int32
|
|
|
|
const (
|
|
Operation_ADD Operation = 0
|
|
Operation_DEL Operation = 1
|
|
Operation_DEL_ALL Operation = 2
|
|
Operation_REPLACE Operation = 3
|
|
)
|
|
|
|
var Operation_name = map[int32]string{
|
|
0: "ADD",
|
|
1: "DEL",
|
|
2: "DEL_ALL",
|
|
3: "REPLACE",
|
|
}
|
|
var Operation_value = map[string]int32{
|
|
"ADD": 0,
|
|
"DEL": 1,
|
|
"DEL_ALL": 2,
|
|
"REPLACE": 3,
|
|
}
|
|
|
|
func (x Operation) String() string {
|
|
return proto.EnumName(Operation_name, int32(x))
|
|
}
|
|
|
|
type DefinedType int32
|
|
|
|
const (
|
|
DefinedType_PREFIX DefinedType = 0
|
|
DefinedType_NEIGHBOR DefinedType = 1
|
|
DefinedType_TAG DefinedType = 2
|
|
DefinedType_AS_PATH DefinedType = 3
|
|
DefinedType_COMMUNITY DefinedType = 4
|
|
DefinedType_EXT_COMMUNITY DefinedType = 5
|
|
)
|
|
|
|
var DefinedType_name = map[int32]string{
|
|
0: "PREFIX",
|
|
1: "NEIGHBOR",
|
|
2: "TAG",
|
|
3: "AS_PATH",
|
|
4: "COMMUNITY",
|
|
5: "EXT_COMMUNITY",
|
|
}
|
|
var DefinedType_value = map[string]int32{
|
|
"PREFIX": 0,
|
|
"NEIGHBOR": 1,
|
|
"TAG": 2,
|
|
"AS_PATH": 3,
|
|
"COMMUNITY": 4,
|
|
"EXT_COMMUNITY": 5,
|
|
}
|
|
|
|
func (x DefinedType) String() string {
|
|
return proto.EnumName(DefinedType_name, int32(x))
|
|
}
|
|
|
|
type MatchType int32
|
|
|
|
const (
|
|
MatchType_ANY MatchType = 0
|
|
MatchType_ALL MatchType = 1
|
|
MatchType_INVERT MatchType = 2
|
|
)
|
|
|
|
var MatchType_name = map[int32]string{
|
|
0: "ANY",
|
|
1: "ALL",
|
|
2: "INVERT",
|
|
}
|
|
var MatchType_value = map[string]int32{
|
|
"ANY": 0,
|
|
"ALL": 1,
|
|
"INVERT": 2,
|
|
}
|
|
|
|
func (x MatchType) String() string {
|
|
return proto.EnumName(MatchType_name, int32(x))
|
|
}
|
|
|
|
type AsPathLengthType int32
|
|
|
|
const (
|
|
AsPathLengthType_EQ AsPathLengthType = 0
|
|
AsPathLengthType_GE AsPathLengthType = 1
|
|
AsPathLengthType_LE AsPathLengthType = 2
|
|
)
|
|
|
|
var AsPathLengthType_name = map[int32]string{
|
|
0: "EQ",
|
|
1: "GE",
|
|
2: "LE",
|
|
}
|
|
var AsPathLengthType_value = map[string]int32{
|
|
"EQ": 0,
|
|
"GE": 1,
|
|
"LE": 2,
|
|
}
|
|
|
|
func (x AsPathLengthType) String() string {
|
|
return proto.EnumName(AsPathLengthType_name, int32(x))
|
|
}
|
|
|
|
type RouteAction int32
|
|
|
|
const (
|
|
RouteAction_NONE RouteAction = 0
|
|
RouteAction_ACCEPT RouteAction = 1
|
|
RouteAction_REJECT RouteAction = 2
|
|
)
|
|
|
|
var RouteAction_name = map[int32]string{
|
|
0: "NONE",
|
|
1: "ACCEPT",
|
|
2: "REJECT",
|
|
}
|
|
var RouteAction_value = map[string]int32{
|
|
"NONE": 0,
|
|
"ACCEPT": 1,
|
|
"REJECT": 2,
|
|
}
|
|
|
|
func (x RouteAction) String() string {
|
|
return proto.EnumName(RouteAction_name, int32(x))
|
|
}
|
|
|
|
type CommunityActionType int32
|
|
|
|
const (
|
|
CommunityActionType_COMMUNITY_ADD CommunityActionType = 0
|
|
CommunityActionType_COMMUNITY_REMOVE CommunityActionType = 1
|
|
CommunityActionType_COMMUNITY_REPLACE CommunityActionType = 2
|
|
)
|
|
|
|
var CommunityActionType_name = map[int32]string{
|
|
0: "COMMUNITY_ADD",
|
|
1: "COMMUNITY_REMOVE",
|
|
2: "COMMUNITY_REPLACE",
|
|
}
|
|
var CommunityActionType_value = map[string]int32{
|
|
"COMMUNITY_ADD": 0,
|
|
"COMMUNITY_REMOVE": 1,
|
|
"COMMUNITY_REPLACE": 2,
|
|
}
|
|
|
|
func (x CommunityActionType) String() string {
|
|
return proto.EnumName(CommunityActionType_name, int32(x))
|
|
}
|
|
|
|
type MedActionType int32
|
|
|
|
const (
|
|
MedActionType_MED_MOD MedActionType = 0
|
|
MedActionType_MED_REPLACE MedActionType = 1
|
|
)
|
|
|
|
var MedActionType_name = map[int32]string{
|
|
0: "MED_MOD",
|
|
1: "MED_REPLACE",
|
|
}
|
|
var MedActionType_value = map[string]int32{
|
|
"MED_MOD": 0,
|
|
"MED_REPLACE": 1,
|
|
}
|
|
|
|
func (x MedActionType) String() string {
|
|
return proto.EnumName(MedActionType_name, int32(x))
|
|
}
|
|
|
|
type PolicyType int32
|
|
|
|
const (
|
|
PolicyType_IN PolicyType = 0
|
|
PolicyType_IMPORT PolicyType = 1
|
|
PolicyType_EXPORT PolicyType = 2
|
|
)
|
|
|
|
var PolicyType_name = map[int32]string{
|
|
0: "IN",
|
|
1: "IMPORT",
|
|
2: "EXPORT",
|
|
}
|
|
var PolicyType_value = map[string]int32{
|
|
"IN": 0,
|
|
"IMPORT": 1,
|
|
"EXPORT": 2,
|
|
}
|
|
|
|
func (x PolicyType) String() string {
|
|
return proto.EnumName(PolicyType_name, int32(x))
|
|
}
|
|
|
|
type Error_ErrorCode int32
|
|
|
|
const (
|
|
Error_SUCCESS Error_ErrorCode = 0
|
|
Error_FAIL Error_ErrorCode = 1
|
|
)
|
|
|
|
var Error_ErrorCode_name = map[int32]string{
|
|
0: "SUCCESS",
|
|
1: "FAIL",
|
|
}
|
|
var Error_ErrorCode_value = map[string]int32{
|
|
"SUCCESS": 0,
|
|
"FAIL": 1,
|
|
}
|
|
|
|
func (x Error_ErrorCode) String() string {
|
|
return proto.EnumName(Error_ErrorCode_name, int32(x))
|
|
}
|
|
|
|
type Error struct {
|
|
Code Error_ErrorCode `protobuf:"varint,1,opt,name=code,enum=gobgpapi.Error_ErrorCode" json:"code,omitempty"`
|
|
Msg string `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
|
|
}
|
|
|
|
func (m *Error) Reset() { *m = Error{} }
|
|
func (m *Error) String() string { return proto.CompactTextString(m) }
|
|
func (*Error) ProtoMessage() {}
|
|
|
|
type Arguments struct {
|
|
Resource Resource `protobuf:"varint,1,opt,name=resource,enum=gobgpapi.Resource" json:"resource,omitempty"`
|
|
Rf uint32 `protobuf:"varint,2,opt,name=rf" json:"rf,omitempty"`
|
|
Name string `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
|
|
}
|
|
|
|
func (m *Arguments) Reset() { *m = Arguments{} }
|
|
func (m *Arguments) String() string { return proto.CompactTextString(m) }
|
|
func (*Arguments) ProtoMessage() {}
|
|
|
|
type ModPathArguments struct {
|
|
Resource Resource `protobuf:"varint,1,opt,name=resource,enum=gobgpapi.Resource" json:"resource,omitempty"`
|
|
Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
|
|
Paths []*Path `protobuf:"bytes,3,rep,name=paths" json:"paths,omitempty"`
|
|
}
|
|
|
|
func (m *ModPathArguments) Reset() { *m = ModPathArguments{} }
|
|
func (m *ModPathArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModPathArguments) ProtoMessage() {}
|
|
|
|
func (m *ModPathArguments) GetPaths() []*Path {
|
|
if m != nil {
|
|
return m.Paths
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ModNeighborArguments struct {
|
|
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
|
|
Peer *Peer `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
|
|
}
|
|
|
|
func (m *ModNeighborArguments) Reset() { *m = ModNeighborArguments{} }
|
|
func (m *ModNeighborArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModNeighborArguments) ProtoMessage() {}
|
|
|
|
func (m *ModNeighborArguments) GetPeer() *Peer {
|
|
if m != nil {
|
|
return m.Peer
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type MrtArguments struct {
|
|
Resource Resource `protobuf:"varint,1,opt,name=resource,enum=gobgpapi.Resource" json:"resource,omitempty"`
|
|
Rf uint32 `protobuf:"varint,2,opt,name=rf" json:"rf,omitempty"`
|
|
Interval uint64 `protobuf:"varint,3,opt,name=interval" json:"interval,omitempty"`
|
|
NeighborAddress string `protobuf:"bytes,4,opt,name=neighbor_address" json:"neighbor_address,omitempty"`
|
|
}
|
|
|
|
func (m *MrtArguments) Reset() { *m = MrtArguments{} }
|
|
func (m *MrtArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*MrtArguments) ProtoMessage() {}
|
|
|
|
type ModVrfArguments struct {
|
|
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
|
|
Vrf *Vrf `protobuf:"bytes,2,opt,name=vrf" json:"vrf,omitempty"`
|
|
}
|
|
|
|
func (m *ModVrfArguments) Reset() { *m = ModVrfArguments{} }
|
|
func (m *ModVrfArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModVrfArguments) ProtoMessage() {}
|
|
|
|
func (m *ModVrfArguments) GetVrf() *Vrf {
|
|
if m != nil {
|
|
return m.Vrf
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ModDefinedSetArguments struct {
|
|
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
|
|
Set *DefinedSet `protobuf:"bytes,2,opt,name=set" json:"set,omitempty"`
|
|
}
|
|
|
|
func (m *ModDefinedSetArguments) Reset() { *m = ModDefinedSetArguments{} }
|
|
func (m *ModDefinedSetArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModDefinedSetArguments) ProtoMessage() {}
|
|
|
|
func (m *ModDefinedSetArguments) GetSet() *DefinedSet {
|
|
if m != nil {
|
|
return m.Set
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ModStatementArguments struct {
|
|
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
|
|
Statement *Statement `protobuf:"bytes,2,opt,name=statement" json:"statement,omitempty"`
|
|
}
|
|
|
|
func (m *ModStatementArguments) Reset() { *m = ModStatementArguments{} }
|
|
func (m *ModStatementArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModStatementArguments) ProtoMessage() {}
|
|
|
|
func (m *ModStatementArguments) GetStatement() *Statement {
|
|
if m != nil {
|
|
return m.Statement
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ModPolicyArguments struct {
|
|
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
|
|
Policy *Policy `protobuf:"bytes,2,opt,name=policy" json:"policy,omitempty"`
|
|
// if this flag is set, gobgpd won't define new statements
|
|
// but refer existing statements using statement's names in this arguments.
|
|
// this flag only works with Operation_ADD
|
|
ReferExistingStatements bool `protobuf:"varint,3,opt,name=refer_existing_statements" json:"refer_existing_statements,omitempty"`
|
|
// if this flag is set, gobgpd won't delete any statements
|
|
// even if some statements get not used by any policy by this operation.
|
|
// this flag means nothing if it is used with Operation_ADD
|
|
PreserveStatements bool `protobuf:"varint,4,opt,name=preserve_statements" json:"preserve_statements,omitempty"`
|
|
}
|
|
|
|
func (m *ModPolicyArguments) Reset() { *m = ModPolicyArguments{} }
|
|
func (m *ModPolicyArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModPolicyArguments) ProtoMessage() {}
|
|
|
|
func (m *ModPolicyArguments) GetPolicy() *Policy {
|
|
if m != nil {
|
|
return m.Policy
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ModPolicyAssignmentArguments struct {
|
|
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
|
|
Assignment *PolicyAssignment `protobuf:"bytes,2,opt,name=assignment" json:"assignment,omitempty"`
|
|
}
|
|
|
|
func (m *ModPolicyAssignmentArguments) Reset() { *m = ModPolicyAssignmentArguments{} }
|
|
func (m *ModPolicyAssignmentArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModPolicyAssignmentArguments) ProtoMessage() {}
|
|
|
|
func (m *ModPolicyAssignmentArguments) GetAssignment() *PolicyAssignment {
|
|
if m != nil {
|
|
return m.Assignment
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ModGlobalConfigArguments struct {
|
|
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
|
|
Global *Global `protobuf:"bytes,2,opt,name=global" json:"global,omitempty"`
|
|
}
|
|
|
|
func (m *ModGlobalConfigArguments) Reset() { *m = ModGlobalConfigArguments{} }
|
|
func (m *ModGlobalConfigArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModGlobalConfigArguments) ProtoMessage() {}
|
|
|
|
func (m *ModGlobalConfigArguments) GetGlobal() *Global {
|
|
if m != nil {
|
|
return m.Global
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Path struct {
|
|
Nlri []byte `protobuf:"bytes,1,opt,name=nlri,proto3" json:"nlri,omitempty"`
|
|
Pattrs [][]byte `protobuf:"bytes,2,rep,name=pattrs,proto3" json:"pattrs,omitempty"`
|
|
Age int64 `protobuf:"varint,3,opt,name=age" json:"age,omitempty"`
|
|
Best bool `protobuf:"varint,4,opt,name=best" json:"best,omitempty"`
|
|
IsWithdraw bool `protobuf:"varint,5,opt,name=is_withdraw" json:"is_withdraw,omitempty"`
|
|
Validation int32 `protobuf:"varint,6,opt,name=validation" json:"validation,omitempty"`
|
|
NoImplicitWithdraw bool `protobuf:"varint,7,opt,name=no_implicit_withdraw" json:"no_implicit_withdraw,omitempty"`
|
|
Rf uint32 `protobuf:"varint,8,opt,name=rf" json:"rf,omitempty"`
|
|
SourceAsn uint32 `protobuf:"varint,9,opt,name=source_asn" json:"source_asn,omitempty"`
|
|
SourceId string `protobuf:"bytes,10,opt,name=source_id" json:"source_id,omitempty"`
|
|
Filtered bool `protobuf:"varint,11,opt,name=filtered" json:"filtered,omitempty"`
|
|
}
|
|
|
|
func (m *Path) Reset() { *m = Path{} }
|
|
func (m *Path) String() string { return proto.CompactTextString(m) }
|
|
func (*Path) ProtoMessage() {}
|
|
|
|
type Destination struct {
|
|
Prefix string `protobuf:"bytes,1,opt,name=prefix" json:"prefix,omitempty"`
|
|
Paths []*Path `protobuf:"bytes,2,rep,name=paths" json:"paths,omitempty"`
|
|
}
|
|
|
|
func (m *Destination) Reset() { *m = Destination{} }
|
|
func (m *Destination) String() string { return proto.CompactTextString(m) }
|
|
func (*Destination) ProtoMessage() {}
|
|
|
|
func (m *Destination) GetPaths() []*Path {
|
|
if m != nil {
|
|
return m.Paths
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Peer struct {
|
|
Addpaths *AddPaths `protobuf:"bytes,1,opt,name=addpaths" json:"addpaths,omitempty"`
|
|
Afisafis *AfiSafis `protobuf:"bytes,2,opt,name=afisafis" json:"afisafis,omitempty"`
|
|
ApplyPolicy *ApplyPolicy `protobuf:"bytes,3,opt,name=apply_policy" json:"apply_policy,omitempty"`
|
|
AsPathOptions *AsPathOptions `protobuf:"bytes,4,opt,name=as_path_options" json:"as_path_options,omitempty"`
|
|
Conf *PeerConf `protobuf:"bytes,5,opt,name=conf" json:"conf,omitempty"`
|
|
EbgpMultihop *EbgpMultihop `protobuf:"bytes,6,opt,name=ebgp_multihop" json:"ebgp_multihop,omitempty"`
|
|
ErrorHandling *ErrorHandling `protobuf:"bytes,7,opt,name=error_handling" json:"error_handling,omitempty"`
|
|
GracefulRestart *PeerGracefulRestart `protobuf:"bytes,8,opt,name=graceful_restart" json:"graceful_restart,omitempty"`
|
|
LoggingOptions *LoggingOptions `protobuf:"bytes,9,opt,name=logging_options" json:"logging_options,omitempty"`
|
|
NighborAddress string `protobuf:"bytes,10,opt,name=nighbor_address" json:"nighbor_address,omitempty"`
|
|
RouteReflector *RouteReflector `protobuf:"bytes,11,opt,name=route_reflector" json:"route_reflector,omitempty"`
|
|
Info *PeerState `protobuf:"bytes,12,opt,name=info" json:"info,omitempty"`
|
|
Timers *Timers `protobuf:"bytes,13,opt,name=timers" json:"timers,omitempty"`
|
|
Transport *Transport `protobuf:"bytes,14,opt,name=transport" json:"transport,omitempty"`
|
|
UseMultiplePaths *UseMultiplePaths `protobuf:"bytes,15,opt,name=use_multiple_paths" json:"use_multiple_paths,omitempty"`
|
|
RouteServer *RouteServer `protobuf:"bytes,16,opt,name=route_server" json:"route_server,omitempty"`
|
|
}
|
|
|
|
func (m *Peer) Reset() { *m = Peer{} }
|
|
func (m *Peer) String() string { return proto.CompactTextString(m) }
|
|
func (*Peer) ProtoMessage() {}
|
|
|
|
func (m *Peer) GetAddpaths() *AddPaths {
|
|
if m != nil {
|
|
return m.Addpaths
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetAfisafis() *AfiSafis {
|
|
if m != nil {
|
|
return m.Afisafis
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetApplyPolicy() *ApplyPolicy {
|
|
if m != nil {
|
|
return m.ApplyPolicy
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetAsPathOptions() *AsPathOptions {
|
|
if m != nil {
|
|
return m.AsPathOptions
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetConf() *PeerConf {
|
|
if m != nil {
|
|
return m.Conf
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetEbgpMultihop() *EbgpMultihop {
|
|
if m != nil {
|
|
return m.EbgpMultihop
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetErrorHandling() *ErrorHandling {
|
|
if m != nil {
|
|
return m.ErrorHandling
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetGracefulRestart() *PeerGracefulRestart {
|
|
if m != nil {
|
|
return m.GracefulRestart
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetLoggingOptions() *LoggingOptions {
|
|
if m != nil {
|
|
return m.LoggingOptions
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetRouteReflector() *RouteReflector {
|
|
if m != nil {
|
|
return m.RouteReflector
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetInfo() *PeerState {
|
|
if m != nil {
|
|
return m.Info
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetTimers() *Timers {
|
|
if m != nil {
|
|
return m.Timers
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetTransport() *Transport {
|
|
if m != nil {
|
|
return m.Transport
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetUseMultiplePaths() *UseMultiplePaths {
|
|
if m != nil {
|
|
return m.UseMultiplePaths
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetRouteServer() *RouteServer {
|
|
if m != nil {
|
|
return m.RouteServer
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type AddPaths struct {
|
|
Receive bool `protobuf:"varint,1,opt,name=receive" json:"receive,omitempty"`
|
|
SendMax uint32 `protobuf:"varint,2,opt,name=send_max" json:"send_max,omitempty"`
|
|
}
|
|
|
|
func (m *AddPaths) Reset() { *m = AddPaths{} }
|
|
func (m *AddPaths) String() string { return proto.CompactTextString(m) }
|
|
func (*AddPaths) ProtoMessage() {}
|
|
|
|
type AfiSafis struct {
|
|
Afisafi []*AfiSafi `protobuf:"bytes,1,rep,name=afisafi" json:"afisafi,omitempty"`
|
|
}
|
|
|
|
func (m *AfiSafis) Reset() { *m = AfiSafis{} }
|
|
func (m *AfiSafis) String() string { return proto.CompactTextString(m) }
|
|
func (*AfiSafis) ProtoMessage() {}
|
|
|
|
func (m *AfiSafis) GetAfisafi() []*AfiSafi {
|
|
if m != nil {
|
|
return m.Afisafi
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type AfiSafi struct {
|
|
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
|
|
ApplyPolicy *ApplyPolicy `protobuf:"bytes,2,opt,name=apply_policy" json:"apply_policy,omitempty"`
|
|
Enabled bool `protobuf:"varint,3,opt,name=enabled" json:"enabled,omitempty"`
|
|
GracefulRestart *AfiSafiGracefulRestart `protobuf:"bytes,4,opt,name=graceful_restart" json:"graceful_restart,omitempty"`
|
|
Ipv4LabelledUnicast *LabelledUnicast `protobuf:"bytes,5,opt,name=ipv4_labelled_unicast" json:"ipv4_labelled_unicast,omitempty"`
|
|
Ipv4Unicast *Unicast `protobuf:"bytes,6,opt,name=ipv4_unicast" json:"ipv4_unicast,omitempty"`
|
|
Ipv6LabelledUnicast *LabelledUnicast `protobuf:"bytes,7,opt,name=ipv6_labelled_unicast" json:"ipv6_labelled_unicast,omitempty"`
|
|
Ipv6Unicast *Unicast `protobuf:"bytes,8,opt,name=ipv6_unicast" json:"ipv6_unicast,omitempty"`
|
|
L2VpnEvpn *Vpn `protobuf:"bytes,9,opt,name=l2_vpn_evpn" json:"l2_vpn_evpn,omitempty"`
|
|
L2VpnVpls *Vpn `protobuf:"bytes,10,opt,name=l2_vpn_vpls" json:"l2_vpn_vpls,omitempty"`
|
|
L3VpnIpv4Multicast *Vpn `protobuf:"bytes,11,opt,name=l3_vpn_ipv4_multicast" json:"l3_vpn_ipv4_multicast,omitempty"`
|
|
L3VpnIpv4Unicast *Vpn `protobuf:"bytes,12,opt,name=l3_vpn_ipv4_unicast" json:"l3_vpn_ipv4_unicast,omitempty"`
|
|
L3VpnIpv6Multicast *Vpn `protobuf:"bytes,13,opt,name=l3_vpn_ipv6_multicast" json:"l3_vpn_ipv6_multicast,omitempty"`
|
|
L3VpnIpv6Unicast *Vpn `protobuf:"bytes,14,opt,name=l3_vpn_ipv6_unicast" json:"l3_vpn_ipv6_unicast,omitempty"`
|
|
UseMultiplePaths *UseMultiplePaths `protobuf:"bytes,15,opt,name=use_multiple_paths" json:"use_multiple_paths,omitempty"`
|
|
Active bool `protobuf:"varint,16,opt,name=active" json:"active,omitempty"`
|
|
Prefixes *Prefixes `protobuf:"bytes,17,opt,name=prefixes" json:"prefixes,omitempty"`
|
|
}
|
|
|
|
func (m *AfiSafi) Reset() { *m = AfiSafi{} }
|
|
func (m *AfiSafi) String() string { return proto.CompactTextString(m) }
|
|
func (*AfiSafi) ProtoMessage() {}
|
|
|
|
func (m *AfiSafi) GetApplyPolicy() *ApplyPolicy {
|
|
if m != nil {
|
|
return m.ApplyPolicy
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetGracefulRestart() *AfiSafiGracefulRestart {
|
|
if m != nil {
|
|
return m.GracefulRestart
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetIpv4LabelledUnicast() *LabelledUnicast {
|
|
if m != nil {
|
|
return m.Ipv4LabelledUnicast
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetIpv4Unicast() *Unicast {
|
|
if m != nil {
|
|
return m.Ipv4Unicast
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetIpv6LabelledUnicast() *LabelledUnicast {
|
|
if m != nil {
|
|
return m.Ipv6LabelledUnicast
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetIpv6Unicast() *Unicast {
|
|
if m != nil {
|
|
return m.Ipv6Unicast
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetL2VpnEvpn() *Vpn {
|
|
if m != nil {
|
|
return m.L2VpnEvpn
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetL2VpnVpls() *Vpn {
|
|
if m != nil {
|
|
return m.L2VpnVpls
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetL3VpnIpv4Multicast() *Vpn {
|
|
if m != nil {
|
|
return m.L3VpnIpv4Multicast
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetL3VpnIpv4Unicast() *Vpn {
|
|
if m != nil {
|
|
return m.L3VpnIpv4Unicast
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetL3VpnIpv6Multicast() *Vpn {
|
|
if m != nil {
|
|
return m.L3VpnIpv6Multicast
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetL3VpnIpv6Unicast() *Vpn {
|
|
if m != nil {
|
|
return m.L3VpnIpv6Unicast
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetUseMultiplePaths() *UseMultiplePaths {
|
|
if m != nil {
|
|
return m.UseMultiplePaths
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *AfiSafi) GetPrefixes() *Prefixes {
|
|
if m != nil {
|
|
return m.Prefixes
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ApplyPolicy struct {
|
|
InPolicy *PolicyAssignment `protobuf:"bytes,1,opt,name=in_policy" json:"in_policy,omitempty"`
|
|
ExportPolicy *PolicyAssignment `protobuf:"bytes,2,opt,name=export_policy" json:"export_policy,omitempty"`
|
|
ImportPolicy *PolicyAssignment `protobuf:"bytes,3,opt,name=import_policy" json:"import_policy,omitempty"`
|
|
}
|
|
|
|
func (m *ApplyPolicy) Reset() { *m = ApplyPolicy{} }
|
|
func (m *ApplyPolicy) String() string { return proto.CompactTextString(m) }
|
|
func (*ApplyPolicy) ProtoMessage() {}
|
|
|
|
func (m *ApplyPolicy) GetInPolicy() *PolicyAssignment {
|
|
if m != nil {
|
|
return m.InPolicy
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *ApplyPolicy) GetExportPolicy() *PolicyAssignment {
|
|
if m != nil {
|
|
return m.ExportPolicy
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *ApplyPolicy) GetImportPolicy() *PolicyAssignment {
|
|
if m != nil {
|
|
return m.ImportPolicy
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type AfiSafiGracefulRestart struct {
|
|
Advertised bool `protobuf:"varint,1,opt,name=advertised" json:"advertised,omitempty"`
|
|
Enabled bool `protobuf:"varint,2,opt,name=enabled" json:"enabled,omitempty"`
|
|
Received bool `protobuf:"varint,3,opt,name=received" json:"received,omitempty"`
|
|
}
|
|
|
|
func (m *AfiSafiGracefulRestart) Reset() { *m = AfiSafiGracefulRestart{} }
|
|
func (m *AfiSafiGracefulRestart) String() string { return proto.CompactTextString(m) }
|
|
func (*AfiSafiGracefulRestart) ProtoMessage() {}
|
|
|
|
type LabelledUnicast struct {
|
|
PrefixLimit *PrefixLimit `protobuf:"bytes,1,opt,name=prefix_limit" json:"prefix_limit,omitempty"`
|
|
}
|
|
|
|
func (m *LabelledUnicast) Reset() { *m = LabelledUnicast{} }
|
|
func (m *LabelledUnicast) String() string { return proto.CompactTextString(m) }
|
|
func (*LabelledUnicast) ProtoMessage() {}
|
|
|
|
func (m *LabelledUnicast) GetPrefixLimit() *PrefixLimit {
|
|
if m != nil {
|
|
return m.PrefixLimit
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type PrefixLimit struct {
|
|
MaxPrefixes uint32 `protobuf:"varint,1,opt,name=max_prefixes" json:"max_prefixes,omitempty"`
|
|
RestartTimer uint64 `protobuf:"varint,2,opt,name=restart_timer" json:"restart_timer,omitempty"`
|
|
ShutdownThresholdPct uint32 `protobuf:"varint,3,opt,name=shutdown_threshold_pct" json:"shutdown_threshold_pct,omitempty"`
|
|
}
|
|
|
|
func (m *PrefixLimit) Reset() { *m = PrefixLimit{} }
|
|
func (m *PrefixLimit) String() string { return proto.CompactTextString(m) }
|
|
func (*PrefixLimit) ProtoMessage() {}
|
|
|
|
type Unicast struct {
|
|
SendDefaultRoute bool `protobuf:"varint,1,opt,name=send_default_route" json:"send_default_route,omitempty"`
|
|
PrefixLimit *PrefixLimit `protobuf:"bytes,2,opt,name=prefix_limit" json:"prefix_limit,omitempty"`
|
|
}
|
|
|
|
func (m *Unicast) Reset() { *m = Unicast{} }
|
|
func (m *Unicast) String() string { return proto.CompactTextString(m) }
|
|
func (*Unicast) ProtoMessage() {}
|
|
|
|
func (m *Unicast) GetPrefixLimit() *PrefixLimit {
|
|
if m != nil {
|
|
return m.PrefixLimit
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Vpn struct {
|
|
PrefixLimit *PrefixLimit `protobuf:"bytes,1,opt,name=prefix_limit" json:"prefix_limit,omitempty"`
|
|
}
|
|
|
|
func (m *Vpn) Reset() { *m = Vpn{} }
|
|
func (m *Vpn) String() string { return proto.CompactTextString(m) }
|
|
func (*Vpn) ProtoMessage() {}
|
|
|
|
func (m *Vpn) GetPrefixLimit() *PrefixLimit {
|
|
if m != nil {
|
|
return m.PrefixLimit
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Prefixes struct {
|
|
Installed uint32 `protobuf:"varint,1,opt,name=installed" json:"installed,omitempty"`
|
|
Received uint32 `protobuf:"varint,2,opt,name=received" json:"received,omitempty"`
|
|
Sent uint32 `protobuf:"varint,3,opt,name=sent" json:"sent,omitempty"`
|
|
}
|
|
|
|
func (m *Prefixes) Reset() { *m = Prefixes{} }
|
|
func (m *Prefixes) String() string { return proto.CompactTextString(m) }
|
|
func (*Prefixes) ProtoMessage() {}
|
|
|
|
type UseMultiplePaths struct {
|
|
Enabled bool `protobuf:"varint,1,opt,name=enabled" json:"enabled,omitempty"`
|
|
Ebgp *Ebgp `protobuf:"bytes,2,opt,name=ebgp" json:"ebgp,omitempty"`
|
|
}
|
|
|
|
func (m *UseMultiplePaths) Reset() { *m = UseMultiplePaths{} }
|
|
func (m *UseMultiplePaths) String() string { return proto.CompactTextString(m) }
|
|
func (*UseMultiplePaths) ProtoMessage() {}
|
|
|
|
func (m *UseMultiplePaths) GetEbgp() *Ebgp {
|
|
if m != nil {
|
|
return m.Ebgp
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Ebgp struct {
|
|
AllowMultipleAs bool `protobuf:"varint,1,opt,name=allow_multiple_as" json:"allow_multiple_as,omitempty"`
|
|
}
|
|
|
|
func (m *Ebgp) Reset() { *m = Ebgp{} }
|
|
func (m *Ebgp) String() string { return proto.CompactTextString(m) }
|
|
func (*Ebgp) ProtoMessage() {}
|
|
|
|
type AsPathOptions struct {
|
|
AllowOwnAs uint32 `protobuf:"varint,1,opt,name=allow_own_as" json:"allow_own_as,omitempty"`
|
|
ReplacePeerAs bool `protobuf:"varint,2,opt,name=replace_peer_as" json:"replace_peer_as,omitempty"`
|
|
}
|
|
|
|
func (m *AsPathOptions) Reset() { *m = AsPathOptions{} }
|
|
func (m *AsPathOptions) String() string { return proto.CompactTextString(m) }
|
|
func (*AsPathOptions) ProtoMessage() {}
|
|
|
|
type PeerConf struct {
|
|
AuthPassword string `protobuf:"bytes,1,opt,name=auth_password" json:"auth_password,omitempty"`
|
|
Description string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
|
|
LocalAs uint32 `protobuf:"varint,3,opt,name=local_as" json:"local_as,omitempty"`
|
|
NeighborAddress string `protobuf:"bytes,4,opt,name=neighbor_address" json:"neighbor_address,omitempty"`
|
|
PeerAs uint32 `protobuf:"varint,5,opt,name=peer_as" json:"peer_as,omitempty"`
|
|
PeerGroup string `protobuf:"bytes,6,opt,name=peer_group" json:"peer_group,omitempty"`
|
|
PeerType uint32 `protobuf:"varint,7,opt,name=peer_type" json:"peer_type,omitempty"`
|
|
RemovePrivateAs uint32 `protobuf:"varint,8,opt,name=remove_private_as" json:"remove_private_as,omitempty"`
|
|
RouteFlapDamping bool `protobuf:"varint,9,opt,name=route_flap_damping" json:"route_flap_damping,omitempty"`
|
|
SendCommunity uint32 `protobuf:"varint,10,opt,name=send_community" json:"send_community,omitempty"`
|
|
RemoteCap [][]byte `protobuf:"bytes,11,rep,name=remote_cap,proto3" json:"remote_cap,omitempty"`
|
|
LocalCap [][]byte `protobuf:"bytes,12,rep,name=local_cap,proto3" json:"local_cap,omitempty"`
|
|
}
|
|
|
|
func (m *PeerConf) Reset() { *m = PeerConf{} }
|
|
func (m *PeerConf) String() string { return proto.CompactTextString(m) }
|
|
func (*PeerConf) ProtoMessage() {}
|
|
|
|
type EbgpMultihop struct {
|
|
Enabled bool `protobuf:"varint,1,opt,name=enabled" json:"enabled,omitempty"`
|
|
MultihopTtl uint32 `protobuf:"varint,2,opt,name=multihop_ttl" json:"multihop_ttl,omitempty"`
|
|
}
|
|
|
|
func (m *EbgpMultihop) Reset() { *m = EbgpMultihop{} }
|
|
func (m *EbgpMultihop) String() string { return proto.CompactTextString(m) }
|
|
func (*EbgpMultihop) ProtoMessage() {}
|
|
|
|
type ErrorHandling struct {
|
|
ErroneousUpdateMessages uint32 `protobuf:"varint,1,opt,name=erroneous_update_messages" json:"erroneous_update_messages,omitempty"`
|
|
TreatAsWithdraw bool `protobuf:"varint,2,opt,name=treat_as_withdraw" json:"treat_as_withdraw,omitempty"`
|
|
}
|
|
|
|
func (m *ErrorHandling) Reset() { *m = ErrorHandling{} }
|
|
func (m *ErrorHandling) String() string { return proto.CompactTextString(m) }
|
|
func (*ErrorHandling) ProtoMessage() {}
|
|
|
|
type PeerGracefulRestart struct {
|
|
Enabled bool `protobuf:"varint,1,opt,name=enabled" json:"enabled,omitempty"`
|
|
HelperOnly bool `protobuf:"varint,2,opt,name=helper_only" json:"helper_only,omitempty"`
|
|
LocalRestarting bool `protobuf:"varint,3,opt,name=local_restarting" json:"local_restarting,omitempty"`
|
|
Mode uint32 `protobuf:"varint,4,opt,name=mode" json:"mode,omitempty"`
|
|
PeerRestartTime uint32 `protobuf:"varint,5,opt,name=peer_restart_time" json:"peer_restart_time,omitempty"`
|
|
PeerRestarting bool `protobuf:"varint,6,opt,name=peer_restarting" json:"peer_restarting,omitempty"`
|
|
RestartTime uint32 `protobuf:"varint,7,opt,name=restart_time" json:"restart_time,omitempty"`
|
|
StaleRoutesTime uint64 `protobuf:"varint,8,opt,name=stale_routes_time" json:"stale_routes_time,omitempty"`
|
|
}
|
|
|
|
func (m *PeerGracefulRestart) Reset() { *m = PeerGracefulRestart{} }
|
|
func (m *PeerGracefulRestart) String() string { return proto.CompactTextString(m) }
|
|
func (*PeerGracefulRestart) ProtoMessage() {}
|
|
|
|
type LoggingOptions struct {
|
|
LogNeighborStateChanges bool `protobuf:"varint,1,opt,name=logNeighbor_state_changes" json:"logNeighbor_state_changes,omitempty"`
|
|
}
|
|
|
|
func (m *LoggingOptions) Reset() { *m = LoggingOptions{} }
|
|
func (m *LoggingOptions) String() string { return proto.CompactTextString(m) }
|
|
func (*LoggingOptions) ProtoMessage() {}
|
|
|
|
type RouteReflector struct {
|
|
RouteReflectorClient bool `protobuf:"varint,1,opt,name=route_reflector_client" json:"route_reflector_client,omitempty"`
|
|
RouteReflectorClusterId uint32 `protobuf:"varint,2,opt,name=route_reflector_cluster_id" json:"route_reflector_cluster_id,omitempty"`
|
|
}
|
|
|
|
func (m *RouteReflector) Reset() { *m = RouteReflector{} }
|
|
func (m *RouteReflector) String() string { return proto.CompactTextString(m) }
|
|
func (*RouteReflector) ProtoMessage() {}
|
|
|
|
type PeerState struct {
|
|
AuthPassword string `protobuf:"bytes,1,opt,name=auth_password" json:"auth_password,omitempty"`
|
|
Description string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
|
|
LocalAs uint32 `protobuf:"varint,3,opt,name=local_as" json:"local_as,omitempty"`
|
|
Messages *Messages `protobuf:"bytes,4,opt,name=messages" json:"messages,omitempty"`
|
|
NeighborAddress string `protobuf:"bytes,5,opt,name=neighbor_address" json:"neighbor_address,omitempty"`
|
|
PeerAs uint32 `protobuf:"varint,6,opt,name=peer_as" json:"peer_as,omitempty"`
|
|
PeerGroup string `protobuf:"bytes,7,opt,name=peer_group" json:"peer_group,omitempty"`
|
|
PeerType uint32 `protobuf:"varint,8,opt,name=peer_type" json:"peer_type,omitempty"`
|
|
Queues *Queues `protobuf:"bytes,9,opt,name=queues" json:"queues,omitempty"`
|
|
RemovePrivateAs uint32 `protobuf:"varint,10,opt,name=remove_private_as" json:"remove_private_as,omitempty"`
|
|
RouteFlapDamping bool `protobuf:"varint,11,opt,name=route_flap_damping" json:"route_flap_damping,omitempty"`
|
|
SendCommunity uint32 `protobuf:"varint,12,opt,name=send_community" json:"send_community,omitempty"`
|
|
SessionState uint32 `protobuf:"varint,13,opt,name=session_state" json:"session_state,omitempty"`
|
|
SupportedCapabilities []string `protobuf:"bytes,14,rep,name=supported_capabilities" json:"supported_capabilities,omitempty"`
|
|
BgpState string `protobuf:"bytes,15,opt,name=bgp_state" json:"bgp_state,omitempty"`
|
|
AdminState string `protobuf:"bytes,16,opt,name=admin_state" json:"admin_state,omitempty"`
|
|
Received uint32 `protobuf:"varint,17,opt,name=received" json:"received,omitempty"`
|
|
Accepted uint32 `protobuf:"varint,18,opt,name=accepted" json:"accepted,omitempty"`
|
|
Advertized uint32 `protobuf:"varint,19,opt,name=advertized" json:"advertized,omitempty"`
|
|
OutQ uint32 `protobuf:"varint,20,opt,name=out_q" json:"out_q,omitempty"`
|
|
Flops uint32 `protobuf:"varint,21,opt,name=flops" json:"flops,omitempty"`
|
|
}
|
|
|
|
func (m *PeerState) Reset() { *m = PeerState{} }
|
|
func (m *PeerState) String() string { return proto.CompactTextString(m) }
|
|
func (*PeerState) ProtoMessage() {}
|
|
|
|
func (m *PeerState) GetMessages() *Messages {
|
|
if m != nil {
|
|
return m.Messages
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *PeerState) GetQueues() *Queues {
|
|
if m != nil {
|
|
return m.Queues
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Messages struct {
|
|
Received *Message `protobuf:"bytes,1,opt,name=received" json:"received,omitempty"`
|
|
Sent *Message `protobuf:"bytes,2,opt,name=sent" json:"sent,omitempty"`
|
|
}
|
|
|
|
func (m *Messages) Reset() { *m = Messages{} }
|
|
func (m *Messages) String() string { return proto.CompactTextString(m) }
|
|
func (*Messages) ProtoMessage() {}
|
|
|
|
func (m *Messages) GetReceived() *Message {
|
|
if m != nil {
|
|
return m.Received
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Messages) GetSent() *Message {
|
|
if m != nil {
|
|
return m.Sent
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Message struct {
|
|
NOTIFICATION uint64 `protobuf:"varint,1,opt,name=NOTIFICATION" json:"NOTIFICATION,omitempty"`
|
|
UPDATE uint64 `protobuf:"varint,2,opt,name=UPDATE" json:"UPDATE,omitempty"`
|
|
OPEN uint64 `protobuf:"varint,3,opt,name=OPEN" json:"OPEN,omitempty"`
|
|
KEEPALIVE uint64 `protobuf:"varint,4,opt,name=KEEPALIVE" json:"KEEPALIVE,omitempty"`
|
|
REFRESH uint64 `protobuf:"varint,5,opt,name=REFRESH" json:"REFRESH,omitempty"`
|
|
DISCARDED uint64 `protobuf:"varint,6,opt,name=DISCARDED" json:"DISCARDED,omitempty"`
|
|
TOTAL uint64 `protobuf:"varint,7,opt,name=TOTAL" json:"TOTAL,omitempty"`
|
|
}
|
|
|
|
func (m *Message) Reset() { *m = Message{} }
|
|
func (m *Message) String() string { return proto.CompactTextString(m) }
|
|
func (*Message) ProtoMessage() {}
|
|
|
|
type Queues struct {
|
|
Input uint32 `protobuf:"varint,1,opt,name=input" json:"input,omitempty"`
|
|
Output uint32 `protobuf:"varint,2,opt,name=output" json:"output,omitempty"`
|
|
}
|
|
|
|
func (m *Queues) Reset() { *m = Queues{} }
|
|
func (m *Queues) String() string { return proto.CompactTextString(m) }
|
|
func (*Queues) ProtoMessage() {}
|
|
|
|
type Timers struct {
|
|
Config *TimersConfig `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`
|
|
State *TimersState `protobuf:"bytes,2,opt,name=state" json:"state,omitempty"`
|
|
}
|
|
|
|
func (m *Timers) Reset() { *m = Timers{} }
|
|
func (m *Timers) String() string { return proto.CompactTextString(m) }
|
|
func (*Timers) ProtoMessage() {}
|
|
|
|
func (m *Timers) GetConfig() *TimersConfig {
|
|
if m != nil {
|
|
return m.Config
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Timers) GetState() *TimersState {
|
|
if m != nil {
|
|
return m.State
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type TimersConfig struct {
|
|
ConnectRetry uint64 `protobuf:"varint,1,opt,name=connect_retry" json:"connect_retry,omitempty"`
|
|
HoldTime uint64 `protobuf:"varint,2,opt,name=hold_time" json:"hold_time,omitempty"`
|
|
KeepaliveInterval uint64 `protobuf:"varint,3,opt,name=keepalive_interval" json:"keepalive_interval,omitempty"`
|
|
MinimumAdvertisementInterval uint64 `protobuf:"varint,4,opt,name=minimum_advertisement_interval" json:"minimum_advertisement_interval,omitempty"`
|
|
}
|
|
|
|
func (m *TimersConfig) Reset() { *m = TimersConfig{} }
|
|
func (m *TimersConfig) String() string { return proto.CompactTextString(m) }
|
|
func (*TimersConfig) ProtoMessage() {}
|
|
|
|
type TimersState struct {
|
|
ConnectRetry uint64 `protobuf:"varint,1,opt,name=connect_retry" json:"connect_retry,omitempty"`
|
|
HoldTime uint64 `protobuf:"varint,2,opt,name=hold_time" json:"hold_time,omitempty"`
|
|
KeepaliveInterval uint64 `protobuf:"varint,3,opt,name=keepalive_interval" json:"keepalive_interval,omitempty"`
|
|
MinimumAdvertisementInterval uint64 `protobuf:"varint,4,opt,name=minimum_advertisement_interval" json:"minimum_advertisement_interval,omitempty"`
|
|
NegotiatedHoldTime uint64 `protobuf:"varint,5,opt,name=negotiated_hold_time" json:"negotiated_hold_time,omitempty"`
|
|
Uptime uint64 `protobuf:"varint,6,opt,name=uptime" json:"uptime,omitempty"`
|
|
Downtime uint64 `protobuf:"varint,7,opt,name=downtime" json:"downtime,omitempty"`
|
|
}
|
|
|
|
func (m *TimersState) Reset() { *m = TimersState{} }
|
|
func (m *TimersState) String() string { return proto.CompactTextString(m) }
|
|
func (*TimersState) ProtoMessage() {}
|
|
|
|
type Transport struct {
|
|
LocalAddress string `protobuf:"bytes,1,opt,name=local_address" json:"local_address,omitempty"`
|
|
LocalPort uint32 `protobuf:"varint,2,opt,name=local_port" json:"local_port,omitempty"`
|
|
MtuDiscovery bool `protobuf:"varint,3,opt,name=mtu_discovery" json:"mtu_discovery,omitempty"`
|
|
PassiveMode bool `protobuf:"varint,4,opt,name=passive_mode" json:"passive_mode,omitempty"`
|
|
RemoteAddress string `protobuf:"bytes,5,opt,name=remote_address" json:"remote_address,omitempty"`
|
|
RemotePort uint32 `protobuf:"varint,6,opt,name=remote_port" json:"remote_port,omitempty"`
|
|
TcpMss uint32 `protobuf:"varint,7,opt,name=tcp_mss" json:"tcp_mss,omitempty"`
|
|
}
|
|
|
|
func (m *Transport) Reset() { *m = Transport{} }
|
|
func (m *Transport) String() string { return proto.CompactTextString(m) }
|
|
func (*Transport) ProtoMessage() {}
|
|
|
|
type RouteServer struct {
|
|
RouteServerClient bool `protobuf:"varint,1,opt,name=route_server_client" json:"route_server_client,omitempty"`
|
|
}
|
|
|
|
func (m *RouteServer) Reset() { *m = RouteServer{} }
|
|
func (m *RouteServer) String() string { return proto.CompactTextString(m) }
|
|
func (*RouteServer) ProtoMessage() {}
|
|
|
|
type Prefix struct {
|
|
IpPrefix string `protobuf:"bytes,1,opt,name=ip_prefix" json:"ip_prefix,omitempty"`
|
|
MaskLengthMin uint32 `protobuf:"varint,2,opt,name=mask_length_min" json:"mask_length_min,omitempty"`
|
|
MaskLengthMax uint32 `protobuf:"varint,3,opt,name=mask_length_max" json:"mask_length_max,omitempty"`
|
|
}
|
|
|
|
func (m *Prefix) Reset() { *m = Prefix{} }
|
|
func (m *Prefix) String() string { return proto.CompactTextString(m) }
|
|
func (*Prefix) ProtoMessage() {}
|
|
|
|
type DefinedSet struct {
|
|
Type DefinedType `protobuf:"varint,1,opt,name=type,enum=gobgpapi.DefinedType" json:"type,omitempty"`
|
|
Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
|
|
List []string `protobuf:"bytes,3,rep,name=list" json:"list,omitempty"`
|
|
Prefixes []*Prefix `protobuf:"bytes,4,rep,name=prefixes" json:"prefixes,omitempty"`
|
|
}
|
|
|
|
func (m *DefinedSet) Reset() { *m = DefinedSet{} }
|
|
func (m *DefinedSet) String() string { return proto.CompactTextString(m) }
|
|
func (*DefinedSet) ProtoMessage() {}
|
|
|
|
func (m *DefinedSet) GetPrefixes() []*Prefix {
|
|
if m != nil {
|
|
return m.Prefixes
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type MatchSet struct {
|
|
Type MatchType `protobuf:"varint,1,opt,name=type,enum=gobgpapi.MatchType" json:"type,omitempty"`
|
|
Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
|
|
}
|
|
|
|
func (m *MatchSet) Reset() { *m = MatchSet{} }
|
|
func (m *MatchSet) String() string { return proto.CompactTextString(m) }
|
|
func (*MatchSet) ProtoMessage() {}
|
|
|
|
type AsPathLength struct {
|
|
Type AsPathLengthType `protobuf:"varint,1,opt,name=type,enum=gobgpapi.AsPathLengthType" json:"type,omitempty"`
|
|
Length uint32 `protobuf:"varint,2,opt,name=length" json:"length,omitempty"`
|
|
}
|
|
|
|
func (m *AsPathLength) Reset() { *m = AsPathLength{} }
|
|
func (m *AsPathLength) String() string { return proto.CompactTextString(m) }
|
|
func (*AsPathLength) ProtoMessage() {}
|
|
|
|
type Conditions struct {
|
|
PrefixSet *MatchSet `protobuf:"bytes,1,opt,name=prefix_set" json:"prefix_set,omitempty"`
|
|
NeighborSet *MatchSet `protobuf:"bytes,2,opt,name=neighbor_set" json:"neighbor_set,omitempty"`
|
|
AsPathLength *AsPathLength `protobuf:"bytes,3,opt,name=as_path_length" json:"as_path_length,omitempty"`
|
|
AsPathSet *MatchSet `protobuf:"bytes,4,opt,name=as_path_set" json:"as_path_set,omitempty"`
|
|
CommunitySet *MatchSet `protobuf:"bytes,5,opt,name=community_set" json:"community_set,omitempty"`
|
|
ExtCommunitySet *MatchSet `protobuf:"bytes,6,opt,name=ext_community_set" json:"ext_community_set,omitempty"`
|
|
RpkiResult int32 `protobuf:"varint,7,opt,name=rpki_result" json:"rpki_result,omitempty"`
|
|
}
|
|
|
|
func (m *Conditions) Reset() { *m = Conditions{} }
|
|
func (m *Conditions) String() string { return proto.CompactTextString(m) }
|
|
func (*Conditions) ProtoMessage() {}
|
|
|
|
func (m *Conditions) GetPrefixSet() *MatchSet {
|
|
if m != nil {
|
|
return m.PrefixSet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetNeighborSet() *MatchSet {
|
|
if m != nil {
|
|
return m.NeighborSet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetAsPathLength() *AsPathLength {
|
|
if m != nil {
|
|
return m.AsPathLength
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetAsPathSet() *MatchSet {
|
|
if m != nil {
|
|
return m.AsPathSet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetCommunitySet() *MatchSet {
|
|
if m != nil {
|
|
return m.CommunitySet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetExtCommunitySet() *MatchSet {
|
|
if m != nil {
|
|
return m.ExtCommunitySet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type CommunityAction struct {
|
|
Type CommunityActionType `protobuf:"varint,1,opt,name=type,enum=gobgpapi.CommunityActionType" json:"type,omitempty"`
|
|
Communities []string `protobuf:"bytes,2,rep,name=communities" json:"communities,omitempty"`
|
|
}
|
|
|
|
func (m *CommunityAction) Reset() { *m = CommunityAction{} }
|
|
func (m *CommunityAction) String() string { return proto.CompactTextString(m) }
|
|
func (*CommunityAction) ProtoMessage() {}
|
|
|
|
type MedAction struct {
|
|
Type MedActionType `protobuf:"varint,1,opt,name=type,enum=gobgpapi.MedActionType" json:"type,omitempty"`
|
|
Value int64 `protobuf:"varint,2,opt,name=value" json:"value,omitempty"`
|
|
}
|
|
|
|
func (m *MedAction) Reset() { *m = MedAction{} }
|
|
func (m *MedAction) String() string { return proto.CompactTextString(m) }
|
|
func (*MedAction) ProtoMessage() {}
|
|
|
|
type AsPrependAction struct {
|
|
Asn uint32 `protobuf:"varint,1,opt,name=asn" json:"asn,omitempty"`
|
|
Repeat uint32 `protobuf:"varint,2,opt,name=repeat" json:"repeat,omitempty"`
|
|
UseLeftMost bool `protobuf:"varint,3,opt,name=use_left_most" json:"use_left_most,omitempty"`
|
|
}
|
|
|
|
func (m *AsPrependAction) Reset() { *m = AsPrependAction{} }
|
|
func (m *AsPrependAction) String() string { return proto.CompactTextString(m) }
|
|
func (*AsPrependAction) ProtoMessage() {}
|
|
|
|
type Actions struct {
|
|
RouteAction RouteAction `protobuf:"varint,1,opt,name=route_action,enum=gobgpapi.RouteAction" json:"route_action,omitempty"`
|
|
Community *CommunityAction `protobuf:"bytes,2,opt,name=community" json:"community,omitempty"`
|
|
Med *MedAction `protobuf:"bytes,3,opt,name=med" json:"med,omitempty"`
|
|
AsPrepend *AsPrependAction `protobuf:"bytes,4,opt,name=as_prepend" json:"as_prepend,omitempty"`
|
|
ExtCommunity *CommunityAction `protobuf:"bytes,5,opt,name=ext_community" json:"ext_community,omitempty"`
|
|
}
|
|
|
|
func (m *Actions) Reset() { *m = Actions{} }
|
|
func (m *Actions) String() string { return proto.CompactTextString(m) }
|
|
func (*Actions) ProtoMessage() {}
|
|
|
|
func (m *Actions) GetCommunity() *CommunityAction {
|
|
if m != nil {
|
|
return m.Community
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Actions) GetMed() *MedAction {
|
|
if m != nil {
|
|
return m.Med
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Actions) GetAsPrepend() *AsPrependAction {
|
|
if m != nil {
|
|
return m.AsPrepend
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Actions) GetExtCommunity() *CommunityAction {
|
|
if m != nil {
|
|
return m.ExtCommunity
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Statement struct {
|
|
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
|
|
Conditions *Conditions `protobuf:"bytes,2,opt,name=conditions" json:"conditions,omitempty"`
|
|
Actions *Actions `protobuf:"bytes,3,opt,name=actions" json:"actions,omitempty"`
|
|
}
|
|
|
|
func (m *Statement) Reset() { *m = Statement{} }
|
|
func (m *Statement) String() string { return proto.CompactTextString(m) }
|
|
func (*Statement) ProtoMessage() {}
|
|
|
|
func (m *Statement) GetConditions() *Conditions {
|
|
if m != nil {
|
|
return m.Conditions
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Statement) GetActions() *Actions {
|
|
if m != nil {
|
|
return m.Actions
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Policy struct {
|
|
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
|
|
Statements []*Statement `protobuf:"bytes,2,rep,name=statements" json:"statements,omitempty"`
|
|
}
|
|
|
|
func (m *Policy) Reset() { *m = Policy{} }
|
|
func (m *Policy) String() string { return proto.CompactTextString(m) }
|
|
func (*Policy) ProtoMessage() {}
|
|
|
|
func (m *Policy) GetStatements() []*Statement {
|
|
if m != nil {
|
|
return m.Statements
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type PolicyAssignment struct {
|
|
Type PolicyType `protobuf:"varint,1,opt,name=type,enum=gobgpapi.PolicyType" json:"type,omitempty"`
|
|
Resource Resource `protobuf:"varint,2,opt,name=resource,enum=gobgpapi.Resource" json:"resource,omitempty"`
|
|
Name string `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
|
|
Policies []*Policy `protobuf:"bytes,4,rep,name=policies" json:"policies,omitempty"`
|
|
Default RouteAction `protobuf:"varint,5,opt,name=default,enum=gobgpapi.RouteAction" json:"default,omitempty"`
|
|
}
|
|
|
|
func (m *PolicyAssignment) Reset() { *m = PolicyAssignment{} }
|
|
func (m *PolicyAssignment) String() string { return proto.CompactTextString(m) }
|
|
func (*PolicyAssignment) ProtoMessage() {}
|
|
|
|
func (m *PolicyAssignment) GetPolicies() []*Policy {
|
|
if m != nil {
|
|
return m.Policies
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type MrtMessage struct {
|
|
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
|
|
}
|
|
|
|
func (m *MrtMessage) Reset() { *m = MrtMessage{} }
|
|
func (m *MrtMessage) String() string { return proto.CompactTextString(m) }
|
|
func (*MrtMessage) ProtoMessage() {}
|
|
|
|
type RPKIConf struct {
|
|
Address string `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"`
|
|
}
|
|
|
|
func (m *RPKIConf) Reset() { *m = RPKIConf{} }
|
|
func (m *RPKIConf) String() string { return proto.CompactTextString(m) }
|
|
func (*RPKIConf) ProtoMessage() {}
|
|
|
|
type RPKIState struct {
|
|
Uptime int64 `protobuf:"varint,1,opt,name=uptime" json:"uptime,omitempty"`
|
|
Downtime int64 `protobuf:"varint,2,opt,name=downtime" json:"downtime,omitempty"`
|
|
ReceivedIpv4 int32 `protobuf:"varint,3,opt,name=received_ipv4" json:"received_ipv4,omitempty"`
|
|
ReceivedIpv6 int32 `protobuf:"varint,4,opt,name=received_ipv6" json:"received_ipv6,omitempty"`
|
|
}
|
|
|
|
func (m *RPKIState) Reset() { *m = RPKIState{} }
|
|
func (m *RPKIState) String() string { return proto.CompactTextString(m) }
|
|
func (*RPKIState) ProtoMessage() {}
|
|
|
|
type RPKI struct {
|
|
Conf *RPKIConf `protobuf:"bytes,1,opt,name=conf" json:"conf,omitempty"`
|
|
State *RPKIState `protobuf:"bytes,2,opt,name=state" json:"state,omitempty"`
|
|
}
|
|
|
|
func (m *RPKI) Reset() { *m = RPKI{} }
|
|
func (m *RPKI) String() string { return proto.CompactTextString(m) }
|
|
func (*RPKI) ProtoMessage() {}
|
|
|
|
func (m *RPKI) GetConf() *RPKIConf {
|
|
if m != nil {
|
|
return m.Conf
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *RPKI) GetState() *RPKIState {
|
|
if m != nil {
|
|
return m.State
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ROA struct {
|
|
As uint32 `protobuf:"varint,1,opt,name=as" json:"as,omitempty"`
|
|
Prefixlen uint32 `protobuf:"varint,2,opt,name=prefixlen" json:"prefixlen,omitempty"`
|
|
Maxlen uint32 `protobuf:"varint,3,opt,name=maxlen" json:"maxlen,omitempty"`
|
|
Prefix string `protobuf:"bytes,4,opt,name=prefix" json:"prefix,omitempty"`
|
|
}
|
|
|
|
func (m *ROA) Reset() { *m = ROA{} }
|
|
func (m *ROA) String() string { return proto.CompactTextString(m) }
|
|
func (*ROA) ProtoMessage() {}
|
|
|
|
type Vrf struct {
|
|
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
|
|
Rd []byte `protobuf:"bytes,2,opt,name=rd,proto3" json:"rd,omitempty"`
|
|
ImportRt [][]byte `protobuf:"bytes,3,rep,name=import_rt,proto3" json:"import_rt,omitempty"`
|
|
ExportRt [][]byte `protobuf:"bytes,4,rep,name=export_rt,proto3" json:"export_rt,omitempty"`
|
|
}
|
|
|
|
func (m *Vrf) Reset() { *m = Vrf{} }
|
|
func (m *Vrf) String() string { return proto.CompactTextString(m) }
|
|
func (*Vrf) ProtoMessage() {}
|
|
|
|
type Global struct {
|
|
As uint32 `protobuf:"varint,1,opt,name=as" json:"as,omitempty"`
|
|
RouterId string `protobuf:"bytes,2,opt,name=router_id" json:"router_id,omitempty"`
|
|
}
|
|
|
|
func (m *Global) Reset() { *m = Global{} }
|
|
func (m *Global) String() string { return proto.CompactTextString(m) }
|
|
func (*Global) ProtoMessage() {}
|
|
|
|
func init() {
|
|
proto.RegisterEnum("gobgpapi.Resource", Resource_name, Resource_value)
|
|
proto.RegisterEnum("gobgpapi.Operation", Operation_name, Operation_value)
|
|
proto.RegisterEnum("gobgpapi.DefinedType", DefinedType_name, DefinedType_value)
|
|
proto.RegisterEnum("gobgpapi.MatchType", MatchType_name, MatchType_value)
|
|
proto.RegisterEnum("gobgpapi.AsPathLengthType", AsPathLengthType_name, AsPathLengthType_value)
|
|
proto.RegisterEnum("gobgpapi.RouteAction", RouteAction_name, RouteAction_value)
|
|
proto.RegisterEnum("gobgpapi.CommunityActionType", CommunityActionType_name, CommunityActionType_value)
|
|
proto.RegisterEnum("gobgpapi.MedActionType", MedActionType_name, MedActionType_value)
|
|
proto.RegisterEnum("gobgpapi.PolicyType", PolicyType_name, PolicyType_value)
|
|
proto.RegisterEnum("gobgpapi.Error_ErrorCode", Error_ErrorCode_name, Error_ErrorCode_value)
|
|
}
|
|
|
|
// Reference imports to suppress errors if they are not otherwise used.
|
|
var _ context.Context
|
|
var _ grpc.ClientConn
|
|
|
|
// Client API for GobgpApi service
|
|
|
|
type GobgpApiClient interface {
|
|
GetGlobalConfig(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Global, error)
|
|
ModGlobalConfig(ctx context.Context, in *ModGlobalConfigArguments, opts ...grpc.CallOption) (*Error, error)
|
|
GetNeighbors(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetNeighborsClient, error)
|
|
GetNeighbor(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Peer, error)
|
|
ModNeighbor(ctx context.Context, in *ModNeighborArguments, opts ...grpc.CallOption) (*Error, error)
|
|
GetRib(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRibClient, error)
|
|
Reset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
SoftReset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
SoftResetIn(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
SoftResetOut(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
Shutdown(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
Enable(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
Disable(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
ModPath(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModPathClient, error)
|
|
MonitorBestChanged(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_MonitorBestChangedClient, error)
|
|
MonitorPeerState(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_MonitorPeerStateClient, error)
|
|
GetMrt(ctx context.Context, in *MrtArguments, opts ...grpc.CallOption) (GobgpApi_GetMrtClient, error)
|
|
GetRPKI(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRPKIClient, error)
|
|
GetROA(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetROAClient, error)
|
|
GetVrfs(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetVrfsClient, error)
|
|
ModVrf(ctx context.Context, in *ModVrfArguments, opts ...grpc.CallOption) (*Error, error)
|
|
GetDefinedSet(ctx context.Context, in *DefinedSet, opts ...grpc.CallOption) (*DefinedSet, error)
|
|
GetDefinedSets(ctx context.Context, in *DefinedSet, opts ...grpc.CallOption) (GobgpApi_GetDefinedSetsClient, error)
|
|
ModDefinedSet(ctx context.Context, in *ModDefinedSetArguments, opts ...grpc.CallOption) (*Error, error)
|
|
GetStatement(ctx context.Context, in *Statement, opts ...grpc.CallOption) (*Statement, error)
|
|
GetStatements(ctx context.Context, in *Statement, opts ...grpc.CallOption) (GobgpApi_GetStatementsClient, error)
|
|
ModStatement(ctx context.Context, in *ModStatementArguments, opts ...grpc.CallOption) (*Error, error)
|
|
GetPolicy(ctx context.Context, in *Policy, opts ...grpc.CallOption) (*Policy, error)
|
|
GetPolicies(ctx context.Context, in *Policy, opts ...grpc.CallOption) (GobgpApi_GetPoliciesClient, error)
|
|
ModPolicy(ctx context.Context, in *ModPolicyArguments, opts ...grpc.CallOption) (*Error, error)
|
|
GetPolicyAssignment(ctx context.Context, in *PolicyAssignment, opts ...grpc.CallOption) (*PolicyAssignment, error)
|
|
ModPolicyAssignment(ctx context.Context, in *ModPolicyAssignmentArguments, opts ...grpc.CallOption) (*Error, error)
|
|
}
|
|
|
|
type gobgpApiClient struct {
|
|
cc *grpc.ClientConn
|
|
}
|
|
|
|
func NewGobgpApiClient(cc *grpc.ClientConn) GobgpApiClient {
|
|
return &gobgpApiClient{cc}
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetGlobalConfig(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Global, error) {
|
|
out := new(Global)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/GetGlobalConfig", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModGlobalConfig(ctx context.Context, in *ModGlobalConfigArguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModGlobalConfig", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetNeighbors(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetNeighborsClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[0], c.cc, "/gobgpapi.GobgpApi/GetNeighbors", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetNeighborsClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetNeighborsClient interface {
|
|
Recv() (*Peer, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetNeighborsClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetNeighborsClient) Recv() (*Peer, error) {
|
|
m := new(Peer)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetNeighbor(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Peer, error) {
|
|
out := new(Peer)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/GetNeighbor", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModNeighbor(ctx context.Context, in *ModNeighborArguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModNeighbor", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetRib(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRibClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[1], c.cc, "/gobgpapi.GobgpApi/GetRib", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetRibClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetRibClient interface {
|
|
Recv() (*Destination, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetRibClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetRibClient) Recv() (*Destination, error) {
|
|
m := new(Destination)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) Reset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/Reset", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) SoftReset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/SoftReset", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) SoftResetIn(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/SoftResetIn", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) SoftResetOut(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/SoftResetOut", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) Shutdown(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/Shutdown", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) Enable(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/Enable", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) Disable(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/Disable", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModPath(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModPathClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[2], c.cc, "/gobgpapi.GobgpApi/ModPath", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiModPathClient{stream}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_ModPathClient interface {
|
|
Send(*ModPathArguments) error
|
|
CloseAndRecv() (*Error, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiModPathClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiModPathClient) Send(m *ModPathArguments) error {
|
|
return x.ClientStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModPathClient) CloseAndRecv() (*Error, error) {
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
m := new(Error)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) MonitorBestChanged(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_MonitorBestChangedClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[3], c.cc, "/gobgpapi.GobgpApi/MonitorBestChanged", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiMonitorBestChangedClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_MonitorBestChangedClient interface {
|
|
Recv() (*Destination, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiMonitorBestChangedClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiMonitorBestChangedClient) Recv() (*Destination, error) {
|
|
m := new(Destination)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) MonitorPeerState(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_MonitorPeerStateClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[4], c.cc, "/gobgpapi.GobgpApi/MonitorPeerState", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiMonitorPeerStateClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_MonitorPeerStateClient interface {
|
|
Recv() (*Peer, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiMonitorPeerStateClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiMonitorPeerStateClient) Recv() (*Peer, error) {
|
|
m := new(Peer)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetMrt(ctx context.Context, in *MrtArguments, opts ...grpc.CallOption) (GobgpApi_GetMrtClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[5], c.cc, "/gobgpapi.GobgpApi/GetMrt", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetMrtClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetMrtClient interface {
|
|
Recv() (*MrtMessage, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetMrtClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetMrtClient) Recv() (*MrtMessage, error) {
|
|
m := new(MrtMessage)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetRPKI(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRPKIClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[6], c.cc, "/gobgpapi.GobgpApi/GetRPKI", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetRPKIClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetRPKIClient interface {
|
|
Recv() (*RPKI, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetRPKIClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetRPKIClient) Recv() (*RPKI, error) {
|
|
m := new(RPKI)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetROA(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetROAClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[7], c.cc, "/gobgpapi.GobgpApi/GetROA", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetROAClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetROAClient interface {
|
|
Recv() (*ROA, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetROAClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetROAClient) Recv() (*ROA, error) {
|
|
m := new(ROA)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetVrfs(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetVrfsClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[8], c.cc, "/gobgpapi.GobgpApi/GetVrfs", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetVrfsClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetVrfsClient interface {
|
|
Recv() (*Vrf, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetVrfsClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetVrfsClient) Recv() (*Vrf, error) {
|
|
m := new(Vrf)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModVrf(ctx context.Context, in *ModVrfArguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModVrf", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetDefinedSet(ctx context.Context, in *DefinedSet, opts ...grpc.CallOption) (*DefinedSet, error) {
|
|
out := new(DefinedSet)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/GetDefinedSet", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetDefinedSets(ctx context.Context, in *DefinedSet, opts ...grpc.CallOption) (GobgpApi_GetDefinedSetsClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[9], c.cc, "/gobgpapi.GobgpApi/GetDefinedSets", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetDefinedSetsClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetDefinedSetsClient interface {
|
|
Recv() (*DefinedSet, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetDefinedSetsClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetDefinedSetsClient) Recv() (*DefinedSet, error) {
|
|
m := new(DefinedSet)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModDefinedSet(ctx context.Context, in *ModDefinedSetArguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModDefinedSet", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetStatement(ctx context.Context, in *Statement, opts ...grpc.CallOption) (*Statement, error) {
|
|
out := new(Statement)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/GetStatement", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetStatements(ctx context.Context, in *Statement, opts ...grpc.CallOption) (GobgpApi_GetStatementsClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[10], c.cc, "/gobgpapi.GobgpApi/GetStatements", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetStatementsClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetStatementsClient interface {
|
|
Recv() (*Statement, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetStatementsClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetStatementsClient) Recv() (*Statement, error) {
|
|
m := new(Statement)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModStatement(ctx context.Context, in *ModStatementArguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModStatement", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetPolicy(ctx context.Context, in *Policy, opts ...grpc.CallOption) (*Policy, error) {
|
|
out := new(Policy)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/GetPolicy", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetPolicies(ctx context.Context, in *Policy, opts ...grpc.CallOption) (GobgpApi_GetPoliciesClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[11], c.cc, "/gobgpapi.GobgpApi/GetPolicies", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetPoliciesClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetPoliciesClient interface {
|
|
Recv() (*Policy, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetPoliciesClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetPoliciesClient) Recv() (*Policy, error) {
|
|
m := new(Policy)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModPolicy(ctx context.Context, in *ModPolicyArguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModPolicy", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetPolicyAssignment(ctx context.Context, in *PolicyAssignment, opts ...grpc.CallOption) (*PolicyAssignment, error) {
|
|
out := new(PolicyAssignment)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/GetPolicyAssignment", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModPolicyAssignment(ctx context.Context, in *ModPolicyAssignmentArguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModPolicyAssignment", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// Server API for GobgpApi service
|
|
|
|
type GobgpApiServer interface {
|
|
GetGlobalConfig(context.Context, *Arguments) (*Global, error)
|
|
ModGlobalConfig(context.Context, *ModGlobalConfigArguments) (*Error, error)
|
|
GetNeighbors(*Arguments, GobgpApi_GetNeighborsServer) error
|
|
GetNeighbor(context.Context, *Arguments) (*Peer, error)
|
|
ModNeighbor(context.Context, *ModNeighborArguments) (*Error, error)
|
|
GetRib(*Arguments, GobgpApi_GetRibServer) error
|
|
Reset(context.Context, *Arguments) (*Error, error)
|
|
SoftReset(context.Context, *Arguments) (*Error, error)
|
|
SoftResetIn(context.Context, *Arguments) (*Error, error)
|
|
SoftResetOut(context.Context, *Arguments) (*Error, error)
|
|
Shutdown(context.Context, *Arguments) (*Error, error)
|
|
Enable(context.Context, *Arguments) (*Error, error)
|
|
Disable(context.Context, *Arguments) (*Error, error)
|
|
ModPath(GobgpApi_ModPathServer) error
|
|
MonitorBestChanged(*Arguments, GobgpApi_MonitorBestChangedServer) error
|
|
MonitorPeerState(*Arguments, GobgpApi_MonitorPeerStateServer) error
|
|
GetMrt(*MrtArguments, GobgpApi_GetMrtServer) error
|
|
GetRPKI(*Arguments, GobgpApi_GetRPKIServer) error
|
|
GetROA(*Arguments, GobgpApi_GetROAServer) error
|
|
GetVrfs(*Arguments, GobgpApi_GetVrfsServer) error
|
|
ModVrf(context.Context, *ModVrfArguments) (*Error, error)
|
|
GetDefinedSet(context.Context, *DefinedSet) (*DefinedSet, error)
|
|
GetDefinedSets(*DefinedSet, GobgpApi_GetDefinedSetsServer) error
|
|
ModDefinedSet(context.Context, *ModDefinedSetArguments) (*Error, error)
|
|
GetStatement(context.Context, *Statement) (*Statement, error)
|
|
GetStatements(*Statement, GobgpApi_GetStatementsServer) error
|
|
ModStatement(context.Context, *ModStatementArguments) (*Error, error)
|
|
GetPolicy(context.Context, *Policy) (*Policy, error)
|
|
GetPolicies(*Policy, GobgpApi_GetPoliciesServer) error
|
|
ModPolicy(context.Context, *ModPolicyArguments) (*Error, error)
|
|
GetPolicyAssignment(context.Context, *PolicyAssignment) (*PolicyAssignment, error)
|
|
ModPolicyAssignment(context.Context, *ModPolicyAssignmentArguments) (*Error, error)
|
|
}
|
|
|
|
func RegisterGobgpApiServer(s *grpc.Server, srv GobgpApiServer) {
|
|
s.RegisterService(&_GobgpApi_serviceDesc, srv)
|
|
}
|
|
|
|
func _GobgpApi_GetGlobalConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).GetGlobalConfig(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_ModGlobalConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(ModGlobalConfigArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).ModGlobalConfig(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_GetNeighbors_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetNeighbors(m, &gobgpApiGetNeighborsServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetNeighborsServer interface {
|
|
Send(*Peer) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetNeighborsServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetNeighborsServer) Send(m *Peer) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetNeighbor_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).GetNeighbor(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_ModNeighbor_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(ModNeighborArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).ModNeighbor(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_GetRib_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetRib(m, &gobgpApiGetRibServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetRibServer interface {
|
|
Send(*Destination) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetRibServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetRibServer) Send(m *Destination) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_Reset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).Reset(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_SoftReset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).SoftReset(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_SoftResetIn_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).SoftResetIn(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_SoftResetOut_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).SoftResetOut(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_Shutdown_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).Shutdown(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_Enable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).Enable(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_Disable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).Disable(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_ModPath_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
return srv.(GobgpApiServer).ModPath(&gobgpApiModPathServer{stream})
|
|
}
|
|
|
|
type GobgpApi_ModPathServer interface {
|
|
SendAndClose(*Error) error
|
|
Recv() (*ModPathArguments, error)
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiModPathServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiModPathServer) SendAndClose(m *Error) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModPathServer) Recv() (*ModPathArguments, error) {
|
|
m := new(ModPathArguments)
|
|
if err := x.ServerStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func _GobgpApi_MonitorBestChanged_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).MonitorBestChanged(m, &gobgpApiMonitorBestChangedServer{stream})
|
|
}
|
|
|
|
type GobgpApi_MonitorBestChangedServer interface {
|
|
Send(*Destination) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiMonitorBestChangedServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiMonitorBestChangedServer) Send(m *Destination) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_MonitorPeerState_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).MonitorPeerState(m, &gobgpApiMonitorPeerStateServer{stream})
|
|
}
|
|
|
|
type GobgpApi_MonitorPeerStateServer interface {
|
|
Send(*Peer) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiMonitorPeerStateServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiMonitorPeerStateServer) Send(m *Peer) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetMrt_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(MrtArguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetMrt(m, &gobgpApiGetMrtServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetMrtServer interface {
|
|
Send(*MrtMessage) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetMrtServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetMrtServer) Send(m *MrtMessage) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetRPKI_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetRPKI(m, &gobgpApiGetRPKIServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetRPKIServer interface {
|
|
Send(*RPKI) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetRPKIServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetRPKIServer) Send(m *RPKI) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetROA_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetROA(m, &gobgpApiGetROAServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetROAServer interface {
|
|
Send(*ROA) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetROAServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetROAServer) Send(m *ROA) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetVrfs_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetVrfs(m, &gobgpApiGetVrfsServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetVrfsServer interface {
|
|
Send(*Vrf) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetVrfsServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetVrfsServer) Send(m *Vrf) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_ModVrf_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(ModVrfArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).ModVrf(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_GetDefinedSet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(DefinedSet)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).GetDefinedSet(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_GetDefinedSets_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(DefinedSet)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetDefinedSets(m, &gobgpApiGetDefinedSetsServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetDefinedSetsServer interface {
|
|
Send(*DefinedSet) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetDefinedSetsServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetDefinedSetsServer) Send(m *DefinedSet) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_ModDefinedSet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(ModDefinedSetArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).ModDefinedSet(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_GetStatement_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Statement)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).GetStatement(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_GetStatements_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Statement)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetStatements(m, &gobgpApiGetStatementsServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetStatementsServer interface {
|
|
Send(*Statement) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetStatementsServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetStatementsServer) Send(m *Statement) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_ModStatement_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(ModStatementArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).ModStatement(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_GetPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Policy)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).GetPolicy(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_GetPolicies_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Policy)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetPolicies(m, &gobgpApiGetPoliciesServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetPoliciesServer interface {
|
|
Send(*Policy) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetPoliciesServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetPoliciesServer) Send(m *Policy) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_ModPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(ModPolicyArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).ModPolicy(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_GetPolicyAssignment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(PolicyAssignment)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).GetPolicyAssignment(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_ModPolicyAssignment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(ModPolicyAssignmentArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).ModPolicyAssignment(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
var _GobgpApi_serviceDesc = grpc.ServiceDesc{
|
|
ServiceName: "gobgpapi.GobgpApi",
|
|
HandlerType: (*GobgpApiServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "GetGlobalConfig",
|
|
Handler: _GobgpApi_GetGlobalConfig_Handler,
|
|
},
|
|
{
|
|
MethodName: "ModGlobalConfig",
|
|
Handler: _GobgpApi_ModGlobalConfig_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetNeighbor",
|
|
Handler: _GobgpApi_GetNeighbor_Handler,
|
|
},
|
|
{
|
|
MethodName: "ModNeighbor",
|
|
Handler: _GobgpApi_ModNeighbor_Handler,
|
|
},
|
|
{
|
|
MethodName: "Reset",
|
|
Handler: _GobgpApi_Reset_Handler,
|
|
},
|
|
{
|
|
MethodName: "SoftReset",
|
|
Handler: _GobgpApi_SoftReset_Handler,
|
|
},
|
|
{
|
|
MethodName: "SoftResetIn",
|
|
Handler: _GobgpApi_SoftResetIn_Handler,
|
|
},
|
|
{
|
|
MethodName: "SoftResetOut",
|
|
Handler: _GobgpApi_SoftResetOut_Handler,
|
|
},
|
|
{
|
|
MethodName: "Shutdown",
|
|
Handler: _GobgpApi_Shutdown_Handler,
|
|
},
|
|
{
|
|
MethodName: "Enable",
|
|
Handler: _GobgpApi_Enable_Handler,
|
|
},
|
|
{
|
|
MethodName: "Disable",
|
|
Handler: _GobgpApi_Disable_Handler,
|
|
},
|
|
{
|
|
MethodName: "ModVrf",
|
|
Handler: _GobgpApi_ModVrf_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetDefinedSet",
|
|
Handler: _GobgpApi_GetDefinedSet_Handler,
|
|
},
|
|
{
|
|
MethodName: "ModDefinedSet",
|
|
Handler: _GobgpApi_ModDefinedSet_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetStatement",
|
|
Handler: _GobgpApi_GetStatement_Handler,
|
|
},
|
|
{
|
|
MethodName: "ModStatement",
|
|
Handler: _GobgpApi_ModStatement_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetPolicy",
|
|
Handler: _GobgpApi_GetPolicy_Handler,
|
|
},
|
|
{
|
|
MethodName: "ModPolicy",
|
|
Handler: _GobgpApi_ModPolicy_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetPolicyAssignment",
|
|
Handler: _GobgpApi_GetPolicyAssignment_Handler,
|
|
},
|
|
{
|
|
MethodName: "ModPolicyAssignment",
|
|
Handler: _GobgpApi_ModPolicyAssignment_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{
|
|
{
|
|
StreamName: "GetNeighbors",
|
|
Handler: _GobgpApi_GetNeighbors_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetRib",
|
|
Handler: _GobgpApi_GetRib_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "ModPath",
|
|
Handler: _GobgpApi_ModPath_Handler,
|
|
ClientStreams: true,
|
|
},
|
|
{
|
|
StreamName: "MonitorBestChanged",
|
|
Handler: _GobgpApi_MonitorBestChanged_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "MonitorPeerState",
|
|
Handler: _GobgpApi_MonitorPeerState_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetMrt",
|
|
Handler: _GobgpApi_GetMrt_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetRPKI",
|
|
Handler: _GobgpApi_GetRPKI_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetROA",
|
|
Handler: _GobgpApi_GetROA_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetVrfs",
|
|
Handler: _GobgpApi_GetVrfs_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetDefinedSets",
|
|
Handler: _GobgpApi_GetDefinedSets_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetStatements",
|
|
Handler: _GobgpApi_GetStatements_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetPolicies",
|
|
Handler: _GobgpApi_GetPolicies_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
},
|
|
}
|