Files
osrg-gobgp/api/gobgp.pb.go
T
2015-10-02 12:23:48 +09:00

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