Documentation ¶
Index ¶
- Variables
- func RegisterBgpServiceServer(s *grpc.Server, srv BgpServiceServer)
- type BgpServiceClient
- type BgpServiceServer
- type BgpService_DumpRIBInClient
- type BgpService_DumpRIBInServer
- type BgpService_DumpRIBOutClient
- type BgpService_DumpRIBOutServer
- type DumpRIBRequest
- func (*DumpRIBRequest) Descriptor() ([]byte, []int)
- func (m *DumpRIBRequest) GetAfi() uint32
- func (m *DumpRIBRequest) GetPeer() *api.IP
- func (m *DumpRIBRequest) GetSafi() uint32
- func (*DumpRIBRequest) ProtoMessage()
- func (m *DumpRIBRequest) Reset()
- func (m *DumpRIBRequest) String() string
- func (m *DumpRIBRequest) XXX_DiscardUnknown()
- func (m *DumpRIBRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpRIBRequest) XXX_Merge(src proto.Message)
- func (m *DumpRIBRequest) XXX_Size() int
- func (m *DumpRIBRequest) XXX_Unmarshal(b []byte) error
- type ListSessionsRequest
- func (*ListSessionsRequest) Descriptor() ([]byte, []int)
- func (m *ListSessionsRequest) GetFilter() *SessionFilter
- func (*ListSessionsRequest) ProtoMessage()
- func (m *ListSessionsRequest) Reset()
- func (m *ListSessionsRequest) String() string
- func (m *ListSessionsRequest) XXX_DiscardUnknown()
- func (m *ListSessionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListSessionsRequest) XXX_Merge(src proto.Message)
- func (m *ListSessionsRequest) XXX_Size() int
- func (m *ListSessionsRequest) XXX_Unmarshal(b []byte) error
- type ListSessionsResponse
- func (*ListSessionsResponse) Descriptor() ([]byte, []int)
- func (m *ListSessionsResponse) GetSessions() []*Session
- func (*ListSessionsResponse) ProtoMessage()
- func (m *ListSessionsResponse) Reset()
- func (m *ListSessionsResponse) String() string
- func (m *ListSessionsResponse) XXX_DiscardUnknown()
- func (m *ListSessionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListSessionsResponse) XXX_Merge(src proto.Message)
- func (m *ListSessionsResponse) XXX_Size() int
- func (m *ListSessionsResponse) XXX_Unmarshal(b []byte) error
- type Session
- func (*Session) Descriptor() ([]byte, []int)
- func (m *Session) GetDescription() string
- func (m *Session) GetEstablishedSince() uint64
- func (m *Session) GetLocalAddress() *api.IP
- func (m *Session) GetLocalAsn() uint32
- func (m *Session) GetNeighborAddress() *api.IP
- func (m *Session) GetPeerAsn() uint32
- func (m *Session) GetStats() *SessionStats
- func (m *Session) GetStatus() Session_State
- func (*Session) ProtoMessage()
- func (m *Session) Reset()
- func (m *Session) String() string
- func (m *Session) XXX_DiscardUnknown()
- func (m *Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Session) XXX_Merge(src proto.Message)
- func (m *Session) XXX_Size() int
- func (m *Session) XXX_Unmarshal(b []byte) error
- type SessionFilter
- func (*SessionFilter) Descriptor() ([]byte, []int)
- func (m *SessionFilter) GetNeighborIp() *api.IP
- func (m *SessionFilter) GetVrfName() string
- func (*SessionFilter) ProtoMessage()
- func (m *SessionFilter) Reset()
- func (m *SessionFilter) String() string
- func (m *SessionFilter) XXX_DiscardUnknown()
- func (m *SessionFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionFilter) XXX_Merge(src proto.Message)
- func (m *SessionFilter) XXX_Size() int
- func (m *SessionFilter) XXX_Unmarshal(b []byte) error
- type SessionStats
- func (*SessionStats) Descriptor() ([]byte, []int)
- func (m *SessionStats) GetFlaps() uint64
- func (m *SessionStats) GetMessagesIn() uint64
- func (m *SessionStats) GetMessagesOut() uint64
- func (m *SessionStats) GetRoutesExported() uint64
- func (m *SessionStats) GetRoutesImported() uint64
- func (m *SessionStats) GetRoutesReceived() uint64
- func (*SessionStats) ProtoMessage()
- func (m *SessionStats) Reset()
- func (m *SessionStats) String() string
- func (m *SessionStats) XXX_DiscardUnknown()
- func (m *SessionStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionStats) XXX_Merge(src proto.Message)
- func (m *SessionStats) XXX_Size() int
- func (m *SessionStats) XXX_Unmarshal(b []byte) error
- type Session_State
Constants ¶
This section is empty.
Variables ¶
View Source
var Session_State_name = map[int32]string{
0: "Disabled",
1: "Idle",
2: "Connect",
3: "Active",
4: "OpenSent",
5: "OpenConfirmed",
6: "Established",
}
View Source
var Session_State_value = map[string]int32{
"Disabled": 0,
"Idle": 1,
"Connect": 2,
"Active": 3,
"OpenSent": 4,
"OpenConfirmed": 5,
"Established": 6,
}
Functions ¶
func RegisterBgpServiceServer ¶
func RegisterBgpServiceServer(s *grpc.Server, srv BgpServiceServer)
Types ¶
type BgpServiceClient ¶
type BgpServiceClient interface { ListSessions(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, error) DumpRIBIn(ctx context.Context, in *DumpRIBRequest, opts ...grpc.CallOption) (BgpService_DumpRIBInClient, error) DumpRIBOut(ctx context.Context, in *DumpRIBRequest, opts ...grpc.CallOption) (BgpService_DumpRIBOutClient, error) }
BgpServiceClient is the client API for BgpService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBgpServiceClient ¶
func NewBgpServiceClient(cc *grpc.ClientConn) BgpServiceClient
type BgpServiceServer ¶
type BgpServiceServer interface { ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error) DumpRIBIn(*DumpRIBRequest, BgpService_DumpRIBInServer) error DumpRIBOut(*DumpRIBRequest, BgpService_DumpRIBOutServer) error }
BgpServiceServer is the server API for BgpService service.
type BgpService_DumpRIBInClient ¶
type BgpService_DumpRIBInClient interface { Recv() (*api1.Route, error) grpc.ClientStream }
type BgpService_DumpRIBInServer ¶
type BgpService_DumpRIBInServer interface { Send(*api1.Route) error grpc.ServerStream }
type BgpService_DumpRIBOutClient ¶
type BgpService_DumpRIBOutClient interface { Recv() (*api1.Route, error) grpc.ClientStream }
type BgpService_DumpRIBOutServer ¶
type BgpService_DumpRIBOutServer interface { Send(*api1.Route) error grpc.ServerStream }
type DumpRIBRequest ¶
type DumpRIBRequest struct { Peer *api.IP `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"` Afi uint32 `protobuf:"varint,2,opt,name=afi,proto3" json:"afi,omitempty"` Safi uint32 `protobuf:"varint,3,opt,name=safi,proto3" json:"safi,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DumpRIBRequest) Descriptor ¶
func (*DumpRIBRequest) Descriptor() ([]byte, []int)
func (*DumpRIBRequest) GetAfi ¶
func (m *DumpRIBRequest) GetAfi() uint32
func (*DumpRIBRequest) GetPeer ¶
func (m *DumpRIBRequest) GetPeer() *api.IP
func (*DumpRIBRequest) GetSafi ¶
func (m *DumpRIBRequest) GetSafi() uint32
func (*DumpRIBRequest) ProtoMessage ¶
func (*DumpRIBRequest) ProtoMessage()
func (*DumpRIBRequest) Reset ¶
func (m *DumpRIBRequest) Reset()
func (*DumpRIBRequest) String ¶
func (m *DumpRIBRequest) String() string
func (*DumpRIBRequest) XXX_DiscardUnknown ¶
func (m *DumpRIBRequest) XXX_DiscardUnknown()
func (*DumpRIBRequest) XXX_Marshal ¶
func (m *DumpRIBRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpRIBRequest) XXX_Merge ¶
func (m *DumpRIBRequest) XXX_Merge(src proto.Message)
func (*DumpRIBRequest) XXX_Size ¶
func (m *DumpRIBRequest) XXX_Size() int
func (*DumpRIBRequest) XXX_Unmarshal ¶
func (m *DumpRIBRequest) XXX_Unmarshal(b []byte) error
type ListSessionsRequest ¶
type ListSessionsRequest struct { Filter *SessionFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListSessionsRequest) Descriptor ¶
func (*ListSessionsRequest) Descriptor() ([]byte, []int)
func (*ListSessionsRequest) GetFilter ¶
func (m *ListSessionsRequest) GetFilter() *SessionFilter
func (*ListSessionsRequest) ProtoMessage ¶
func (*ListSessionsRequest) ProtoMessage()
func (*ListSessionsRequest) Reset ¶
func (m *ListSessionsRequest) Reset()
func (*ListSessionsRequest) String ¶
func (m *ListSessionsRequest) String() string
func (*ListSessionsRequest) XXX_DiscardUnknown ¶
func (m *ListSessionsRequest) XXX_DiscardUnknown()
func (*ListSessionsRequest) XXX_Marshal ¶
func (m *ListSessionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListSessionsRequest) XXX_Merge ¶
func (m *ListSessionsRequest) XXX_Merge(src proto.Message)
func (*ListSessionsRequest) XXX_Size ¶
func (m *ListSessionsRequest) XXX_Size() int
func (*ListSessionsRequest) XXX_Unmarshal ¶
func (m *ListSessionsRequest) XXX_Unmarshal(b []byte) error
type ListSessionsResponse ¶
type ListSessionsResponse struct { Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListSessionsResponse) Descriptor ¶
func (*ListSessionsResponse) Descriptor() ([]byte, []int)
func (*ListSessionsResponse) GetSessions ¶
func (m *ListSessionsResponse) GetSessions() []*Session
func (*ListSessionsResponse) ProtoMessage ¶
func (*ListSessionsResponse) ProtoMessage()
func (*ListSessionsResponse) Reset ¶
func (m *ListSessionsResponse) Reset()
func (*ListSessionsResponse) String ¶
func (m *ListSessionsResponse) String() string
func (*ListSessionsResponse) XXX_DiscardUnknown ¶
func (m *ListSessionsResponse) XXX_DiscardUnknown()
func (*ListSessionsResponse) XXX_Marshal ¶
func (m *ListSessionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListSessionsResponse) XXX_Merge ¶
func (m *ListSessionsResponse) XXX_Merge(src proto.Message)
func (*ListSessionsResponse) XXX_Size ¶
func (m *ListSessionsResponse) XXX_Size() int
func (*ListSessionsResponse) XXX_Unmarshal ¶
func (m *ListSessionsResponse) XXX_Unmarshal(b []byte) error
type Session ¶
type Session struct { LocalAddress *api.IP `protobuf:"bytes,1,opt,name=local_address,json=localAddress,proto3" json:"local_address,omitempty"` NeighborAddress *api.IP `protobuf:"bytes,2,opt,name=neighbor_address,json=neighborAddress,proto3" json:"neighbor_address,omitempty"` LocalAsn uint32 `protobuf:"varint,3,opt,name=local_asn,json=localAsn,proto3" json:"local_asn,omitempty"` PeerAsn uint32 `protobuf:"varint,4,opt,name=peer_asn,json=peerAsn,proto3" json:"peer_asn,omitempty"` Status Session_State `protobuf:"varint,5,opt,name=status,proto3,enum=bio.bgp.Session_State" json:"status,omitempty"` Stats *SessionStats `protobuf:"bytes,6,opt,name=stats,proto3" json:"stats,omitempty"` EstablishedSince uint64 `protobuf:"varint,7,opt,name=established_since,json=establishedSince,proto3" json:"established_since,omitempty"` Description string `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Session) Descriptor ¶
func (*Session) GetDescription ¶
func (*Session) GetEstablishedSince ¶
func (*Session) GetLocalAddress ¶
func (*Session) GetLocalAsn ¶
func (*Session) GetNeighborAddress ¶
func (*Session) GetPeerAsn ¶
func (*Session) GetStats ¶
func (m *Session) GetStats() *SessionStats
func (*Session) GetStatus ¶
func (m *Session) GetStatus() Session_State
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) XXX_DiscardUnknown ¶
func (m *Session) XXX_DiscardUnknown()
func (*Session) XXX_Marshal ¶
func (*Session) XXX_Unmarshal ¶
type SessionFilter ¶
type SessionFilter struct { NeighborIp *api.IP `protobuf:"bytes,1,opt,name=neighbor_ip,json=neighborIp,proto3" json:"neighbor_ip,omitempty"` VrfName string `protobuf:"bytes,2,opt,name=vrf_name,json=vrfName,proto3" json:"vrf_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SessionFilter) Descriptor ¶
func (*SessionFilter) Descriptor() ([]byte, []int)
func (*SessionFilter) GetNeighborIp ¶
func (m *SessionFilter) GetNeighborIp() *api.IP
func (*SessionFilter) GetVrfName ¶
func (m *SessionFilter) GetVrfName() string
func (*SessionFilter) ProtoMessage ¶
func (*SessionFilter) ProtoMessage()
func (*SessionFilter) Reset ¶
func (m *SessionFilter) Reset()
func (*SessionFilter) String ¶
func (m *SessionFilter) String() string
func (*SessionFilter) XXX_DiscardUnknown ¶
func (m *SessionFilter) XXX_DiscardUnknown()
func (*SessionFilter) XXX_Marshal ¶
func (m *SessionFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionFilter) XXX_Merge ¶
func (m *SessionFilter) XXX_Merge(src proto.Message)
func (*SessionFilter) XXX_Size ¶
func (m *SessionFilter) XXX_Size() int
func (*SessionFilter) XXX_Unmarshal ¶
func (m *SessionFilter) XXX_Unmarshal(b []byte) error
type SessionStats ¶
type SessionStats struct { MessagesIn uint64 `protobuf:"varint,1,opt,name=messages_in,json=messagesIn,proto3" json:"messages_in,omitempty"` MessagesOut uint64 `protobuf:"varint,2,opt,name=messages_out,json=messagesOut,proto3" json:"messages_out,omitempty"` Flaps uint64 `protobuf:"varint,3,opt,name=flaps,proto3" json:"flaps,omitempty"` RoutesReceived uint64 `protobuf:"varint,4,opt,name=routes_received,json=routesReceived,proto3" json:"routes_received,omitempty"` RoutesImported uint64 `protobuf:"varint,5,opt,name=routes_imported,json=routesImported,proto3" json:"routes_imported,omitempty"` RoutesExported uint64 `protobuf:"varint,6,opt,name=routes_exported,json=routesExported,proto3" json:"routes_exported,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SessionStats) Descriptor ¶
func (*SessionStats) Descriptor() ([]byte, []int)
func (*SessionStats) GetFlaps ¶
func (m *SessionStats) GetFlaps() uint64
func (*SessionStats) GetMessagesIn ¶
func (m *SessionStats) GetMessagesIn() uint64
func (*SessionStats) GetMessagesOut ¶
func (m *SessionStats) GetMessagesOut() uint64
func (*SessionStats) GetRoutesExported ¶
func (m *SessionStats) GetRoutesExported() uint64
func (*SessionStats) GetRoutesImported ¶
func (m *SessionStats) GetRoutesImported() uint64
func (*SessionStats) GetRoutesReceived ¶
func (m *SessionStats) GetRoutesReceived() uint64
func (*SessionStats) ProtoMessage ¶
func (*SessionStats) ProtoMessage()
func (*SessionStats) Reset ¶
func (m *SessionStats) Reset()
func (*SessionStats) String ¶
func (m *SessionStats) String() string
func (*SessionStats) XXX_DiscardUnknown ¶
func (m *SessionStats) XXX_DiscardUnknown()
func (*SessionStats) XXX_Marshal ¶
func (m *SessionStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionStats) XXX_Merge ¶
func (m *SessionStats) XXX_Merge(src proto.Message)
func (*SessionStats) XXX_Size ¶
func (m *SessionStats) XXX_Size() int
func (*SessionStats) XXX_Unmarshal ¶
func (m *SessionStats) XXX_Unmarshal(b []byte) error
type Session_State ¶
type Session_State int32
const ( Session_Disabled Session_State = 0 Session_Idle Session_State = 1 Session_Connect Session_State = 2 Session_Active Session_State = 3 Session_OpenSent Session_State = 4 Session_OpenConfirmed Session_State = 5 Session_Established Session_State = 6 )
func (Session_State) EnumDescriptor ¶
func (Session_State) EnumDescriptor() ([]byte, []int)
func (Session_State) String ¶
func (x Session_State) String() string
Click to show internal directories.
Click to hide internal directories.