bgpmonv2

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: May 16, 2019 License: BSD-2-Clause Imports: 7 Imported by: 7

Documentation

Overview

Package bgpmonv2 is a generated protocol buffer package.

It is generated from these files: 

github.com/CSUNetSec/netsec-protobufs/bgpmon/v2/bgpmon.proto

It has these top-level messages: 

Empty
RunModuleRequest
RunModuleReply
CloseModuleRequest
ModuleInfo
ListAvailableModulesReply
OpenModuleInfo
ListOpenModulesReply
SessionType
SessionInfoRequest
SessionInfoReply
ListAvailableSessionsReply
CloseSessionRequest
ListOpenSessionsReply
OpenSessionRequest
OpenSessionReply
WriteRequest
WriteReply
GetRequest
Filter
GetReply
BGPCapture
Entity

Index

Constants

This section is empty.

Variables

View Source 
var Filter_FilterType_name = map[int32]string{
	0: "ORIGIN_AS",
	1: "PREFIXEXACT",
	2: "PREFIXINCLUDED",
}
View Source 
var Filter_FilterType_value = map[string]int32{
	"ORIGIN_AS":      0,
	"PREFIXEXACT":    1,
	"PREFIXINCLUDED": 2,
}
View Source 
var GetRequest_Type_name = map[int32]string{
	0: "CAPTURE",
	1: "PREFIX",
	2: "ASPATH",
	3: "ENTITY",
}
View Source 
var GetRequest_Type_value = map[string]int32{
	"CAPTURE": 0,
	"PREFIX":  1,
	"ASPATH":  2,
	"ENTITY":  3,
}
View Source 
var WriteRequest_Type_name = map[int32]string{
	0: "BGP_CAPTURE",
	1: "ENTITY",
}
View Source 
var WriteRequest_Type_value = map[string]int32{
	"BGP_CAPTURE": 0,
	"ENTITY":      1,
}

Functions

func RegisterBgpmondServer 

func RegisterBgpmondServer(s *grpc.Server, srv BgpmondServer)

Types

type BGPCapture 

type BGPCapture struct {
	Timestamp      uint32                   `protobuf:"varint,1,opt,name=timestamp" json:"timestamp,omitempty"`
	Peer_AS        uint32                   `protobuf:"varint,2,opt,name=peer_AS,json=peerAS" json:"peer_AS,omitempty"`
	Local_AS       uint32                   `protobuf:"varint,3,opt,name=local_AS,json=localAS" json:"local_AS,omitempty"`
	InterfaceIndex uint32                   `protobuf:"varint,4,opt,name=interface_index,json=interfaceIndex" json:"interface_index,omitempty"`
	AddressFamily  uint32                   `protobuf:"varint,5,opt,name=address_family,json=addressFamily" json:"address_family,omitempty"`
	Peer_IP        *common.IPAddressWrapper `protobuf:"bytes,6,opt,name=peer_IP,json=peerIP" json:"peer_IP,omitempty"`
	Local_IP       *common.IPAddressWrapper `protobuf:"bytes,7,opt,name=local_IP,json=localIP" json:"local_IP,omitempty"`
	Update         *bgp.BGPUpdate           `protobuf:"bytes,8,opt,name=update" json:"update,omitempty"`
}

BGPCaprure messages facilitate the represtation of a BGP Update from multuple sources (live/mrt etc) to bgpmon and other systems. the inner actual update is defined in protocol/bgp

func (*BGPCapture) Descriptor 

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

func (*BGPCapture) GetAddressFamily 

func (m *BGPCapture) GetAddressFamily() uint32

func (*BGPCapture) GetInterfaceIndex 

func (m *BGPCapture) GetInterfaceIndex() uint32

func (*BGPCapture) GetLocal_AS added in v0.1.4 

func (m *BGPCapture) GetLocal_AS() uint32

func (*BGPCapture) GetLocal_IP added in v0.1.4 

func (m *BGPCapture) GetLocal_IP() *common.IPAddressWrapper

func (*BGPCapture) GetPeer_AS added in v0.1.4 

func (m *BGPCapture) GetPeer_AS() uint32

func (*BGPCapture) GetPeer_IP added in v0.1.4 

