mirror of
https://github.com/osrg/gobgp.git
synced 2024-05-11 05:55:10 +00:00
1762 lines
54 KiB
Go
1762 lines
54 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
|
|
PolicyArguments
|
|
MrtArguments
|
|
ModVrfArguments
|
|
Path
|
|
Destination
|
|
PeerConf
|
|
PeerInfo
|
|
Peer
|
|
Prefix
|
|
PrefixSet
|
|
Neighbor
|
|
NeighborSet
|
|
AsPathLength
|
|
AsPathSet
|
|
CommunitySet
|
|
ExtCommunitySet
|
|
Conditions
|
|
CommunityAction
|
|
AsPrependAction
|
|
Actions
|
|
Statement
|
|
PolicyDefinition
|
|
ApplyPolicy
|
|
MrtMessage
|
|
RPKIConf
|
|
RPKIState
|
|
RPKI
|
|
ROA
|
|
Vrf
|
|
*/
|
|
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_POLICY_PREFIX Resource = 4
|
|
Resource_POLICY_NEIGHBOR Resource = 5
|
|
Resource_POLICY_ASPATH Resource = 6
|
|
Resource_POLICY_COMMUNITY Resource = 7
|
|
Resource_POLICY_ROUTEPOLICY Resource = 8
|
|
Resource_POLICY_EXTCOMMUNITY Resource = 9
|
|
Resource_VRF Resource = 10
|
|
)
|
|
|
|
var Resource_name = map[int32]string{
|
|
0: "GLOBAL",
|
|
1: "LOCAL",
|
|
2: "ADJ_IN",
|
|
3: "ADJ_OUT",
|
|
4: "POLICY_PREFIX",
|
|
5: "POLICY_NEIGHBOR",
|
|
6: "POLICY_ASPATH",
|
|
7: "POLICY_COMMUNITY",
|
|
8: "POLICY_ROUTEPOLICY",
|
|
9: "POLICY_EXTCOMMUNITY",
|
|
10: "VRF",
|
|
}
|
|
var Resource_value = map[string]int32{
|
|
"GLOBAL": 0,
|
|
"LOCAL": 1,
|
|
"ADJ_IN": 2,
|
|
"ADJ_OUT": 3,
|
|
"POLICY_PREFIX": 4,
|
|
"POLICY_NEIGHBOR": 5,
|
|
"POLICY_ASPATH": 6,
|
|
"POLICY_COMMUNITY": 7,
|
|
"POLICY_ROUTEPOLICY": 8,
|
|
"POLICY_EXTCOMMUNITY": 9,
|
|
"VRF": 10,
|
|
}
|
|
|
|
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
|
|
)
|
|
|
|
var Operation_name = map[int32]string{
|
|
0: "ADD",
|
|
1: "DEL",
|
|
2: "DEL_ALL",
|
|
}
|
|
var Operation_value = map[string]int32{
|
|
"ADD": 0,
|
|
"DEL": 1,
|
|
"DEL_ALL": 2,
|
|
}
|
|
|
|
func (x Operation) String() string {
|
|
return proto.EnumName(Operation_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 PolicyArguments struct {
|
|
Resource Resource `protobuf:"varint,1,opt,name=resource,enum=gobgpapi.Resource" json:"resource,omitempty"`
|
|
Operation Operation `protobuf:"varint,2,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
|
|
NeighborAddress string `protobuf:"bytes,3,opt,name=neighbor_address" json:"neighbor_address,omitempty"`
|
|
Name string `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"`
|
|
PolicyDefinition *PolicyDefinition `protobuf:"bytes,6,opt,name=policy_definition" json:"policy_definition,omitempty"`
|
|
ApplyPolicy *ApplyPolicy `protobuf:"bytes,7,opt,name=apply_policy" json:"apply_policy,omitempty"`
|
|
}
|
|
|
|
func (m *PolicyArguments) Reset() { *m = PolicyArguments{} }
|
|
func (m *PolicyArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*PolicyArguments) ProtoMessage() {}
|
|
|
|
func (m *PolicyArguments) GetPolicyDefinition() *PolicyDefinition {
|
|
if m != nil {
|
|
return m.PolicyDefinition
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *PolicyArguments) GetApplyPolicy() *ApplyPolicy {
|
|
if m != nil {
|
|
return m.ApplyPolicy
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type MrtArguments struct {
|
|
Resource Resource `protobuf:"varint,1,opt,name=resource,enum=gobgpapi.Resource" json:"resource,omitempty"`
|
|
Rf uint32 `protobuf:"varint,2,opt,name=rf" json:"rf,omitempty"`
|
|
Interval uint64 `protobuf:"varint,3,opt,name=interval" json:"interval,omitempty"`
|
|
NeighborAddress string `protobuf:"bytes,4,opt,name=neighbor_address" json:"neighbor_address,omitempty"`
|
|
}
|
|
|
|
func (m *MrtArguments) Reset() { *m = MrtArguments{} }
|
|
func (m *MrtArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*MrtArguments) ProtoMessage() {}
|
|
|
|
type ModVrfArguments struct {
|
|
Operation Operation `protobuf:"varint,1,opt,name=operation,enum=gobgpapi.Operation" json:"operation,omitempty"`
|
|
Vrf *Vrf `protobuf:"bytes,2,opt,name=vrf" json:"vrf,omitempty"`
|
|
}
|
|
|
|
func (m *ModVrfArguments) Reset() { *m = ModVrfArguments{} }
|
|
func (m *ModVrfArguments) String() string { return proto.CompactTextString(m) }
|
|
func (*ModVrfArguments) ProtoMessage() {}
|
|
|
|
func (m *ModVrfArguments) GetVrf() *Vrf {
|
|
if m != nil {
|
|
return m.Vrf
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type 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 PeerConf struct {
|
|
RemoteIp string `protobuf:"bytes,1,opt,name=remote_ip" json:"remote_ip,omitempty"`
|
|
Id string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
|
|
RemoteAs uint32 `protobuf:"varint,3,opt,name=remote_as" json:"remote_as,omitempty"`
|
|
RemoteCap [][]byte `protobuf:"bytes,6,rep,name=remote_cap,proto3" json:"remote_cap,omitempty"`
|
|
LocalCap [][]byte `protobuf:"bytes,7,rep,name=local_cap,proto3" json:"local_cap,omitempty"`
|
|
Holdtime uint32 `protobuf:"varint,8,opt,name=holdtime" json:"holdtime,omitempty"`
|
|
KeepaliveInterval uint32 `protobuf:"varint,9,opt,name=keepalive_interval" json:"keepalive_interval,omitempty"`
|
|
}
|
|
|
|
func (m *PeerConf) Reset() { *m = PeerConf{} }
|
|
func (m *PeerConf) String() string { return proto.CompactTextString(m) }
|
|
func (*PeerConf) ProtoMessage() {}
|
|
|
|
type PeerInfo struct {
|
|
BgpState string `protobuf:"bytes,1,opt,name=bgp_state" json:"bgp_state,omitempty"`
|
|
AdminState string `protobuf:"bytes,2,opt,name=admin_state" json:"admin_state,omitempty"`
|
|
FsmEstablishedTransitions uint32 `protobuf:"varint,3,opt,name=fsm_established_transitions" json:"fsm_established_transitions,omitempty"`
|
|
TotalMessageOut uint64 `protobuf:"varint,4,opt,name=total_message_out" json:"total_message_out,omitempty"`
|
|
TotalMessageIn uint64 `protobuf:"varint,5,opt,name=total_message_in" json:"total_message_in,omitempty"`
|
|
UpdateMessageOut uint64 `protobuf:"varint,6,opt,name=update_message_out" json:"update_message_out,omitempty"`
|
|
UpdateMessageIn uint64 `protobuf:"varint,7,opt,name=update_message_in" json:"update_message_in,omitempty"`
|
|
KeepAliveMessageOut uint64 `protobuf:"varint,8,opt,name=keep_alive_message_out" json:"keep_alive_message_out,omitempty"`
|
|
KeepAliveMessageIn uint64 `protobuf:"varint,9,opt,name=keep_alive_message_in" json:"keep_alive_message_in,omitempty"`
|
|
OpenMessageOut uint64 `protobuf:"varint,10,opt,name=open_message_out" json:"open_message_out,omitempty"`
|
|
OpenMessageIn uint64 `protobuf:"varint,11,opt,name=open_message_in" json:"open_message_in,omitempty"`
|
|
NotificationOut uint64 `protobuf:"varint,12,opt,name=notification_out" json:"notification_out,omitempty"`
|
|
NotificationIn uint64 `protobuf:"varint,13,opt,name=notification_in" json:"notification_in,omitempty"`
|
|
RefreshMessageOut uint64 `protobuf:"varint,14,opt,name=refresh_message_out" json:"refresh_message_out,omitempty"`
|
|
RefreshMessageIn uint64 `protobuf:"varint,15,opt,name=refresh_message_in" json:"refresh_message_in,omitempty"`
|
|
DiscardedOut uint64 `protobuf:"varint,16,opt,name=discarded_out" json:"discarded_out,omitempty"`
|
|
DiscardedIn uint64 `protobuf:"varint,17,opt,name=discarded_in" json:"discarded_in,omitempty"`
|
|
Uptime int64 `protobuf:"varint,18,opt,name=uptime" json:"uptime,omitempty"`
|
|
Downtime int64 `protobuf:"varint,19,opt,name=downtime" json:"downtime,omitempty"`
|
|
LastError string `protobuf:"bytes,20,opt,name=last_error" json:"last_error,omitempty"`
|
|
Received uint32 `protobuf:"varint,21,opt,name=received" json:"received,omitempty"`
|
|
Accepted uint32 `protobuf:"varint,22,opt,name=accepted" json:"accepted,omitempty"`
|
|
Advertized uint32 `protobuf:"varint,23,opt,name=advertized" json:"advertized,omitempty"`
|
|
OutQ uint32 `protobuf:"varint,24,opt,name=out_q" json:"out_q,omitempty"`
|
|
Flops uint32 `protobuf:"varint,25,opt,name=flops" json:"flops,omitempty"`
|
|
NegotiatedHoldtime uint32 `protobuf:"varint,26,opt,name=negotiated_holdtime" json:"negotiated_holdtime,omitempty"`
|
|
KeepaliveInterval uint32 `protobuf:"varint,27,opt,name=keepalive_interval" json:"keepalive_interval,omitempty"`
|
|
}
|
|
|
|
func (m *PeerInfo) Reset() { *m = PeerInfo{} }
|
|
func (m *PeerInfo) String() string { return proto.CompactTextString(m) }
|
|
func (*PeerInfo) ProtoMessage() {}
|
|
|
|
type Peer struct {
|
|
Conf *PeerConf `protobuf:"bytes,1,opt,name=conf" json:"conf,omitempty"`
|
|
Info *PeerInfo `protobuf:"bytes,2,opt,name=info" json:"info,omitempty"`
|
|
}
|
|
|
|
func (m *Peer) Reset() { *m = Peer{} }
|
|
func (m *Peer) String() string { return proto.CompactTextString(m) }
|
|
func (*Peer) ProtoMessage() {}
|
|
|
|
func (m *Peer) GetConf() *PeerConf {
|
|
if m != nil {
|
|
return m.Conf
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Peer) GetInfo() *PeerInfo {
|
|
if m != nil {
|
|
return m.Info
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Prefix struct {
|
|
IpPrefix string `protobuf:"bytes,1,opt,name=ip_prefix" json:"ip_prefix,omitempty"`
|
|
MaskLengthRange string `protobuf:"bytes,2,opt,name=mask_length_range" json:"mask_length_range,omitempty"`
|
|
}
|
|
|
|
func (m *Prefix) Reset() { *m = Prefix{} }
|
|
func (m *Prefix) String() string { return proto.CompactTextString(m) }
|
|
func (*Prefix) ProtoMessage() {}
|
|
|
|
type PrefixSet struct {
|
|
PrefixSetName string `protobuf:"bytes,1,opt,name=prefix_set_name" json:"prefix_set_name,omitempty"`
|
|
PrefixList []*Prefix `protobuf:"bytes,2,rep,name=prefix_list" json:"prefix_list,omitempty"`
|
|
MatchSetOptions string `protobuf:"bytes,3,opt,name=match_set_options" json:"match_set_options,omitempty"`
|
|
}
|
|
|
|
func (m *PrefixSet) Reset() { *m = PrefixSet{} }
|
|
func (m *PrefixSet) String() string { return proto.CompactTextString(m) }
|
|
func (*PrefixSet) ProtoMessage() {}
|
|
|
|
func (m *PrefixSet) GetPrefixList() []*Prefix {
|
|
if m != nil {
|
|
return m.PrefixList
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Neighbor struct {
|
|
Address string `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"`
|
|
}
|
|
|
|
func (m *Neighbor) Reset() { *m = Neighbor{} }
|
|
func (m *Neighbor) String() string { return proto.CompactTextString(m) }
|
|
func (*Neighbor) ProtoMessage() {}
|
|
|
|
type NeighborSet struct {
|
|
NeighborSetName string `protobuf:"bytes,1,opt,name=neighbor_set_name" json:"neighbor_set_name,omitempty"`
|
|
NeighborList []*Neighbor `protobuf:"bytes,2,rep,name=neighbor_list" json:"neighbor_list,omitempty"`
|
|
MatchSetOptions string `protobuf:"bytes,3,opt,name=match_set_options" json:"match_set_options,omitempty"`
|
|
}
|
|
|
|
func (m *NeighborSet) Reset() { *m = NeighborSet{} }
|
|
func (m *NeighborSet) String() string { return proto.CompactTextString(m) }
|
|
func (*NeighborSet) ProtoMessage() {}
|
|
|
|
func (m *NeighborSet) GetNeighborList() []*Neighbor {
|
|
if m != nil {
|
|
return m.NeighborList
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type AsPathLength struct {
|
|
Value string `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
|
|
Operator string `protobuf:"bytes,2,opt,name=operator" json:"operator,omitempty"`
|
|
}
|
|
|
|
func (m *AsPathLength) Reset() { *m = AsPathLength{} }
|
|
func (m *AsPathLength) String() string { return proto.CompactTextString(m) }
|
|
func (*AsPathLength) ProtoMessage() {}
|
|
|
|
type AsPathSet struct {
|
|
AsPathSetName string `protobuf:"bytes,1,opt,name=as_path_set_name" json:"as_path_set_name,omitempty"`
|
|
AsPathMembers []string `protobuf:"bytes,2,rep,name=as_path_members" json:"as_path_members,omitempty"`
|
|
MatchSetOptions string `protobuf:"bytes,3,opt,name=match_set_options" json:"match_set_options,omitempty"`
|
|
}
|
|
|
|
func (m *AsPathSet) Reset() { *m = AsPathSet{} }
|
|
func (m *AsPathSet) String() string { return proto.CompactTextString(m) }
|
|
func (*AsPathSet) ProtoMessage() {}
|
|
|
|
type CommunitySet struct {
|
|
CommunitySetName string `protobuf:"bytes,1,opt,name=community_set_name" json:"community_set_name,omitempty"`
|
|
CommunityMembers []string `protobuf:"bytes,2,rep,name=community_members" json:"community_members,omitempty"`
|
|
MatchSetOptions string `protobuf:"bytes,3,opt,name=match_set_options" json:"match_set_options,omitempty"`
|
|
}
|
|
|
|
func (m *CommunitySet) Reset() { *m = CommunitySet{} }
|
|
func (m *CommunitySet) String() string { return proto.CompactTextString(m) }
|
|
func (*CommunitySet) ProtoMessage() {}
|
|
|
|
type ExtCommunitySet struct {
|
|
ExtCommunitySetName string `protobuf:"bytes,1,opt,name=ext_community_set_name" json:"ext_community_set_name,omitempty"`
|
|
ExtCommunityMembers []string `protobuf:"bytes,2,rep,name=ext_community_members" json:"ext_community_members,omitempty"`
|
|
MatchSetOptions string `protobuf:"bytes,3,opt,name=match_set_options" json:"match_set_options,omitempty"`
|
|
}
|
|
|
|
func (m *ExtCommunitySet) Reset() { *m = ExtCommunitySet{} }
|
|
func (m *ExtCommunitySet) String() string { return proto.CompactTextString(m) }
|
|
func (*ExtCommunitySet) ProtoMessage() {}
|
|
|
|
type Conditions struct {
|
|
MatchPrefixSet *PrefixSet `protobuf:"bytes,1,opt,name=match_prefix_set" json:"match_prefix_set,omitempty"`
|
|
MatchNeighborSet *NeighborSet `protobuf:"bytes,2,opt,name=match_neighbor_set" json:"match_neighbor_set,omitempty"`
|
|
MatchAsPathLength *AsPathLength `protobuf:"bytes,3,opt,name=match_as_path_length" json:"match_as_path_length,omitempty"`
|
|
MatchAsPathSet *AsPathSet `protobuf:"bytes,4,opt,name=match_as_path_set" json:"match_as_path_set,omitempty"`
|
|
MatchCommunitySet *CommunitySet `protobuf:"bytes,5,opt,name=match_community_set" json:"match_community_set,omitempty"`
|
|
MatchExtCommunitySet *ExtCommunitySet `protobuf:"bytes,6,opt,name=match_ext_community_set" json:"match_ext_community_set,omitempty"`
|
|
}
|
|
|
|
func (m *Conditions) Reset() { *m = Conditions{} }
|
|
func (m *Conditions) String() string { return proto.CompactTextString(m) }
|
|
func (*Conditions) ProtoMessage() {}
|
|
|
|
func (m *Conditions) GetMatchPrefixSet() *PrefixSet {
|
|
if m != nil {
|
|
return m.MatchPrefixSet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetMatchNeighborSet() *NeighborSet {
|
|
if m != nil {
|
|
return m.MatchNeighborSet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetMatchAsPathLength() *AsPathLength {
|
|
if m != nil {
|
|
return m.MatchAsPathLength
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetMatchAsPathSet() *AsPathSet {
|
|
if m != nil {
|
|
return m.MatchAsPathSet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetMatchCommunitySet() *CommunitySet {
|
|
if m != nil {
|
|
return m.MatchCommunitySet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Conditions) GetMatchExtCommunitySet() *ExtCommunitySet {
|
|
if m != nil {
|
|
return m.MatchExtCommunitySet
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type CommunityAction struct {
|
|
Communities []string `protobuf:"bytes,1,rep,name=communities" json:"communities,omitempty"`
|
|
Options string `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
|
|
}
|
|
|
|
func (m *CommunityAction) Reset() { *m = CommunityAction{} }
|
|
func (m *CommunityAction) String() string { return proto.CompactTextString(m) }
|
|
func (*CommunityAction) ProtoMessage() {}
|
|
|
|
type AsPrependAction struct {
|
|
As string `protobuf:"bytes,1,opt,name=as" json:"as,omitempty"`
|
|
Repeatn uint32 `protobuf:"varint,2,opt,name=repeatn" json:"repeatn,omitempty"`
|
|
}
|
|
|
|
func (m *AsPrependAction) Reset() { *m = AsPrependAction{} }
|
|
func (m *AsPrependAction) String() string { return proto.CompactTextString(m) }
|
|
func (*AsPrependAction) ProtoMessage() {}
|
|
|
|
type Actions struct {
|
|
RouteAction string `protobuf:"bytes,1,opt,name=route_action" json:"route_action,omitempty"`
|
|
Community *CommunityAction `protobuf:"bytes,2,opt,name=community" json:"community,omitempty"`
|
|
Med string `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) 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 {
|
|
StatementNeme string `protobuf:"bytes,1,opt,name=statement_neme" json:"statement_neme,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 PolicyDefinition struct {
|
|
PolicyDefinitionName string `protobuf:"bytes,1,opt,name=policy_definition_name" json:"policy_definition_name,omitempty"`
|
|
StatementList []*Statement `protobuf:"bytes,2,rep,name=statement_list" json:"statement_list,omitempty"`
|
|
}
|
|
|
|
func (m *PolicyDefinition) Reset() { *m = PolicyDefinition{} }
|
|
func (m *PolicyDefinition) String() string { return proto.CompactTextString(m) }
|
|
func (*PolicyDefinition) ProtoMessage() {}
|
|
|
|
func (m *PolicyDefinition) GetStatementList() []*Statement {
|
|
if m != nil {
|
|
return m.StatementList
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ApplyPolicy struct {
|
|
ImportPolicies []*PolicyDefinition `protobuf:"bytes,1,rep,name=import_policies" json:"import_policies,omitempty"`
|
|
DefaultImportPolicy string `protobuf:"bytes,2,opt,name=default_import_policy" json:"default_import_policy,omitempty"`
|
|
ExportPolicies []*PolicyDefinition `protobuf:"bytes,3,rep,name=export_policies" json:"export_policies,omitempty"`
|
|
DefaultExportPolicy string `protobuf:"bytes,4,opt,name=default_export_policy" json:"default_export_policy,omitempty"`
|
|
InPolicies []*PolicyDefinition `protobuf:"bytes,5,rep,name=in_policies" json:"in_policies,omitempty"`
|
|
DefaultInPolicy string `protobuf:"bytes,6,opt,name=default_in_policy" json:"default_in_policy,omitempty"`
|
|
}
|
|
|
|
func (m *ApplyPolicy) Reset() { *m = ApplyPolicy{} }
|
|
func (m *ApplyPolicy) String() string { return proto.CompactTextString(m) }
|
|
func (*ApplyPolicy) ProtoMessage() {}
|
|
|
|
func (m *ApplyPolicy) GetImportPolicies() []*PolicyDefinition {
|
|
if m != nil {
|
|
return m.ImportPolicies
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *ApplyPolicy) GetExportPolicies() []*PolicyDefinition {
|
|
if m != nil {
|
|
return m.ExportPolicies
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *ApplyPolicy) GetInPolicies() []*PolicyDefinition {
|
|
if m != nil {
|
|
return m.InPolicies
|
|
}
|
|
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() {}
|
|
|
|
func init() {
|
|
proto.RegisterEnum("gobgpapi.Resource", Resource_name, Resource_value)
|
|
proto.RegisterEnum("gobgpapi.Operation", Operation_name, Operation_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 {
|
|
GetNeighbors(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetNeighborsClient, error)
|
|
GetNeighbor(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Peer, error)
|
|
GetRib(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRibClient, error)
|
|
Reset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
SoftReset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
SoftResetIn(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
SoftResetOut(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
Shutdown(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
Enable(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
Disable(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error)
|
|
ModPath(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModPathClient, error)
|
|
GetNeighborPolicy(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*ApplyPolicy, error)
|
|
ModNeighborPolicy(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModNeighborPolicyClient, error)
|
|
GetPolicyRoutePolicies(ctx context.Context, in *PolicyArguments, opts ...grpc.CallOption) (GobgpApi_GetPolicyRoutePoliciesClient, error)
|
|
GetPolicyRoutePolicy(ctx context.Context, in *PolicyArguments, opts ...grpc.CallOption) (*PolicyDefinition, error)
|
|
ModPolicyRoutePolicy(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModPolicyRoutePolicyClient, error)
|
|
MonitorBestChanged(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_MonitorBestChangedClient, error)
|
|
MonitorPeerState(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_MonitorPeerStateClient, error)
|
|
GetMrt(ctx context.Context, in *MrtArguments, opts ...grpc.CallOption) (GobgpApi_GetMrtClient, error)
|
|
GetRPKI(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRPKIClient, error)
|
|
GetROA(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetROAClient, error)
|
|
GetVrfs(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetVrfsClient, error)
|
|
ModVrf(ctx context.Context, in *ModVrfArguments, opts ...grpc.CallOption) (*Error, error)
|
|
}
|
|
|
|
type gobgpApiClient struct {
|
|
cc *grpc.ClientConn
|
|
}
|
|
|
|
func NewGobgpApiClient(cc *grpc.ClientConn) GobgpApiClient {
|
|
return &gobgpApiClient{cc}
|
|
}
|
|
|
|
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) GetRib(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRibClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[1], c.cc, "/gobgpapi.GobgpApi/GetRib", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetRibClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetRibClient interface {
|
|
Recv() (*Destination, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetRibClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetRibClient) Recv() (*Destination, error) {
|
|
m := new(Destination)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) Reset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/Reset", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) SoftReset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/SoftReset", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) SoftResetIn(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/SoftResetIn", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) SoftResetOut(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/SoftResetOut", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) Shutdown(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/Shutdown", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) Enable(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/Enable", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) Disable(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) {
|
|
out := new(Error)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/Disable", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModPath(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModPathClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[2], c.cc, "/gobgpapi.GobgpApi/ModPath", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiModPathClient{stream}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_ModPathClient interface {
|
|
Send(*ModPathArguments) error
|
|
CloseAndRecv() (*Error, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiModPathClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiModPathClient) Send(m *ModPathArguments) error {
|
|
return x.ClientStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModPathClient) CloseAndRecv() (*Error, error) {
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
m := new(Error)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetNeighborPolicy(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*ApplyPolicy, error) {
|
|
out := new(ApplyPolicy)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/GetNeighborPolicy", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModNeighborPolicy(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModNeighborPolicyClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[3], c.cc, "/gobgpapi.GobgpApi/ModNeighborPolicy", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiModNeighborPolicyClient{stream}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_ModNeighborPolicyClient interface {
|
|
Send(*PolicyArguments) error
|
|
Recv() (*Error, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiModNeighborPolicyClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiModNeighborPolicyClient) Send(m *PolicyArguments) error {
|
|
return x.ClientStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModNeighborPolicyClient) Recv() (*Error, error) {
|
|
m := new(Error)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetPolicyRoutePolicies(ctx context.Context, in *PolicyArguments, opts ...grpc.CallOption) (GobgpApi_GetPolicyRoutePoliciesClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[4], c.cc, "/gobgpapi.GobgpApi/GetPolicyRoutePolicies", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetPolicyRoutePoliciesClient{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_GetPolicyRoutePoliciesClient interface {
|
|
Recv() (*PolicyDefinition, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetPolicyRoutePoliciesClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetPolicyRoutePoliciesClient) Recv() (*PolicyDefinition, error) {
|
|
m := new(PolicyDefinition)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetPolicyRoutePolicy(ctx context.Context, in *PolicyArguments, opts ...grpc.CallOption) (*PolicyDefinition, error) {
|
|
out := new(PolicyDefinition)
|
|
err := grpc.Invoke(ctx, "/gobgpapi.GobgpApi/GetPolicyRoutePolicy", in, out, c.cc, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) ModPolicyRoutePolicy(ctx context.Context, opts ...grpc.CallOption) (GobgpApi_ModPolicyRoutePolicyClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[5], c.cc, "/gobgpapi.GobgpApi/ModPolicyRoutePolicy", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiModPolicyRoutePolicyClient{stream}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_ModPolicyRoutePolicyClient interface {
|
|
Send(*PolicyArguments) error
|
|
Recv() (*Error, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiModPolicyRoutePolicyClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiModPolicyRoutePolicyClient) Send(m *PolicyArguments) error {
|
|
return x.ClientStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModPolicyRoutePolicyClient) Recv() (*Error, error) {
|
|
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[6], 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[7], 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[8], c.cc, "/gobgpapi.GobgpApi/GetMrt", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetMrtClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetMrtClient interface {
|
|
Recv() (*MrtMessage, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetMrtClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetMrtClient) Recv() (*MrtMessage, error) {
|
|
m := new(MrtMessage)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetRPKI(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetRPKIClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[9], c.cc, "/gobgpapi.GobgpApi/GetRPKI", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &gobgpApiGetRPKIClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type GobgpApi_GetRPKIClient interface {
|
|
Recv() (*RPKI, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type gobgpApiGetRPKIClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *gobgpApiGetRPKIClient) Recv() (*RPKI, error) {
|
|
m := new(RPKI)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func (c *gobgpApiClient) GetROA(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (GobgpApi_GetROAClient, error) {
|
|
stream, err := grpc.NewClientStream(ctx, &_GobgpApi_serviceDesc.Streams[10], 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[11], 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
|
|
}
|
|
|
|
// Server API for GobgpApi service
|
|
|
|
type GobgpApiServer interface {
|
|
GetNeighbors(*Arguments, GobgpApi_GetNeighborsServer) error
|
|
GetNeighbor(context.Context, *Arguments) (*Peer, error)
|
|
GetRib(*Arguments, GobgpApi_GetRibServer) error
|
|
Reset(context.Context, *Arguments) (*Error, error)
|
|
SoftReset(context.Context, *Arguments) (*Error, error)
|
|
SoftResetIn(context.Context, *Arguments) (*Error, error)
|
|
SoftResetOut(context.Context, *Arguments) (*Error, error)
|
|
Shutdown(context.Context, *Arguments) (*Error, error)
|
|
Enable(context.Context, *Arguments) (*Error, error)
|
|
Disable(context.Context, *Arguments) (*Error, error)
|
|
ModPath(GobgpApi_ModPathServer) error
|
|
GetNeighborPolicy(context.Context, *Arguments) (*ApplyPolicy, error)
|
|
ModNeighborPolicy(GobgpApi_ModNeighborPolicyServer) error
|
|
GetPolicyRoutePolicies(*PolicyArguments, GobgpApi_GetPolicyRoutePoliciesServer) error
|
|
GetPolicyRoutePolicy(context.Context, *PolicyArguments) (*PolicyDefinition, error)
|
|
ModPolicyRoutePolicy(GobgpApi_ModPolicyRoutePolicyServer) error
|
|
MonitorBestChanged(*Arguments, GobgpApi_MonitorBestChangedServer) error
|
|
MonitorPeerState(*Arguments, GobgpApi_MonitorPeerStateServer) error
|
|
GetMrt(*MrtArguments, GobgpApi_GetMrtServer) error
|
|
GetRPKI(*Arguments, GobgpApi_GetRPKIServer) error
|
|
GetROA(*Arguments, GobgpApi_GetROAServer) error
|
|
GetVrfs(*Arguments, GobgpApi_GetVrfsServer) error
|
|
ModVrf(context.Context, *ModVrfArguments) (*Error, error)
|
|
}
|
|
|
|
func RegisterGobgpApiServer(s *grpc.Server, srv GobgpApiServer) {
|
|
s.RegisterService(&_GobgpApi_serviceDesc, srv)
|
|
}
|
|
|
|
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_GetRib_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetRib(m, &gobgpApiGetRibServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetRibServer interface {
|
|
Send(*Destination) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetRibServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetRibServer) Send(m *Destination) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_Reset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).Reset(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_SoftReset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).SoftReset(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_SoftResetIn_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).SoftResetIn(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_SoftResetOut_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).SoftResetOut(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_Shutdown_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).Shutdown(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_Enable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).Enable(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_Disable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(Arguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).Disable(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_ModPath_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
return srv.(GobgpApiServer).ModPath(&gobgpApiModPathServer{stream})
|
|
}
|
|
|
|
type GobgpApi_ModPathServer interface {
|
|
SendAndClose(*Error) error
|
|
Recv() (*ModPathArguments, error)
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiModPathServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiModPathServer) SendAndClose(m *Error) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModPathServer) Recv() (*ModPathArguments, error) {
|
|
m := new(ModPathArguments)
|
|
if err := x.ServerStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func _GobgpApi_GetNeighborPolicy_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).GetNeighborPolicy(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_ModNeighborPolicy_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
return srv.(GobgpApiServer).ModNeighborPolicy(&gobgpApiModNeighborPolicyServer{stream})
|
|
}
|
|
|
|
type GobgpApi_ModNeighborPolicyServer interface {
|
|
Send(*Error) error
|
|
Recv() (*PolicyArguments, error)
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiModNeighborPolicyServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiModNeighborPolicyServer) Send(m *Error) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModNeighborPolicyServer) Recv() (*PolicyArguments, error) {
|
|
m := new(PolicyArguments)
|
|
if err := x.ServerStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func _GobgpApi_GetPolicyRoutePolicies_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(PolicyArguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetPolicyRoutePolicies(m, &gobgpApiGetPolicyRoutePoliciesServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetPolicyRoutePoliciesServer interface {
|
|
Send(*PolicyDefinition) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetPolicyRoutePoliciesServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetPolicyRoutePoliciesServer) Send(m *PolicyDefinition) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetPolicyRoutePolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(PolicyArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).GetPolicyRoutePolicy(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func _GobgpApi_ModPolicyRoutePolicy_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
return srv.(GobgpApiServer).ModPolicyRoutePolicy(&gobgpApiModPolicyRoutePolicyServer{stream})
|
|
}
|
|
|
|
type GobgpApi_ModPolicyRoutePolicyServer interface {
|
|
Send(*Error) error
|
|
Recv() (*PolicyArguments, error)
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiModPolicyRoutePolicyServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiModPolicyRoutePolicyServer) Send(m *Error) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func (x *gobgpApiModPolicyRoutePolicyServer) Recv() (*PolicyArguments, error) {
|
|
m := new(PolicyArguments)
|
|
if err := x.ServerStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
func _GobgpApi_MonitorBestChanged_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).MonitorBestChanged(m, &gobgpApiMonitorBestChangedServer{stream})
|
|
}
|
|
|
|
type GobgpApi_MonitorBestChangedServer interface {
|
|
Send(*Destination) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiMonitorBestChangedServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiMonitorBestChangedServer) Send(m *Destination) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_MonitorPeerState_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).MonitorPeerState(m, &gobgpApiMonitorPeerStateServer{stream})
|
|
}
|
|
|
|
type GobgpApi_MonitorPeerStateServer interface {
|
|
Send(*Peer) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiMonitorPeerStateServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiMonitorPeerStateServer) Send(m *Peer) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetMrt_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(MrtArguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetMrt(m, &gobgpApiGetMrtServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetMrtServer interface {
|
|
Send(*MrtMessage) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetMrtServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetMrtServer) Send(m *MrtMessage) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetRPKI_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetRPKI(m, &gobgpApiGetRPKIServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetRPKIServer interface {
|
|
Send(*RPKI) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetRPKIServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetRPKIServer) Send(m *RPKI) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetROA_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetROA(m, &gobgpApiGetROAServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetROAServer interface {
|
|
Send(*ROA) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetROAServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetROAServer) Send(m *ROA) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_GetVrfs_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Arguments)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(GobgpApiServer).GetVrfs(m, &gobgpApiGetVrfsServer{stream})
|
|
}
|
|
|
|
type GobgpApi_GetVrfsServer interface {
|
|
Send(*Vrf) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type gobgpApiGetVrfsServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *gobgpApiGetVrfsServer) Send(m *Vrf) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func _GobgpApi_ModVrf_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error) (interface{}, error) {
|
|
in := new(ModVrfArguments)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
out, err := srv.(GobgpApiServer).ModVrf(ctx, in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
var _GobgpApi_serviceDesc = grpc.ServiceDesc{
|
|
ServiceName: "gobgpapi.GobgpApi",
|
|
HandlerType: (*GobgpApiServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "GetNeighbor",
|
|
Handler: _GobgpApi_GetNeighbor_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: "GetNeighborPolicy",
|
|
Handler: _GobgpApi_GetNeighborPolicy_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetPolicyRoutePolicy",
|
|
Handler: _GobgpApi_GetPolicyRoutePolicy_Handler,
|
|
},
|
|
{
|
|
MethodName: "ModVrf",
|
|
Handler: _GobgpApi_ModVrf_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{
|
|
{
|
|
StreamName: "GetNeighbors",
|
|
Handler: _GobgpApi_GetNeighbors_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetRib",
|
|
Handler: _GobgpApi_GetRib_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "ModPath",
|
|
Handler: _GobgpApi_ModPath_Handler,
|
|
ClientStreams: true,
|
|
},
|
|
{
|
|
StreamName: "ModNeighborPolicy",
|
|
Handler: _GobgpApi_ModNeighborPolicy_Handler,
|
|
ServerStreams: true,
|
|
ClientStreams: true,
|
|
},
|
|
{
|
|
StreamName: "GetPolicyRoutePolicies",
|
|
Handler: _GobgpApi_GetPolicyRoutePolicies_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
{
|
|
StreamName: "ModPolicyRoutePolicy",
|
|
Handler: _GobgpApi_ModPolicyRoutePolicy_Handler,
|
|
ServerStreams: true,
|
|
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,
|
|
},
|
|
},
|
|
}
|