api

package
v0.0.3-pre9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 27, 2022 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

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",
	}
	Session_State_value = map[string]int32{
		"Disabled":      0,
		"Idle":          1,
		"Connect":       2,
		"Active":        3,
		"OpenSent":      4,
		"OpenConfirmed": 5,
		"Established":   6,
	}
)

Enum value maps for Session_State.

View Source 
var BgpService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "bio.bgp.BgpService",
	HandlerType: (*BgpServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListSessions",
			Handler:    _BgpService_ListSessions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DumpRIBIn",
			Handler:       _BgpService_DumpRIBIn_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DumpRIBOut",
			Handler:       _BgpService_DumpRIBOut_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "protocols/bgp/api/bgp.proto",
}

BgpService_ServiceDesc is the grpc.ServiceDesc for BgpService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_protocols_bgp_api_bgp_proto protoreflect.FileDescriptor
View Source 
var File_protocols_bgp_api_session_proto protoreflect.FileDescriptor

Functions

func RegisterBgpServiceServer 

func RegisterBgpServiceServer(s grpc.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBgpServiceClient 

func NewBgpServiceClient(cc grpc.ClientConnInterface) BgpServiceClient

type BgpServiceServer 

type BgpServiceServer interface {
	ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)
	DumpRIBIn(*DumpRIBRequest, BgpService_DumpRIBInServer) error
	DumpRIBOut(*DumpRIBRequest, BgpService_DumpRIBOutServer) error
	// contains filtered or unexported methods
}

BgpServiceServer is the server API for BgpService service. All implementations must embed UnimplementedBgpServiceServer for forward compatibility

type BgpService_DumpRIBInClient 

type BgpService_DumpRIBInClient interface {
	Recv() (*api.Route, error)
	grpc.ClientStream
}

type BgpService_DumpRIBInServer 

type BgpService_DumpRIBInServer interface {
	Send(*api.Route) error
	grpc.ServerStream
}

type BgpService_DumpRIBOutClient 

type BgpService_DumpRIBOutClient interface {
	Recv() (*api.Route, error)
	grpc.ClientStream
}

type BgpService_DumpRIBOutServer 