func (m *BGPCapture) GetPeer_IP() *common.IPAddressWrapper

func (*BGPCapture) GetTimestamp 

func (m *BGPCapture) GetTimestamp() uint32

func (*BGPCapture) GetUpdate 

func (m *BGPCapture) GetUpdate() *bgp.BGPUpdate

func (*BGPCapture) ProtoMessage 

func (*BGPCapture) ProtoMessage()

func (*BGPCapture) Reset 

func (m *BGPCapture) Reset()

func (*BGPCapture) String 

func (m *BGPCapture) String() string

type BgpmondClient 

type BgpmondClient interface {
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*Empty, error)
	ListOpenSessions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListOpenSessionsReply, error)
	ListAvailableSessions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListAvailableSessionsReply, error)
	OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionReply, error)
	Write(ctx context.Context, opts ...grpc.CallOption) (Bgpmond_WriteClient, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (Bgpmond_GetClient, error)
	GetSessionInfo(ctx context.Context, in *SessionInfoRequest, opts ...grpc.CallOption) (*SessionInfoReply, error)
	RunModule(ctx context.Context, in *RunModuleRequest, opts ...grpc.CallOption) (*RunModuleReply, error)
	CloseModule(ctx context.Context, in *CloseModuleRequest, opts ...grpc.CallOption) (*Empty, error)
	ListAvailableModules(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListAvailableModulesReply, error)
	ListOpenModules(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListOpenModulesReply, error)
}

func NewBgpmondClient 

func NewBgpmondClient(cc *grpc.ClientConn) BgpmondClient

type BgpmondServer 

type BgpmondServer interface {
	CloseSession(context.Context, *CloseSessionRequest) (*Empty, error)
	ListOpenSessions(context.Context, *Empty) (*ListOpenSessionsReply, error)
	ListAvailableSessions(context.Context, *Empty) (*ListAvailableSessionsReply, error)
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionReply, error)
	Write(Bgpmond_WriteServer) error
	Get(*GetRequest, Bgpmond_GetServer) error
	GetSessionInfo(context.Context, *SessionInfoRequest) (*SessionInfoReply, error)
	RunModule(context.Context, *RunModuleRequest) (*RunModuleReply, error)
	CloseModule(context.Context, *CloseModuleRequest) (*Empty, error)
	ListAvailableModules(context.Context, *Empty) (*ListAvailableModulesReply, error)
	ListOpenModules(context.Context, *Empty) (*ListOpenModulesReply, error)
}

type Bgpmond_GetClient 

type Bgpmond_GetClient interface {
	Recv() (*GetReply, error)
	grpc.ClientStream
}

type Bgpmond_GetServer 

type Bgpmond_GetServer interface {
	Send(*GetReply) error
	grpc.ServerStream
}

type Bgpmond_WriteClient 

type Bgpmond_WriteClient interface {
	Send(*WriteRequest) error
	CloseAndRecv() (*WriteReply, error)
	grpc.ClientStream
}

type Bgpmond_WriteServer 

type Bgpmond_WriteServer interface {
	SendAndClose(*WriteReply) error
	Recv() (*WriteRequest, error)
	grpc.ServerStream
}

type CloseModuleRequest added in v0.1.3 

type CloseModuleRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

CloseModuleRequest messages contain the ID of the module that is requested to be closed.

func (*CloseModuleRequest) Descriptor added in v0.1.3 

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

func (*CloseModuleRequest) GetId added in v0.1.3 

func (m *CloseModuleRequest) GetId() string

func (*CloseModuleRequest) ProtoMessage added in v0.1.3 

func (*CloseModuleRequest) ProtoMessage()

func (*CloseModuleRequest) Reset added in v0.1.3 

func (m *CloseModuleRequest) Reset()

func (*CloseModuleRequest) String added in v0.1.3 

func (m *CloseModuleRequest) String() string

type CloseSessionRequest 

type CloseSessionRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
}

CloseSessionRequest messages request the closing of session identified by ID.

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSessionId 

func (m *CloseSessionRequest) GetSessionId() string

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

type Empty 

type Empty struct {
}

Empty messages are used as return types for functions that don't need to return any data.

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

type Entity added in v0.1.5 

