Files
osrg-gobgp/api/gobgp.pb.go
T
2015-12-02 08:53:04 +09:00

2859 lines
88 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
ModMrtArguments
ModRpkiArguments
ModVrfArguments
ModDefinedSetArguments
ModStatementArguments
ModPolicyArguments
ModPolicyAssignmentArguments
ModGlobalConfigArguments
Table
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 ModMrtArguments struct {
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
Filename string `protobuf:"bytes,2,opt,name=filename" json:"filename,omitempty"`
}
func (m *ModMrtArguments) Reset() { *m = ModMrtArguments{} }
func (m *ModMrtArguments) String() string { return proto.CompactTextString(m) }
func (*ModMrtArguments) ProtoMessage() {}
type ModRpkiArguments struct {
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address" json:"address,omitempty"`
Port uint32 `protobuf:"varint,3,opt,name=port" json:"port,omitempty"`
}
func (m *ModRpkiArguments) Reset() { *m = ModRpkiArguments{} }
func (m *ModRpkiArguments) String() string { return proto.CompactTextString(m) }
func (*ModRpkiArguments) 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 Table struct {
Type Resource `protobuf:"varint,1,opt,name=type,enum=gobgpapi.Resource" json:"type,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
Family uint32 `protobuf:"varint,3,opt,name=family" json:"family,omitempty"`
Destinations []*Destination `protobuf:"bytes,4,rep,name=destinations" json:"destinations,omitempty"`
}
func (m *Table) Reset() { *m = Table{} }
func (m *Table) String() string { return proto.CompactTextString(m) }
func (*Table) ProtoMessage() {}
func (m *Table) GetDestinations() []*Destination {
if m != nil {
return m.Destinations
}
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"`
RouteReflector *RouteReflector `protobuf:"bytes,10,opt,name=route_reflector" json:"route_reflector,omitempty"`
Info *PeerState `protobuf:"bytes,11,opt,name=info" json:"info,omitempty"`
Timers *Timers `protobuf:"bytes,12,opt,name=timers" json:"timers,omitempty"`
Transport *Transport `protobuf:"bytes,13,opt,name=transport" json:"transport,omitempty"`
UseMultiplePaths *UseMultiplePaths `protobuf:"bytes,14,opt,name=use_multiple_paths" json:"use_multiple_paths,omitempty"`
RouteServer *RouteServer `protobuf:"bytes,15,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"`
Id string `protobuf:"bytes,13,opt,name=id" json:"id,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 *Table, opts ...grpc.CallOption) (*Table, 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)
ModMrt(ctx context.Context, in *ModMrtArguments, opts ...grpc.CallOption) (*Error, error)
GetRPKI(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRPKIClient, error)
ModRPKI(ctx context.Context, in *ModRpkiArguments, opts ...grpc.CallOption) (*Error, 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 *Table, opts ...grpc.CallOption) (*Table, error) {
out := new(Table)
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/GetRib", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, 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[1], 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[2], 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[3], 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[4], 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) ModMrt(ctx context.Context, in *ModMrtArguments, opts ...grpc.CallOption) (*Error, error) {
out := new(Error)
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModMrt", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *gobgpApiClient) GetRPKI(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRPKIClient, error) {
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[5], 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) ModRPKI(ctx context.Context, in *ModRpkiArguments, opts ...grpc.CallOption) (*Error, error) {
out := new(Error)
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModRPKI", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *gobgpApiClient) GetROA(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetROAClient, error) {
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[6], 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[7], 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[8], 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[9], 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[10], 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(context.Context, *Table) (*Table, 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
ModMrt(context.Context, *ModMrtArguments) (*Error, error)
GetRPKI(*Arguments, GobgpApi_GetRPKIServer) error
ModRPKI(context.Context, *ModRpkiArguments) (*Error, 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{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
in := new(Table)
if err := dec(in); err != nil {
return nil, err
}
out, err := srv.(GobgpApiServer).GetRib(ctx, in)
if err != nil {
return nil, err
}
return out, nil
}
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_ModMrt_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
in := new(ModMrtArguments)
if err := dec(in); err != nil {
return nil, err
}
out, err := srv.(GobgpApiServer).ModMrt(ctx, in)
if err != nil {
return nil, err
}
return out, nil
}
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_ModRPKI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
in := new(ModRpkiArguments)
if err := dec(in); err != nil {
return nil, err
}
out, err := srv.(GobgpApiServer).ModRPKI(ctx, in)
if err != nil {
return nil, err
}
return out, nil
}
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: "GetRib",
Handler: _GobgpApi_GetRib_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: "ModMrt",
Handler: _GobgpApi_ModMrt_Handler,
},
{
MethodName: "ModRPKI",
Handler: _GobgpApi_ModRPKI_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: "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,
},
},
}