type BgpService_DumpRIBOutServer interface {
	Send(*api.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"`
	// contains filtered or unexported fields
}

func (*DumpRIBRequest) Descriptor deprecated 

func (*DumpRIBRequest) Descriptor() ([]byte, []int)

Deprecated: Use DumpRIBRequest.ProtoReflect.Descriptor instead.

func (*DumpRIBRequest) GetAfi 

func (x *DumpRIBRequest) GetAfi() uint32

func (*DumpRIBRequest) GetPeer 

func (x *DumpRIBRequest) GetPeer() *api.IP

func (*DumpRIBRequest) GetSafi 

func (x *DumpRIBRequest) GetSafi() uint32

func (*DumpRIBRequest) ProtoMessage 

func (*DumpRIBRequest) ProtoMessage()

func (*DumpRIBRequest) ProtoReflect 

func (x *DumpRIBRequest) ProtoReflect() protoreflect.Message

func (*DumpRIBRequest) Reset 

func (x *DumpRIBRequest) Reset()

func (*DumpRIBRequest) String 

func (x *DumpRIBRequest) String() string

type ListSessionsRequest 

type ListSessionsRequest struct {
	Filter *SessionFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSessionsRequest) Descriptor deprecated 

func (*ListSessionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSessionsRequest.ProtoReflect.Descriptor instead.

func (*ListSessionsRequest) GetFilter 

func (x *ListSessionsRequest) GetFilter() *SessionFilter

func (*ListSessionsRequest) ProtoMessage 

func (*ListSessionsRequest) ProtoMessage()

func (*ListSessionsRequest) ProtoReflect 

func (x *ListSessionsRequest) ProtoReflect() protoreflect.Message

func (*ListSessionsRequest) Reset 

func (x *ListSessionsRequest) Reset()

func (*ListSessionsRequest) String 

func (x *ListSessionsRequest) String() string

type ListSessionsResponse 

type ListSessionsResponse struct {
	Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSessionsResponse) Descriptor deprecated 

func (*ListSessionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListSessionsResponse.ProtoReflect.Descriptor instead.

func (*ListSessionsResponse) GetSessions 

func (x *ListSessionsResponse) GetSessions() []*Session

func (*ListSessionsResponse) ProtoMessage 

func (*ListSessionsResponse) ProtoMessage()

func (*ListSessionsResponse) ProtoReflect 

func (x *ListSessionsResponse) ProtoReflect() protoreflect.Message

func (*ListSessionsResponse) Reset 

func (x *ListSessionsResponse) Reset()

func (*ListSessionsResponse) String 

func (x *ListSessionsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated 

func (*Session) Descriptor() ([]byte, []int)

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetDescription 

func (x *Session) GetDescription() string

func (*Session) GetEstablishedSince 

func (x *Session) GetEstablishedSince() uint64

func (*Session) GetLocalAddress 

func (x *Session) GetLocalAddress() *api.IP

func (*Session) GetLocalAsn 

func (x *Session) GetLocalAsn() uint32

func (*Session) GetNeighborAddress 

func (x *Session) GetNeighborAddress() *api.IP

func (*Session) GetPeerAsn 

func (x *Session) GetPeerAsn() uint32

func (*Session) GetStats 

func (x *Session) GetStats() *SessionStats

func (*Session) GetStatus 

func (x *Session) GetStatus() Session_State

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

func (x *Session) ProtoReflect() protoreflect.Message

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

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"`
	// contains filtered or unexported fields
}

func (*SessionFilter) Descriptor deprecated 

func (*SessionFilter) Descriptor() ([]byte, []int)

Deprecated: Use SessionFilter.ProtoReflect.Descriptor instead.

func (*SessionFilter) GetNeighborIp 

func (x *SessionFilter) GetNeighborIp() *api.IP

func (*SessionFilter) GetVrfName 

func (x *SessionFilter) GetVrfName() string

func (*SessionFilter) ProtoMessage 

func (*SessionFilter) ProtoMessage()

func (*SessionFilter) ProtoReflect 

func (x *SessionFilter) ProtoReflect() protoreflect.Message

func (*SessionFilter) Reset 

func (x *SessionFilter) Reset()

func (*SessionFilter) String 

func (x *SessionFilter) String() string

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"`
	// contains filtered or unexported fields
}

func (*SessionStats) Descriptor deprecated 

func (*SessionStats) Descriptor() ([]byte, []int)

Deprecated: Use SessionStats.ProtoReflect.Descriptor instead.

func (*SessionStats) GetFlaps 

func (x *SessionStats) GetFlaps() uint64

func (*SessionStats) GetMessagesIn 

func (x *SessionStats) GetMessagesIn() uint64

func (*SessionStats) GetMessagesOut 

func (x *SessionStats) GetMessagesOut() uint64

func (*SessionStats) GetRoutesExported 

func (x *SessionStats) GetRoutesExported() uint64

func (*SessionStats) GetRoutesImported 

func (x *SessionStats) GetRoutesImported() uint64

func (*SessionStats) GetRoutesReceived 

func (x *SessionStats) GetRoutesReceived() uint64

func (*SessionStats) ProtoMessage 

func (*SessionStats) ProtoMessage()

func (*SessionStats) ProtoReflect 

func (x *SessionStats) ProtoReflect() protoreflect.Message

func (*SessionStats) Reset 

func (x *SessionStats) Reset()

func (*SessionStats) String 

func (x *SessionStats) String() string

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) Descriptor 

func (Session_State) Descriptor() protoreflect.EnumDescriptor

func (Session_State) Enum 

func (x Session_State) Enum() *Session_State

func (Session_State) EnumDescriptor deprecated 

func (Session_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Session_State.Descriptor instead.

func (Session_State) Number 

func (x Session_State) Number() protoreflect.EnumNumber

func (Session_State) String 

func (x Session_State) String() string

func (Session_State) Type 

func (Session_State) Type() protoreflect.EnumType

type UnimplementedBgpServiceServer 

type UnimplementedBgpServiceServer struct {
}

UnimplementedBgpServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBgpServiceServer) DumpRIBIn 

func (UnimplementedBgpServiceServer) DumpRIBIn(*DumpRIBRequest, BgpService_DumpRIBInServer) error

func (UnimplementedBgpServiceServer) DumpRIBOut 

func (UnimplementedBgpServiceServer) DumpRIBOut(*DumpRIBRequest, BgpService_DumpRIBOutServer) error

func (UnimplementedBgpServiceServer) ListSessions 

func (UnimplementedBgpServiceServer) ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)

type UnsafeBgpServiceServer 

type UnsafeBgpServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBgpServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BgpServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.