type Entity struct {
	// maximal field value = 4
	Name          string                  `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Email         string                  `protobuf:"bytes,2,opt,name=email" json:"email,omitempty"`
	OwnedOrigins  []int32                 `protobuf:"varint,3,rep,packed,name=ownedOrigins" json:"ownedOrigins,omitempty"`
	OwnedPrefixes []*common.PrefixWrapper `protobuf:"bytes,4,rep,name=ownedPrefixes" json:"ownedPrefixes,omitempty"`
}

func (*Entity) Descriptor added in v0.1.5 

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

func (*Entity) GetEmail added in v0.1.5 

func (m *Entity) GetEmail() string

func (*Entity) GetName added in v0.1.5 

func (m *Entity) GetName() string

func (*Entity) GetOwnedOrigins added in v0.1.5 

func (m *Entity) GetOwnedOrigins() []int32

func (*Entity) GetOwnedPrefixes added in v0.1.5 

func (m *Entity) GetOwnedPrefixes() []*common.PrefixWrapper

func (*Entity) ProtoMessage added in v0.1.5 

func (*Entity) ProtoMessage()

func (*Entity) Reset added in v0.1.5 

func (m *Entity) Reset()

func (*Entity) String added in v0.1.5 

func (m *Entity) String() string

type Filter added in v0.1.2 

type Filter struct {
	Type             Filter_FilterType `protobuf:"varint,1,opt,name=type,enum=bgpmonv2.Filter_FilterType" json:"type,omitempty"`
	Origin_AS        uint32            `protobuf:"varint,2,opt,name=origin_AS,json=originAS" json:"origin_AS,omitempty"`
	AdvertisedPrefix string            `protobuf:"bytes,3,opt,name=advertised_prefix,json=advertisedPrefix" json:"advertised_prefix,omitempty"`
	WithdrawnPrefix  string            `protobuf:"bytes,4,opt,name=withdrawn_prefix,json=withdrawnPrefix" json:"withdrawn_prefix,omitempty"`
}

Filter messages contain the type of filter that is to be run as well as field values that will be used to filter messages passed through the filter.

func (*Filter) Descriptor added in v0.1.2 

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

func (*Filter) GetAdvertisedPrefix added in v0.1.4 

func (m *Filter) GetAdvertisedPrefix() string

func (*Filter) GetOrigin_AS added in v0.1.4 

func (m *Filter) GetOrigin_AS() uint32

func (*Filter) GetType added in v0.1.2 

func (m *Filter) GetType() Filter_FilterType

func (*Filter) GetWithdrawnPrefix added in v0.1.2 

func (m *Filter) GetWithdrawnPrefix() string

func (*Filter) ProtoMessage added in v0.1.2 

func (*Filter) ProtoMessage()

func (*Filter) Reset added in v0.1.2 

func (m *Filter) Reset()

func (*Filter) String added in v0.1.2 

func (m *Filter) String() string

type Filter_FilterType added in v0.1.2 

type Filter_FilterType int32

maximal field value = 4 

const (
	Filter_ORIGIN_AS      Filter_FilterType = 0
	Filter_PREFIXEXACT    Filter_FilterType = 1
	Filter_PREFIXINCLUDED Filter_FilterType = 2
)

func (Filter_FilterType) EnumDescriptor added in v0.1.2 

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

func (Filter_FilterType) String added in v0.1.2 

func (x Filter_FilterType) String() string

type GetReply 

type GetReply struct {
	// maximal field value = 4
	Type       GetRequest_Type `protobuf:"varint,1,opt,name=type,enum=bgpmonv2.GetRequest_Type" json:"type,omitempty"`
	Error      string          `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	Incomplete bool            `protobuf:"varint,3,opt,name=incomplete" json:"incomplete,omitempty"`
	Chunk      [][]byte        `protobuf:"bytes,4,rep,name=chunk,proto3" json:"chunk,omitempty"`
}

GetReply carries chunks of a PBStream byte array. If it is incomplete then the client should read all the following messages until the incomplete flag is not set and then try to unmarshal the message. Also the Type once an incomplete stream starts has to remain the same accros all subsequent messages

func (*GetReply) Descriptor 

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

func (*GetReply) GetChunk added in v0.1.2 

