mirror of
https://github.com/osrg/gobgp.git
synced 2024-05-11 05:55:10 +00:00
Handle only one route unlike MOD_PATHS API. When the API returns an uuid when a route is created. The uuid can be used to remove the route later. Signed-off-by: FUJITA Tomonori <[email protected]>
2632 lines
82 KiB
Go
2632 lines
82 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
|
|
ModPathResponse
|
|
ModPathsArguments
|
|
ModNeighborArguments
|
|
MrtArguments
|
|
ModMrtArguments
|
|
ModRpkiArguments
|
|
ModVrfArguments
|
|
ModDefinedSetArguments
|
|
ModStatementArguments
|
|
ModPolicyArguments
|
|
ModPolicyAssignmentArguments
|
|
ModGlobalConfigArguments
|
|
Path
|
|
Destination
|
|
Table
|
|
Peer
|
|
ApplyPolicy
|
|
PeerConf
|
|
EbgpMultihop
|
|
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
|
|
Operation_ENABLE Operation = 4
|
|
Operation_DISABLE Operation = 5
|
|
Operation_RESET Operation = 6
|
|
Operation_SOFTRESET Operation = 7
|
|
)
|
|
|
|
var Operation_name = map[int32]string{
|
|
0: "ADD",
|
|
1: "DEL",
|
|
2: "DEL_ALL",
|
|
3: "REPLACE",
|
|
4: "ENABLE",
|
|
5: "DISABLE",
|
|
6: "RESET",
|
|
7: "SOFTRESET",
|
|
}
|
|
var Operation_value = map[string]int32{
|
|
"ADD": 0,
|
|
"DEL": 1,
|
|
"DEL_ALL": 2,
|
|
"REPLACE": 3,
|
|
"ENABLE": 4,
|
|
"DISABLE": 5,
|
|
"RESET": 6,
|
|
"SOFTRESET": 7,
|
|
}
|
|
|
|
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"`
|
|
Family uint32 `protobuf:"varint,2,opt,name=family" json:"family,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 {
|
|
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,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"`
|
|
Path *Path `protobuf:"bytes,4,opt,name=path" json:"path,omitempty"`
|
|
Uuid []byte `protobuf:"bytes,5,opt,name=uuid,proto3" json:"uuid,omitempty"`
|
|
}
|
|
|
|
func (m *ModPathArguments) Reset() { *m = ModPathArguments{} }
|
|
func (m *ModPathArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModPathArguments) ProtoMessage() {}
|
|
|
|
func (m *ModPathArguments) GetPath() *Path {
|
|
if m != nil {
|
|
return m.Path
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ModPathResponse struct {
|
|
Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
|
|
}
|
|
|
|
func (m *ModPathResponse) Reset() { *m = ModPathResponse{} }
|
|
func (m *ModPathResponse) String() string { return proto.CompactTextString(m) }
|
|
func (*ModPathResponse) ProtoMessage() {}
|
|
|
|
type ModPathsArguments 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 *ModPathsArguments) Reset() { *m = ModPathsArguments{} }
|
|
func (m *ModPathsArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModPathsArguments) ProtoMessage() {}
|
|
|
|
func (m *ModPathsArguments) 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"`
|
|
Family uint32 `protobuf:"varint,2,opt,name=family" json:"family,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 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"`
|
|
Family uint32 `protobuf:"varint,8,opt,name=family" json:"family,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"`
|
|
LongerPrefixes bool `protobuf:"varint,3,opt,name=longer_prefixes" json:"longer_prefixes,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 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 Peer struct {
|
|
Families []uint32 `protobuf:"varint,2,rep,name=families" json:"families,omitempty"`
|
|
ApplyPolicy *ApplyPolicy `protobuf:"bytes,3,opt,name=apply_policy" json:"apply_policy,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"`
|
|
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"`
|
|
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) GetApplyPolicy() *ApplyPolicy {
|
|
if m != nil {
|
|
return m.ApplyPolicy
|
|
}
|
|
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) 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) GetRouteServer() *RouteServer {
|
|
if m != nil {
|
|
return m.RouteServer
|
|
}
|
|
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 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 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"`
|
|
RemotePort uint32 `protobuf:"varint,2,opt,name=remote_port" json:"remote_port,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 int64 `protobuf:"varint,3,opt,name=received_ipv4" json:"received_ipv4,omitempty"`
|
|
ReceivedIpv6 int64 `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"`
|
|
Conf *RPKIConf `protobuf:"bytes,5,opt,name=conf" json:"conf,omitempty"`
|
|
}
|
|
|
|
func (m *ROA) Reset() { *m = ROA{} }
|
|
func (m *ROA) String() string { return proto.CompactTextString(m) }
|
|
func (*ROA) ProtoMessage() {}
|
|
|
|
func (m *ROA) GetConf() *RPKIConf {
|
|
if m != nil {
|
|
return m.Conf
|
|
}
|
|
return nil
|
|
}
|
|
|
|
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"`
|
|
ListenPort int32 `protobuf:"varint,3,opt,name=listen_port" json:"listen_port,omitempty"`
|
|
}
|
|
|
|
func (m *Global) Reset() { *m = Global{} }
|
|
func (m *Global) String() string { return proto.CompactTextString(m) }
|
|
func (*Global) ProtoMessage() {}
|
|
|
|
func init() {
|
|
proto.RegisterType((*Error)(nil), "gobgpapi.Error")
|
|
proto.RegisterType((*Arguments)(nil), "gobgpapi.Arguments")
|
|
proto.RegisterType((*ModPathArguments)(nil), "gobgpapi.ModPathArguments")
|
|
proto.RegisterType((*ModPathResponse)(nil), "gobgpapi.ModPathResponse")
|
|
proto.RegisterType((*ModPathsArguments)(nil), "gobgpapi.ModPathsArguments")
|
|
proto.RegisterType((*ModNeighborArguments)(nil), "gobgpapi.ModNeighborArguments")
|
|
proto.RegisterType((*MrtArguments)(nil), "gobgpapi.MrtArguments")
|
|
proto.RegisterType((*ModMrtArguments)(nil), "gobgpapi.ModMrtArguments")
|
|
proto.RegisterType((*ModRpkiArguments)(nil), "gobgpapi.ModRpkiArguments")
|
|
proto.RegisterType((*ModVrfArguments)(nil), "gobgpapi.ModVrfArguments")
|
|
proto.RegisterType((*ModDefinedSetArguments)(nil), "gobgpapi.ModDefinedSetArguments")
|
|
proto.RegisterType((*ModStatementArguments)(nil), "gobgpapi.ModStatementArguments")
|
|
proto.RegisterType((*ModPolicyArguments)(nil), "gobgpapi.ModPolicyArguments")
|
|
proto.RegisterType((*ModPolicyAssignmentArguments)(nil), "gobgpapi.ModPolicyAssignmentArguments")
|
|
proto.RegisterType((*ModGlobalConfigArguments)(nil), "gobgpapi.ModGlobalConfigArguments")
|
|
proto.RegisterType((*Path)(nil), "gobgpapi.Path")
|
|
proto.RegisterType((*Destination)(nil), "gobgpapi.Destination")
|
|
proto.RegisterType((*Table)(nil), "gobgpapi.Table")
|
|
proto.RegisterType((*Peer)(nil), "gobgpapi.Peer")
|
|
proto.RegisterType((*ApplyPolicy)(nil), "gobgpapi.ApplyPolicy")
|
|
proto.RegisterType((*PeerConf)(nil), "gobgpapi.PeerConf")
|
|
proto.RegisterType((*EbgpMultihop)(nil), "gobgpapi.EbgpMultihop")
|
|
proto.RegisterType((*RouteReflector)(nil), "gobgpapi.RouteReflector")
|
|
proto.RegisterType((*PeerState)(nil), "gobgpapi.PeerState")
|
|
proto.RegisterType((*Messages)(nil), "gobgpapi.Messages")
|
|
proto.RegisterType((*Message)(nil), "gobgpapi.Message")
|
|
proto.RegisterType((*Queues)(nil), "gobgpapi.Queues")
|
|
proto.RegisterType((*Timers)(nil), "gobgpapi.Timers")
|
|
proto.RegisterType((*TimersConfig)(nil), "gobgpapi.TimersConfig")
|
|
proto.RegisterType((*TimersState)(nil), "gobgpapi.TimersState")
|
|
proto.RegisterType((*Transport)(nil), "gobgpapi.Transport")
|
|
proto.RegisterType((*RouteServer)(nil), "gobgpapi.RouteServer")
|
|
proto.RegisterType((*Prefix)(nil), "gobgpapi.Prefix")
|
|
proto.RegisterType((*DefinedSet)(nil), "gobgpapi.DefinedSet")
|
|
proto.RegisterType((*MatchSet)(nil), "gobgpapi.MatchSet")
|
|
proto.RegisterType((*AsPathLength)(nil), "gobgpapi.AsPathLength")
|
|
proto.RegisterType((*Conditions)(nil), "gobgpapi.Conditions")
|
|
proto.RegisterType((*CommunityAction)(nil), "gobgpapi.CommunityAction")
|
|
proto.RegisterType((*MedAction)(nil), "gobgpapi.MedAction")
|
|
proto.RegisterType((*AsPrependAction)(nil), "gobgpapi.AsPrependAction")
|
|
proto.RegisterType((*Actions)(nil), "gobgpapi.Actions")
|
|
proto.RegisterType((*Statement)(nil), "gobgpapi.Statement")
|
|
proto.RegisterType((*Policy)(nil), "gobgpapi.Policy")
|
|
proto.RegisterType((*PolicyAssignment)(nil), "gobgpapi.PolicyAssignment")
|
|
proto.RegisterType((*MrtMessage)(nil), "gobgpapi.MrtMessage")
|
|
proto.RegisterType((*RPKIConf)(nil), "gobgpapi.RPKIConf")
|
|
proto.RegisterType((*RPKIState)(nil), "gobgpapi.RPKIState")
|
|
proto.RegisterType((*RPKI)(nil), "gobgpapi.RPKI")
|
|
proto.RegisterType((*ROA)(nil), "gobgpapi.ROA")
|
|
proto.RegisterType((*Vrf)(nil), "gobgpapi.Vrf")
|
|
proto.RegisterType((*Global)(nil), "gobgpapi.Global")
|
|
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, in *ModPathArguments, opts ...grpc.CallOption) (*ModPathResponse, error)
|
|
ModPaths(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModPathsClient, 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, in *ModPathArguments, opts ...grpc.CallOption) (*ModPathResponse, error) {
|
|
out := new(ModPathResponse)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/ModPath", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModPaths(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModPathsClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[1], c.cc, "/gobgpapi.GobgpApi/ModPaths", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiModPathsClient{stream}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_ModPathsClient interface {
|
|
Send(*ModPathsArguments) error
|
|
CloseAndRecv() (*Error, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiModPathsClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiModPathsClient) Send(m *ModPathsArguments) error {
|
|
return x.ClientStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModPathsClient) 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(context.Context, *ModPathArguments) (*ModPathResponse, error)
|
|
ModPaths(GobgpApi_ModPathsServer) 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{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(ModPathArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).ModPath(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_ModPaths_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
return srv.(GobgpApiServer).ModPaths(&gobgpApiModPathsServer{stream})
|
|
}
|
|
|
|
type GobgpApi_ModPathsServer interface {
|
|
SendAndClose(*Error) error
|
|
Recv() (*ModPathsArguments, error)
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiModPathsServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiModPathsServer) SendAndClose(m *Error) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModPathsServer) Recv() (*ModPathsArguments, error) {
|
|
m := new(ModPathsArguments)
|
|
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: "ModPath",
|
|
Handler: _GobgpApi_ModPath_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: "ModPaths",
|
|
Handler: _GobgpApi_ModPaths_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,
|
|
},
|
|
},
|
|
}
|