func (m *GetReply) GetChunk() [][]byte

func (*GetReply) GetError added in v0.1.2 

func (m *GetReply) GetError() string

func (*GetReply) GetIncomplete added in v0.1.2 

func (m *GetReply) GetIncomplete() bool

func (*GetReply) GetType 

func (m *GetReply) GetType() GetRequest_Type

func (*GetReply) ProtoMessage 

func (*GetReply) ProtoMessage()

func (*GetReply) Reset 

func (m *GetReply) Reset()

func (*GetReply) String 

func (m *GetReply) String() string

type GetRequest 

type GetRequest struct {
	Type           GetRequest_Type `protobuf:"varint,1,opt,name=type,enum=bgpmonv2.GetRequest_Type" json:"type,omitempty"`
	SessionId      string          `protobuf:"bytes,2,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
	Filters        []*Filter       `protobuf:"bytes,3,rep,name=filters" json:"filters,omitempty"`
	CollectorName  string          `protobuf:"bytes,4,opt,name=collector_name,json=collectorName" json:"collector_name,omitempty"`
	StartTimestamp uint64          `protobuf:"varint,5,opt,name=start_timestamp,json=startTimestamp" json:"start_timestamp,omitempty"`
	EndTimestamp   uint64          `protobuf:"varint,6,opt,name=end_timestamp,json=endTimestamp" json:"end_timestamp,omitempty"`
}

GetRequest messages contain the type of the messages that the user wishes to have returned, the session ID on which the request should be performed, the filters associated and the collector name and relevant time range for the query.

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetCollectorName added in v0.1.2 

func (m *GetRequest) GetCollectorName() string

func (*GetRequest) GetEndTimestamp 

func (m *GetRequest) GetEndTimestamp() uint64

func (*GetRequest) GetFilters added in v0.1.2 

func (m *GetRequest) GetFilters() []*Filter

func (*GetRequest) GetSessionId 

func (m *GetRequest) GetSessionId() string

func (*GetRequest) GetStartTimestamp 

func (m *GetRequest) GetStartTimestamp() uint64

func (*GetRequest) GetType 

func (m *GetRequest) GetType() GetRequest_Type

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

type GetRequest_Type 

type GetRequest_Type int32
const (
	GetRequest_CAPTURE GetRequest_Type = 0
	GetRequest_PREFIX  GetRequest_Type = 1
	GetRequest_ASPATH  GetRequest_Type = 2
	GetRequest_ENTITY  GetRequest_Type = 3
)

func (GetRequest_Type) EnumDescriptor 

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

func (GetRequest_Type) String 

func (x GetRequest_Type) String() string

type ListAvailableModulesReply added in v0.1.3 

type ListAvailableModulesReply struct {
	AvailableModules []*ModuleInfo `protobuf:"bytes,1,rep,name=available_modules,json=availableModules" json:"available_modules,omitempty"`
}

ListAvailableModulesReply messages contain an array of ModuleInfo message for available modules.

func (*ListAvailableModulesReply) Descriptor added in v0.1.3 

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

func (*ListAvailableModulesReply) GetAvailableModules added in v0.1.3 

func (m *ListAvailableModulesReply) GetAvailableModules() []*ModuleInfo

func (*ListAvailableModulesReply) ProtoMessage added in v0.1.3 

func (*ListAvailableModulesReply) ProtoMessage()

func (*ListAvailableModulesReply) Reset added in v0.1.3 

func (m *ListAvailableModulesReply) Reset()

func (*ListAvailableModulesReply) String added in v0.1.3 

func (m *ListAvailableModulesReply) String() string

type ListAvailableSessionsReply 

type ListAvailableSessionsReply struct {
	AvailableSessions []*SessionType `protobuf:"bytes,1,rep,name=available_sessions,json=availableSessions" json:"available_sessions,omitempty"`
}

ListAvailableSessionsReply messages return an array of the available session type names.

func (*ListAvailableSessionsReply) Descriptor 

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

func (*ListAvailableSessionsReply) GetAvailableSessions 

func (m *ListAvailableSessionsReply) GetAvailableSessions() []*SessionType

func (*ListAvailableSessionsReply) ProtoMessage 

func (*ListAvailableSessionsReply) ProtoMessage()

func (*ListAvailableSessionsReply) Reset 

func (m *ListAvailableSessionsReply) Reset()

func (*ListAvailableSessionsReply) String 

func (m *ListAvailableSessionsReply) String() string

type ListOpenModulesReply added in v0.1.3 

type ListOpenModulesReply struct {
	OpenModules []*OpenModuleInfo `protobuf:"bytes,1,rep,name=open_modules,json=openModules" json:"open_modules,omitempty"`
}

ListOpenModulesReply messages contain an array of OpenModuleInfo messages for the currently open modules.

func (*ListOpenModulesReply) Descriptor added in v0.1.3 

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

func (*ListOpenModulesReply) GetOpenModules added in v0.1.3 

func (m *ListOpenModulesReply) GetOpenModules() []*OpenModuleInfo

func (*ListOpenModulesReply) ProtoMessage added in v0.1.3 

func (*ListOpenModulesReply) ProtoMessage()

func (*ListOpenModulesReply) Reset added in v0.1.3 

func (m *ListOpenModulesReply) Reset()

func (*ListOpenModulesReply) String added in v0.1.3 

func (m *ListOpenModulesReply) String() string

type ListOpenSessionsReply 

type ListOpenSessionsReply struct {
	SessionId []string `protobuf:"bytes,1,rep,name=session_id,json=sessionId" json:"session_id,omitempty"`
}

func (*ListOpenSessionsReply) Descriptor 

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

func (*ListOpenSessionsReply) GetSessionId 

func (m *ListOpenSessionsReply) GetSessionId() []string

func (*ListOpenSessionsReply) ProtoMessage 

func (*ListOpenSessionsReply) ProtoMessage()

func (*ListOpenSessionsReply) Reset 

func (m *ListOpenSessionsReply) Reset()

func (*ListOpenSessionsReply) String 

func (m *ListOpenSessionsReply) String() string

type ModuleInfo added in v0.1.3 

type ModuleInfo struct {
	Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Desc string `protobuf:"bytes,2,opt,name=desc" json:"desc,omitempty"`
	Opts string `protobuf:"bytes,3,opt,name=opts" json:"opts,omitempty"`
}

ModuleInfo messages contain the type, description and option strings for a module.

func (*ModuleInfo) Descriptor added in v0.1.3 

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

func (*ModuleInfo) GetDesc added in v0.1.3 

func (m *ModuleInfo) GetDesc() string

func (*ModuleInfo) GetOpts added in v0.1.3 

func (m *ModuleInfo) GetOpts() string

func (*ModuleInfo) GetType added in v0.1.3 

func (m *ModuleInfo) GetType() string

func (*ModuleInfo) ProtoMessage added in v0.1.3 

func (*ModuleInfo) ProtoMessage()

func (*ModuleInfo) Reset added in v0.1.3 

func (m *ModuleInfo) Reset()

func (*ModuleInfo) String added in v0.1.3 

func (m *ModuleInfo) String() string

type OpenModuleInfo added in v0.1.3 

type OpenModuleInfo struct {
	Type   string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
	Status string `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"`
}

OpenModuleInfo messages contain the type, ID and status of currently open modules.

func (*OpenModuleInfo) Descriptor added in v0.1.3 

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

func (*OpenModuleInfo) GetId added in v0.1.3 

func (m *OpenModuleInfo) GetId() string

func (*OpenModuleInfo) GetStatus added in v0.1.3 

func (m *OpenModuleInfo) GetStatus() string

func (*OpenModuleInfo) GetType added in v0.1.3 

func (m *OpenModuleInfo) GetType() string

func (*OpenModuleInfo) ProtoMessage added in v0.1.3 

func (*OpenModuleInfo) ProtoMessage()

func (*OpenModuleInfo) Reset added in v0.1.3 

func (m *OpenModuleInfo) Reset()

func (*OpenModuleInfo) String added in v0.1.3 

func (m *OpenModuleInfo) String() string

type OpenSessionReply 

type OpenSessionReply struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
}

OpenSessionReply message return the ID of the session that was just opened.

func (*OpenSessionReply) Descriptor 

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

func (*OpenSessionReply) GetSessionId 

func (m *OpenSessionReply) GetSessionId() string

func (*OpenSessionReply) ProtoMessage 

func (*OpenSessionReply) ProtoMessage()

func (*OpenSessionReply) Reset 

func (m *OpenSessionReply) Reset()

func (*OpenSessionReply) String 

func (m *OpenSessionReply) String() string

type OpenSessionRequest 

type OpenSessionRequest struct {
	SessionName string `protobuf:"bytes,1,opt,name=session_name,json=sessionName" json:"session_name,omitempty"`
	SessionId   string `protobuf:"bytes,2,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
	Workers     uint32 `protobuf:"varint,3,opt,name=workers" json:"workers,omitempty"`
}

OpenSessionRequest messages request the opening of a session of a type named session_name, with an ID of session_id and the specified amount of worker threads.

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetSessionId 

func (m *OpenSessionRequest) GetSessionId() string

func (*OpenSessionRequest) GetSessionName 

func (m *OpenSessionRequest) GetSessionName() string

func (*OpenSessionRequest) GetWorkers 

func (m *OpenSessionRequest) GetWorkers() uint32

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

type RunModuleReply added in v0.1.3 

type RunModuleReply struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

RunModuleReply messages contain the ID of the module that was just set to run.

func (*RunModuleReply) Descriptor added in v0.1.3 

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

func (*RunModuleReply) GetId added in v0.1.3 

func (m *RunModuleReply) GetId() string

func (*RunModuleReply) ProtoMessage added in v0.1.3 

func (*RunModuleReply) ProtoMessage()

func (*RunModuleReply) Reset added in v0.1.3 

func (m *RunModuleReply) Reset()

func (*RunModuleReply) String added in v0.1.3 

func (m *RunModuleReply) String() string

type RunModuleRequest added in v0.1.3 

type RunModuleRequest struct {
	Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Id   string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
	Args string `protobuf:"bytes,3,opt,name=args" json:"args,omitempty"`
}

RunModuleRequest messages contain the type of the module that is requested to run , the ID and the arguments it should be invoked with.

func (*RunModuleRequest) Descriptor added in v0.1.3 

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

func (*RunModuleRequest) GetArgs added in v0.1.3 

func (m *RunModuleRequest) GetArgs() string

func (*RunModuleRequest) GetId added in v0.1.3 

func (m *RunModuleRequest) GetId() string

func (*RunModuleRequest) GetType added in v0.1.3 

func (m *RunModuleRequest) GetType() string

func (*RunModuleRequest) ProtoMessage added in v0.1.3 

func (*RunModuleRequest) ProtoMessage()

func (*RunModuleRequest) Reset added in v0.1.3 

func (m *RunModuleRequest) Reset()

func (*RunModuleRequest) String added in v0.1.3 

func (m *RunModuleRequest) String() string

type SessionInfoReply added in v0.1.2 

type SessionInfoReply struct {
	Type      *SessionType `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	SessionId string       `protobuf:"bytes,2,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
	Workers   uint32       `protobuf:"varint,3,opt,name=workers" json:"workers,omitempty"`
}

SessionInfoReply messages contain the type and the configured number of workers for that session ID.

func (*SessionInfoReply) Descriptor added in v0.1.2 

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

func (*SessionInfoReply) GetSessionId added in v0.1.2 

func (m *SessionInfoReply) GetSessionId() string

func (*SessionInfoReply) GetType added in v0.1.2 

func (m *SessionInfoReply) GetType() *SessionType

func (*SessionInfoReply) GetWorkers added in v0.1.2 

func (m *SessionInfoReply) GetWorkers() uint32

func (*SessionInfoReply) ProtoMessage added in v0.1.2 

func (*SessionInfoReply) ProtoMessage()

func (*SessionInfoReply) Reset added in v0.1.2 

func (m *SessionInfoReply) Reset()

func (*SessionInfoReply) String added in v0.1.2 

func (m *SessionInfoReply) String() string

type SessionInfoRequest added in v0.1.2 

type SessionInfoRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
}

SessionInfoRequest messages contain the ID of the session on which more info is requested on.

func (*SessionInfoRequest) Descriptor added in v0.1.2 

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

func (*SessionInfoRequest) GetSessionId added in v0.1.2 

func (m *SessionInfoRequest) GetSessionId() string

func (*SessionInfoRequest) ProtoMessage added in v0.1.2 

func (*SessionInfoRequest) ProtoMessage()

func (*SessionInfoRequest) Reset added in v0.1.2 

func (m *SessionInfoRequest) Reset()

func (*SessionInfoRequest) String added in v0.1.2 

func (m *SessionInfoRequest) String() string

type SessionType 

type SessionType struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	Desc string `protobuf:"bytes,3,opt,name=desc" json:"desc,omitempty"`
}

SessionType message contain the name, type and description of a session.

func (*SessionType) Descriptor 

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

func (*SessionType) GetDesc 

func (m *SessionType) GetDesc() string

func (*SessionType) GetName 

func (m *SessionType) GetName() string

func (*SessionType) GetType 

func (m *SessionType) GetType() string

func (*SessionType) ProtoMessage 

func (*SessionType) ProtoMessage()

func (*SessionType) Reset 

func (m *SessionType) Reset()

func (*SessionType) String 

func (m *SessionType) String() string

type WriteReply added in v0.1.2 

type WriteReply struct {
	TotalMessages uint64 `protobuf:"varint,1,opt,name=totalMessages" json:"totalMessages,omitempty"`
	StartTime     uint64 `protobuf:"varint,2,opt,name=startTime" json:"startTime,omitempty"`
	EndTime       uint64 `protobuf:"varint,3,opt,name=endTime" json:"endTime,omitempty"`
	NumWorkers    uint32 `protobuf:"varint,4,opt,name=numWorkers" json:"numWorkers,omitempty"`
	Error         string `protobuf:"bytes,5,opt,name=error" json:"error,omitempty"`
}

WriteReply messages return the total number of messages written, the time range the request took , the number of workers used for the request as well as possible errors.

func (*WriteReply) Descriptor added in v0.1.2 

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

func (*WriteReply) GetEndTime added in v0.1.2 

func (m *WriteReply) GetEndTime() uint64

func (*WriteReply) GetError added in v0.1.2 

func (m *WriteReply) GetError() string

func (*WriteReply) GetNumWorkers added in v0.1.2 

func (m *WriteReply) GetNumWorkers() uint32

func (*WriteReply) GetStartTime added in v0.1.2 

func (m *WriteReply) GetStartTime() uint64

func (*WriteReply) GetTotalMessages added in v0.1.2 

func (m *WriteReply) GetTotalMessages() uint64

func (*WriteReply) ProtoMessage added in v0.1.2 

func (*WriteReply) ProtoMessage()

func (*WriteReply) Reset added in v0.1.2 

func (m *WriteReply) Reset()

func (*WriteReply) String added in v0.1.2 

func (m *WriteReply) String() string

type WriteRequest 

type WriteRequest struct {
	Type       WriteRequest_Type `protobuf:"varint,1,opt,name=type,enum=bgpmonv2.WriteRequest_Type" json:"type,omitempty"`
	SessionId  string            `protobuf:"bytes,2,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
	BgpCapture *BGPCapture       `protobuf:"bytes,3,opt,name=bgp_capture,json=bgpCapture" json:"bgp_capture,omitempty"`
	Entity     *Entity           `protobuf:"bytes,4,opt,name=entity" json:"entity,omitempty"`
}

WriteRequest messages contain the type of the submessage that is to be written as well as the session ID that this should be performed on.

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetBgpCapture 

func (m *WriteRequest) GetBgpCapture() *BGPCapture

func (*WriteRequest) GetEntity added in v0.1.5 

func (m *WriteRequest) GetEntity() *Entity

func (*WriteRequest) GetSessionId 

func (m *WriteRequest) GetSessionId() string

func (*WriteRequest) GetType 

func (m *WriteRequest) GetType() WriteRequest_Type

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

type WriteRequest_Type 

type WriteRequest_Type int32
const (
	WriteRequest_BGP_CAPTURE WriteRequest_Type = 0
	WriteRequest_ENTITY      WriteRequest_Type = 1
)

func (WriteRequest_Type) EnumDescriptor 

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

func (WriteRequest_Type) String 

func (x WriteRequest_Type) String() string

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.