bgpmon

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: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GetReply_Type_name = map[int32]string{
	0: "BGP_CAPTURE",
}
View Source 
var GetReply_Type_value = map[string]int32{
	"BGP_CAPTURE": 0,
}
View Source 
var GetRequest_Type_name = map[int32]string{
	0: "BGP_CAPTURE",
}
View Source 
var GetRequest_Type_value = map[string]int32{
	"BGP_CAPTURE": 0,
}
View Source 
var ModuleType_name = map[int32]string{
	0: "GOBGP_LINK",
	1: "PREFIX_BY_AS_NUMBER",
	2: "PREFIX_HIJACK",
	3: "LOOKING_GLASS",
}
View Source 
var ModuleType_value = map[string]int32{
	"GOBGP_LINK":          0,
	"PREFIX_BY_AS_NUMBER": 1,
	"PREFIX_HIJACK":       2,
	"LOOKING_GLASS":       3,
}
View Source 
var SessionType_name = map[int32]string{
	0: "CASSANDRA",
	1: "FILE",
	2: "COCKROACH",
	3: "SQLITE",
}
View Source 
var SessionType_value = map[string]int32{
	"CASSANDRA": 0,
	"FILE":      1,
	"COCKROACH": 2,
	"SQLITE":    3,
}
View Source 
var WriteRequest_Type_name = map[int32]string{
	0: "AS_NUMBER_LOCATION",
	2: "IP_ADDRESS_LOCATION",
	3: "PREFIX_LOCATION",
	4: "BGP_CAPTURE",
	5: "BGP_STATS",
}
View Source 
var WriteRequest_Type_value = map[string]int32{
	"AS_NUMBER_LOCATION":  0,
	"IP_ADDRESS_LOCATION": 2,
	"PREFIX_LOCATION":     3,
	"BGP_CAPTURE":         4,
	"BGP_STATS":           5,
}

Functions

func RegisterBgpmondServer 

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

Types

type ASNumberLocation 

type ASNumberLocation struct {
	AsNumber             uint32    `protobuf:"varint,1,opt,name=as_number,json=asNumber,proto3" json:"as_number,omitempty"`
	MeasureDate          string    `protobuf:"bytes,2,opt,name=measure_date,json=measureDate,proto3" json:"measure_date,omitempty"`
	Location             *Location `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
	Source               string    `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ASNumberLocation) Descriptor 

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

func (*ASNumberLocation) GetAsNumber 

func (m *ASNumberLocation) GetAsNumber() uint32

func (*ASNumberLocation) GetLocation 

func (m *ASNumberLocation) GetLocation() *Location

func (*ASNumberLocation) GetMeasureDate 

func (m *ASNumberLocation) GetMeasureDate() string

func (*ASNumberLocation) GetSource 

func (m *ASNumberLocation) GetSource() string

func (*ASNumberLocation) ProtoMessage 

func (*ASNumberLocation) ProtoMessage()

func (*ASNumberLocation) Reset 

func (m *ASNumberLocation) Reset()

func (*ASNumberLocation) String 

func (m *ASNumberLocation) String() string

func (*ASNumberLocation) XXX_DiscardUnknown added in v0.1.2 

func (m *ASNumberLocation) XXX_DiscardUnknown()

func (*ASNumberLocation) XXX_Marshal added in v0.1.2 

func (m *ASNumberLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ASNumberLocation) XXX_Merge added in v0.1.2 

func (dst *ASNumberLocation) XXX_Merge(src proto.Message)

func (*ASNumberLocation) XXX_Size added in v0.1.2 

func (m *ASNumberLocation) XXX_Size() int

func (*ASNumberLocation) XXX_Unmarshal added in v0.1.2 

func (m *ASNumberLocation) XXX_Unmarshal(b []byte) error

type BGPCapture 

type BGPCapture struct {
	Timestamp            uint32                   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	PeerAs               uint32                   `protobuf:"varint,2,opt,name=peer_as,json=peerAs,proto3" json:"peer_as,omitempty"`
	LocalAs              uint32                   `protobuf:"varint,3,opt,name=local_as,json=localAs,proto3" json:"local_as,omitempty"`
	InterfaceIndex       uint32                   `protobuf:"varint,4,opt,name=interface_index,json=interfaceIndex,proto3" json:"interface_index,omitempty"`
	AddressFamily        uint32                   `protobuf:"varint,5,opt,name=address_family,json=addressFamily,proto3" json:"address_family,omitempty"`
	PeerIp               *common.IPAddressWrapper `protobuf:"bytes,6,opt,name=peer_ip,json=peerIp,proto3" json:"peer_ip,omitempty"`
	LocalIp              *common.IPAddressWrapper `protobuf:"bytes,7,opt,name=local_ip,json=localIp,proto3" json:"local_ip,omitempty"`
	Update               *bgp.BGPUpdate           `protobuf:"bytes,8,opt,name=update,proto3" json:"update,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

a message of Capture type to 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) GetLocalAs 

func (m *BGPCapture) GetLocalAs() uint32

func (*BGPCapture) GetLocalIp 

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

func (*BGPCapture) GetPeerAs 

func (m *BGPCapture) GetPeerAs() uint32

func (*BGPCapture) GetPeerIp 

func (m *BGPCapture) GetPeerIp() *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

func (*BGPCapture) XXX_DiscardUnknown added in v0.1.2 

func (m *BGPCapture) XXX_DiscardUnknown()

func (*BGPCapture) XXX_Marshal added in v0.1.2 

func (m *BGPCapture) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BGPCapture) XXX_Merge added in v0.1.2 

func (dst *BGPCapture) XXX_Merge(src proto.Message)

func (*BGPCapture) XXX_Size added in v0.1.2 

func (m *BGPCapture) XXX_Size() int

func (*BGPCapture) XXX_Unmarshal added in v0.1.2 

func (m *BGPCapture) XXX_Unmarshal(b []byte) error

type BGPStats 

type BGPStats struct {
	CollectorIp          string            `protobuf:"bytes,1,opt,name=collector_ip,json=collectorIp,proto3" json:"collector_ip,omitempty"`
	TimeStartSecEpoch    uint64            `protobuf:"varint,2,opt,name=timeStartSecEpoch,proto3" json:"timeStartSecEpoch,omitempty"`
	DurationSec          uint32            `protobuf:"varint,3,opt,name=durationSec,proto3" json:"durationSec,omitempty"`
	MsgCounts            *Count            `protobuf:"bytes,4,opt,name=msgCounts,proto3" json:"msgCounts,omitempty"`
	DestAsToPrefixCounts map[string]*Count `` /* 181-byte string literal not displayed */
	DestAsToASPCounts    map[string]*Count `` /* 175-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*BGPStats) Descriptor 

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

func (*BGPStats) GetCollectorIp 

func (m *BGPStats) GetCollectorIp() string

func (*BGPStats) GetDestAsToASPCounts 

func (m *BGPStats) GetDestAsToASPCounts() map[string]*Count

func (*BGPStats) GetDestAsToPrefixCounts 

func (m *BGPStats) GetDestAsToPrefixCounts() map[string]*Count

func (*BGPStats) GetDurationSec 

func (m *BGPStats) GetDurationSec() uint32

func (*BGPStats) GetMsgCounts 

func (m *BGPStats) GetMsgCounts() *Count

func (*BGPStats) GetTimeStartSecEpoch 

func (m *BGPStats) GetTimeStartSecEpoch() uint64

func (*BGPStats) ProtoMessage 

func (*BGPStats) ProtoMessage()

func (*BGPStats) Reset 

func (m *BGPStats) Reset()

func (*BGPStats) String 

func (m *BGPStats) String() string

func (*BGPStats) XXX_DiscardUnknown added in v0.1.2 

func (m *BGPStats) XXX_DiscardUnknown()

func (*BGPStats) XXX_Marshal added in v0.1.2 

func (m *BGPStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BGPStats) XXX_Merge added in v0.1.2 

func (dst *BGPStats) XXX_Merge(src proto.Message)

func (*BGPStats) XXX_Size added in v0.1.2 

func (m *BGPStats) XXX_Size() int

func (*BGPStats) XXX_Unmarshal added in v0.1.2 

func (m *BGPStats) XXX_Unmarshal(b []byte) error

type BgpmondClient 

type BgpmondClient interface {
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*Empty, error)
	ListModules(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListModulesReply, error)
	ListSessions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListSessionsReply, error)
	RunModule(ctx context.Context, in *RunModuleRequest, opts ...grpc.CallOption) (*RunModuleReply, error)
	StartModule(ctx context.Context, in *StartModuleRequest, opts ...grpc.CallOption) (*StartModuleReply, error)
	StopModule(ctx context.Context, in *StopModuleRequest, opts ...grpc.CallOption) (*Empty, 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)
}

BgpmondClient is the client API for Bgpmond service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBgpmondClient 

func NewBgpmondClient(cc *grpc.ClientConn) BgpmondClient

type BgpmondServer 

type BgpmondServer interface {
	CloseSession(context.Context, *CloseSessionRequest) (*Empty, error)
	ListModules(context.Context, *Empty) (*ListModulesReply, error)
	ListSessions(context.Context, *Empty) (*ListSessionsReply, error)
	RunModule(context.Context, *RunModuleRequest) (*RunModuleReply, error)
	StartModule(context.Context, *StartModuleRequest) (*StartModuleReply, error)
	StopModule(context.Context, *StopModuleRequest) (*Empty, error)
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionReply, error)
	Write(Bgpmond_WriteServer) error
	Get(*GetRequest, Bgpmond_GetServer) error
}

BgpmondServer is the server API for Bgpmond service.

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() (*Empty, error)
	grpc.ClientStream
}

type Bgpmond_WriteServer 

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

type CassandraSession 

type CassandraSession struct {
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Hosts                []string `protobuf:"bytes,3,rep,name=hosts,proto3" json:"hosts,omitempty"`
	WorkerCount          uint32   `protobuf:"varint,4,opt,name=workerCount,proto3" json:"workerCount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CassandraSession) Descriptor 

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

func (*CassandraSession) GetHosts 

func (m *CassandraSession) GetHosts() []string

func (*CassandraSession) GetPassword 

func (m *CassandraSession) GetPassword() string

func (*CassandraSession) GetUsername 

func (m *CassandraSession) GetUsername() string

func (*CassandraSession) GetWorkerCount 

func (m *CassandraSession) GetWorkerCount() uint32

func (*CassandraSession) ProtoMessage 

func (*CassandraSession) ProtoMessage()

func (*CassandraSession) Reset 

func (m *CassandraSession) Reset()

func (*CassandraSession) String 

func (m *CassandraSession) String() string

func (*CassandraSession) XXX_DiscardUnknown added in v0.1.2 

func (m *CassandraSession) XXX_DiscardUnknown()

func (*CassandraSession) XXX_Marshal added in v0.1.2 

func (m *CassandraSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CassandraSession) XXX_Merge added in v0.1.2 

func (dst *CassandraSession) XXX_Merge(src proto.Message)

func (*CassandraSession) XXX_Size added in v0.1.2 

func (m *CassandraSession) XXX_Size() int

func (*CassandraSession) XXX_Unmarshal added in v0.1.2 

func (m *CassandraSession) XXX_Unmarshal(b []byte) error

type CloseSessionRequest 

type CloseSessionRequest struct {
	SessionId            string   `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Session Command Messages

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

func (*CloseSessionRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal added in v0.1.2 

func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseSessionRequest) XXX_Merge added in v0.1.2 

func (dst *CloseSessionRequest) XXX_Merge(src proto.Message)

func (*CloseSessionRequest) XXX_Size added in v0.1.2 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal added in v0.1.2 

func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error

type CockroachSession 

type CockroachSession struct {
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Hosts                []string `protobuf:"bytes,3,rep,name=hosts,proto3" json:"hosts,omitempty"`
	Port                 uint32   `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	WorkerCount          uint32   `protobuf:"varint,5,opt,name=workerCount,proto3" json:"workerCount,omitempty"`
	Certdir              string   `protobuf:"bytes,6,opt,name=certdir,proto3" json:"certdir,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CockroachSession) Descriptor 

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

func (*CockroachSession) GetCertdir 

func (m *CockroachSession) GetCertdir() string

func (*CockroachSession) GetHosts 

func (m *CockroachSession) GetHosts() []string

func (*CockroachSession) GetPassword 

func (m *CockroachSession) GetPassword() string

func (*CockroachSession) GetPort 

func (m *CockroachSession) GetPort() uint32

func (*CockroachSession) GetUsername 

func (m *CockroachSession) GetUsername() string

func (*CockroachSession) GetWorkerCount 

func (m *CockroachSession) GetWorkerCount() uint32

func (*CockroachSession) ProtoMessage 

func (*CockroachSession) ProtoMessage()

func (*CockroachSession) Reset 

func (m *CockroachSession) Reset()

func (*CockroachSession) String 

func (m *CockroachSession) String() string

func (*CockroachSession) XXX_DiscardUnknown added in v0.1.2 

func (m *CockroachSession) XXX_DiscardUnknown()

func (*CockroachSession) XXX_Marshal added in v0.1.2 

func (m *CockroachSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CockroachSession) XXX_Merge added in v0.1.2 

func (dst *CockroachSession) XXX_Merge(src proto.Message)

func (*CockroachSession) XXX_Size added in v0.1.2 

func (m *CockroachSession) XXX_Size() int

func (*CockroachSession) XXX_Unmarshal added in v0.1.2 

func (m *CockroachSession) XXX_Unmarshal(b []byte) error

type Count 

type Count struct {
	Count                map[string]uint32 `` /* 152-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Count) Descriptor 

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

func (*Count) GetCount 

func (m *Count) GetCount() map[string]uint32

func (*Count) ProtoMessage 

func (*Count) ProtoMessage()

func (*Count) Reset 

func (m *Count) Reset()

func (*Count) String 

func (m *Count) String() string

func (*Count) XXX_DiscardUnknown added in v0.1.2 

func (m *Count) XXX_DiscardUnknown()

func (*Count) XXX_Marshal added in v0.1.2 

func (m *Count) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Count) XXX_Merge added in v0.1.2 

func (dst *Count) XXX_Merge(src proto.Message)

func (*Count) XXX_Size added in v0.1.2 

func (m *Count) XXX_Size() int

func (*Count) XXX_Unmarshal added in v0.1.2 

func (m *Count) XXX_Unmarshal(b []byte) error

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Empty) XXX_DiscardUnknown added in v0.1.2 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal added in v0.1.2 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge added in v0.1.2 

func (dst *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size added in v0.1.2 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal added in v0.1.2 

func (m *Empty) XXX_Unmarshal(b []byte) error

type FileSession 

type FileSession struct {
	Filename             string   `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FileSession) Descriptor 

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

func (*FileSession) GetFilename 

func (m *FileSession) GetFilename() string

func (*FileSession) ProtoMessage 

func (*FileSession) ProtoMessage()

func (*FileSession) Reset 

func (m *FileSession) Reset()

func (*FileSession) String 

func (m *FileSession) String() string

func (*FileSession) XXX_DiscardUnknown added in v0.1.2 

func (m *FileSession) XXX_DiscardUnknown()

func (*FileSession) XXX_Marshal added in v0.1.2 

func (m *FileSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileSession) XXX_Merge added in v0.1.2 

func (dst *FileSession) XXX_Merge(src proto.Message)

func (*FileSession) XXX_Size added in v0.1.2 

func (m *FileSession) XXX_Size() int

func (*FileSession) XXX_Unmarshal added in v0.1.2 

func (m *FileSession) XXX_Unmarshal(b []byte) error

type GetReply 

type GetReply struct {
	Type                 GetReply_Type `protobuf:"varint,1,opt,name=type,proto3,enum=bgpmon.GetReply_Type" json:"type,omitempty"`
	Captures             []*BGPCapture `protobuf:"bytes,2,rep,name=captures,proto3" json:"captures,omitempty"`
	CollectionId         string        `protobuf:"bytes,3,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetReply) Descriptor 

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

func (*GetReply) GetCaptures 

func (m *GetReply) GetCaptures() []*BGPCapture

func (*GetReply) GetCollectionId 

func (m *GetReply) GetCollectionId() string

func (*GetReply) GetType 

func (m *GetReply) GetType() GetReply_Type

func (*GetReply) ProtoMessage 

func (*GetReply) ProtoMessage()

func (*GetReply) Reset 

func (m *GetReply) Reset()

func (*GetReply) String 

func (m *GetReply) String() string

func (*GetReply) XXX_DiscardUnknown added in v0.1.2 

func (m *GetReply) XXX_DiscardUnknown()

func (*GetReply) XXX_Marshal added in v0.1.2 

func (m *GetReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetReply) XXX_Merge added in v0.1.2 

func (dst *GetReply) XXX_Merge(src proto.Message)

func (*GetReply) XXX_Size added in v0.1.2 

func (m *GetReply) XXX_Size() int

func (*GetReply) XXX_Unmarshal added in v0.1.2 

func (m *GetReply) XXX_Unmarshal(b []byte) error

type GetReply_Type 

type GetReply_Type int32
const (
	GetReply_BGP_CAPTURE GetReply_Type = 0
)

func (GetReply_Type) EnumDescriptor 

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

func (GetReply_Type) String 

func (x GetReply_Type) String() string

type GetRequest 

type GetRequest struct {
	Type                 GetRequest_Type `protobuf:"varint,1,opt,name=type,proto3,enum=bgpmon.GetRequest_Type" json:"type,omitempty"`
	SessionId            string          `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	StartTimestamp       string          `protobuf:"bytes,3,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	EndTimestamp         string          `protobuf:"bytes,4,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Get Messages

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetEndTimestamp 

func (m *GetRequest) GetEndTimestamp() string

func (*GetRequest) GetSessionId 

func (m *GetRequest) GetSessionId() string

func (*GetRequest) GetStartTimestamp 

func (m *GetRequest) GetStartTimestamp() string

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

func (*GetRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal added in v0.1.2 

func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRequest) XXX_Merge added in v0.1.2 

func (dst *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size added in v0.1.2 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal added in v0.1.2 

func (m *GetRequest) XXX_Unmarshal(b []byte) error

type GetRequest_Type 

type GetRequest_Type int32
const (
	GetRequest_BGP_CAPTURE GetRequest_Type = 0
)

func (GetRequest_Type) EnumDescriptor 

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

func (GetRequest_Type) String 

func (x GetRequest_Type) String() string

type GoBGPLinkModule 

type GoBGPLinkModule struct {
	Address              string   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	OutSessionId         []string `protobuf:"bytes,2,rep,name=out_session_id,json=outSessionId,proto3" json:"out_session_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GoBGPLinkModule) Descriptor 

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

func (*GoBGPLinkModule) GetAddress 

func (m *GoBGPLinkModule) GetAddress() string

func (*GoBGPLinkModule) GetOutSessionId 

func (m *GoBGPLinkModule) GetOutSessionId() []string

func (*GoBGPLinkModule) ProtoMessage 

func (*GoBGPLinkModule) ProtoMessage()

func (*GoBGPLinkModule) Reset 

func (m *GoBGPLinkModule) Reset()

func (*GoBGPLinkModule) String 

func (m *GoBGPLinkModule) String() string

func (*GoBGPLinkModule) XXX_DiscardUnknown added in v0.1.2 

func (m *GoBGPLinkModule) XXX_DiscardUnknown()

func (*GoBGPLinkModule) XXX_Marshal added in v0.1.2 

func (m *GoBGPLinkModule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GoBGPLinkModule) XXX_Merge added in v0.1.2 

func (dst *GoBGPLinkModule) XXX_Merge(src proto.Message)

func (*GoBGPLinkModule) XXX_Size added in v0.1.2 

func (m *GoBGPLinkModule) XXX_Size() int

func (*GoBGPLinkModule) XXX_Unmarshal added in v0.1.2 

func (m *GoBGPLinkModule) XXX_Unmarshal(b []byte) error

type IPAddressLocation 

type IPAddressLocation struct {
	IpAddress            string    `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	MeasureDate          string    `protobuf:"bytes,2,opt,name=measure_date,json=measureDate,proto3" json:"measure_date,omitempty"`
	Location             *Location `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
	Source               string    `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*IPAddressLocation) Descriptor 

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

func (*IPAddressLocation) GetIpAddress 

func (m *IPAddressLocation) GetIpAddress() string

func (*IPAddressLocation) GetLocation 

func (m *IPAddressLocation) GetLocation() *Location

func (*IPAddressLocation) GetMeasureDate 

func (m *IPAddressLocation) GetMeasureDate() string

func (*IPAddressLocation) GetSource 

func (m *IPAddressLocation) GetSource() string

func (*IPAddressLocation) ProtoMessage 

func (*IPAddressLocation) ProtoMessage()

func (*IPAddressLocation) Reset 

func (m *IPAddressLocation) Reset()

func (*IPAddressLocation) String 

func (m *IPAddressLocation) String() string

func (*IPAddressLocation) XXX_DiscardUnknown added in v0.1.2 

func (m *IPAddressLocation) XXX_DiscardUnknown()

func (*IPAddressLocation) XXX_Marshal added in v0.1.2 

func (m *IPAddressLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IPAddressLocation) XXX_Merge added in v0.1.2 

func (dst *IPAddressLocation) XXX_Merge(src proto.Message)

func (*IPAddressLocation) XXX_Size added in v0.1.2 

func (m *IPAddressLocation) XXX_Size() int

func (*IPAddressLocation) XXX_Unmarshal added in v0.1.2 

func (m *IPAddressLocation) XXX_Unmarshal(b []byte) error

type IPPrefix 

type IPPrefix struct {
	PrefixIpAddress      string   `protobuf:"bytes,1,opt,name=prefix_ip_address,json=prefixIpAddress,proto3" json:"prefix_ip_address,omitempty"`
	PrefixMask           uint32   `protobuf:"varint,2,opt,name=prefix_mask,json=prefixMask,proto3" json:"prefix_mask,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IPPrefix) Descriptor 

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

func (*IPPrefix) GetPrefixIpAddress 

func (m *IPPrefix) GetPrefixIpAddress() string

func (*IPPrefix) GetPrefixMask 

func (m *IPPrefix) GetPrefixMask() uint32

func (*IPPrefix) ProtoMessage 

func (*IPPrefix) ProtoMessage()

func (*IPPrefix) Reset 

func (m *IPPrefix) Reset()

func (*IPPrefix) String 

func (m *IPPrefix) String() string

func (*IPPrefix) XXX_DiscardUnknown added in v0.1.2 

func (m *IPPrefix) XXX_DiscardUnknown()

func (*IPPrefix) XXX_Marshal added in v0.1.2 

func (m *IPPrefix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IPPrefix) XXX_Merge added in v0.1.2 

func (dst *IPPrefix) XXX_Merge(src proto.Message)

func (*IPPrefix) XXX_Size added in v0.1.2 

func (m *IPPrefix) XXX_Size() int

func (*IPPrefix) XXX_Unmarshal added in v0.1.2 

func (m *IPPrefix) XXX_Unmarshal(b []byte) error

type ListModulesReply 

type ListModulesReply struct {
	ModuleId             []string `protobuf:"bytes,1,rep,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Module Command Messages

func (*ListModulesReply) Descriptor 

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

func (*ListModulesReply) GetModuleId 

func (m *ListModulesReply) GetModuleId() []string

func (*ListModulesReply) ProtoMessage 

func (*ListModulesReply) ProtoMessage()

func (*ListModulesReply) Reset 

func (m *ListModulesReply) Reset()

func (*ListModulesReply) String 

func (m *ListModulesReply) String() string

func (*ListModulesReply) XXX_DiscardUnknown added in v0.1.2 

func (m *ListModulesReply) XXX_DiscardUnknown()

func (*ListModulesReply) XXX_Marshal added in v0.1.2 

func (m *ListModulesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListModulesReply) XXX_Merge added in v0.1.2 

func (dst *ListModulesReply) XXX_Merge(src proto.Message)

func (*ListModulesReply) XXX_Size added in v0.1.2 

func (m *ListModulesReply) XXX_Size() int

func (*ListModulesReply) XXX_Unmarshal added in v0.1.2 

func (m *ListModulesReply) XXX_Unmarshal(b []byte) error

type ListSessionsReply 

type ListSessionsReply struct {
	SessionId            []string `protobuf:"bytes,1,rep,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListSessionsReply) Descriptor 

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

func (*ListSessionsReply) GetSessionId 

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

func (*ListSessionsReply) ProtoMessage 

func (*ListSessionsReply) ProtoMessage()

func (*ListSessionsReply) Reset 

func (m *ListSessionsReply) Reset()

func (*ListSessionsReply) String 

func (m *ListSessionsReply) String() string

func (*ListSessionsReply) XXX_DiscardUnknown added in v0.1.2 

func (m *ListSessionsReply) XXX_DiscardUnknown()

func (*ListSessionsReply) XXX_Marshal added in v0.1.2 

func (m *ListSessionsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSessionsReply) XXX_Merge added in v0.1.2 

func (dst *ListSessionsReply) XXX_Merge(src proto.Message)

func (*ListSessionsReply) XXX_Size added in v0.1.2 

func (m *ListSessionsReply) XXX_Size() int

func (*ListSessionsReply) XXX_Unmarshal added in v0.1.2 

func (m *ListSessionsReply) XXX_Unmarshal(b []byte) error

type Location 

type Location struct {
	CountryCode          string   `protobuf:"bytes,1,opt,name=country_code,json=countryCode,proto3" json:"country_code,omitempty"`
	StateCode            string   `protobuf:"bytes,2,opt,name=state_code,json=stateCode,proto3" json:"state_code,omitempty"`
	City                 string   `protobuf:"bytes,3,opt,name=city,proto3" json:"city,omitempty"`
	Latitude             float64  `protobuf:"fixed64,4,opt,name=latitude,proto3" json:"latitude,omitempty"`
	Longitude            float64  `protobuf:"fixed64,5,opt,name=longitude,proto3" json:"longitude,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Location) Descriptor 

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

func (*Location) GetCity 

func (m *Location) GetCity() string

func (*Location) GetCountryCode 

func (m *Location) GetCountryCode() string

func (*Location) GetLatitude 

func (m *Location) GetLatitude() float64

func (*Location) GetLongitude 

func (m *Location) GetLongitude() float64

func (*Location) GetStateCode 

func (m *Location) GetStateCode() string

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

func (*Location) XXX_DiscardUnknown added in v0.1.2 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal added in v0.1.2 

func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Location) XXX_Merge added in v0.1.2 

func (dst *Location) XXX_Merge(src proto.Message)

func (*Location) XXX_Size added in v0.1.2 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal added in v0.1.2 

func (m *Location) XXX_Unmarshal(b []byte) error

type LookingGlassModule 

type LookingGlassModule struct {
	StartTime            int64    `protobuf:"varint,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              int64    `protobuf:"varint,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Prefixes             []string `protobuf:"bytes,3,rep,name=prefixes,proto3" json:"prefixes,omitempty"`
	Asns                 []uint32 `protobuf:"varint,4,rep,packed,name=asns,proto3" json:"asns,omitempty"`
	Peers                []string `protobuf:"bytes,5,rep,name=peers,proto3" json:"peers,omitempty"`
	SessionId            []string `protobuf:"bytes,6,rep,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookingGlassModule) Descriptor 

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

func (*LookingGlassModule) GetAsns 

func (m *LookingGlassModule) GetAsns() []uint32

func (*LookingGlassModule) GetEndTime 

func (m *LookingGlassModule) GetEndTime() int64

func (*LookingGlassModule) GetPeers 

func (m *LookingGlassModule) GetPeers() []string

func (*LookingGlassModule) GetPrefixes 

func (m *LookingGlassModule) GetPrefixes() []string

func (*LookingGlassModule) GetSessionId 

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

func (*LookingGlassModule) GetStartTime 

func (m *LookingGlassModule) GetStartTime() int64

func (*LookingGlassModule) ProtoMessage 

func (*LookingGlassModule) ProtoMessage()

func (*LookingGlassModule) Reset 

func (m *LookingGlassModule) Reset()

func (*LookingGlassModule) String 

func (m *LookingGlassModule) String() string

func (*LookingGlassModule) XXX_DiscardUnknown added in v0.1.2 

func (m *LookingGlassModule) XXX_DiscardUnknown()

func (*LookingGlassModule) XXX_Marshal added in v0.1.2 

func (m *LookingGlassModule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LookingGlassModule) XXX_Merge added in v0.1.2 

func (dst *LookingGlassModule) XXX_Merge(src proto.Message)

func (*LookingGlassModule) XXX_Size added in v0.1.2 

func (m *LookingGlassModule) XXX_Size() int

func (*LookingGlassModule) XXX_Unmarshal added in v0.1.2 

func (m *LookingGlassModule) XXX_Unmarshal(b []byte) error

type ModuleType 

type ModuleType int32

Module Messages 

const (
	ModuleType_GOBGP_LINK          ModuleType = 0
	ModuleType_PREFIX_BY_AS_NUMBER ModuleType = 1
	ModuleType_PREFIX_HIJACK       ModuleType = 2
	ModuleType_LOOKING_GLASS       ModuleType = 3
)

func (ModuleType) EnumDescriptor 

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

func (ModuleType) String 

func (x ModuleType) String() string

type OpenSessionReply 

type OpenSessionReply struct {
	SessionId            string   `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*OpenSessionReply) XXX_DiscardUnknown added in v0.1.2 

func (m *OpenSessionReply) XXX_DiscardUnknown()

func (*OpenSessionReply) XXX_Marshal added in v0.1.2 

func (m *OpenSessionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenSessionReply) XXX_Merge added in v0.1.2 

func (dst *OpenSessionReply) XXX_Merge(src proto.Message)

func (*OpenSessionReply) XXX_Size added in v0.1.2 

func (m *OpenSessionReply) XXX_Size() int

func (*OpenSessionReply) XXX_Unmarshal added in v0.1.2 

func (m *OpenSessionReply) XXX_Unmarshal(b []byte) error

type OpenSessionRequest 

type OpenSessionRequest struct {
	Type                 SessionType       `protobuf:"varint,1,opt,name=type,proto3,enum=bgpmon.SessionType" json:"type,omitempty"`
	SessionId            string            `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	CassandraSession     *CassandraSession `protobuf:"bytes,3,opt,name=cassandra_session,json=cassandraSession,proto3" json:"cassandra_session,omitempty"`
	FileSession          *FileSession      `protobuf:"bytes,4,opt,name=file_session,json=fileSession,proto3" json:"file_session,omitempty"`
	CockroachSession     *CockroachSession `protobuf:"bytes,5,opt,name=cockroach_session,json=cockroachSession,proto3" json:"cockroach_session,omitempty"`
	SqliteSession        *SqliteSession    `protobuf:"bytes,6,opt,name=sqlite_session,json=sqliteSession,proto3" json:"sqlite_session,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetCassandraSession 

func (m *OpenSessionRequest) GetCassandraSession() *CassandraSession

func (*OpenSessionRequest) GetCockroachSession 

func (m *OpenSessionRequest) GetCockroachSession() *CockroachSession

func (*OpenSessionRequest) GetFileSession 

func (m *OpenSessionRequest) GetFileSession() *FileSession

func (*OpenSessionRequest) GetSessionId 

func (m *OpenSessionRequest) GetSessionId() string

func (*OpenSessionRequest) GetSqliteSession 

func (m *OpenSessionRequest) GetSqliteSession() *SqliteSession

func (*OpenSessionRequest) GetType 

func (m *OpenSessionRequest) GetType() SessionType

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *OpenSessionRequest) XXX_DiscardUnknown()

func (*OpenSessionRequest) XXX_Marshal added in v0.1.2 

func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenSessionRequest) XXX_Merge added in v0.1.2 

func (dst *OpenSessionRequest) XXX_Merge(src proto.Message)

func (*OpenSessionRequest) XXX_Size added in v0.1.2 

func (m *OpenSessionRequest) XXX_Size() int

func (*OpenSessionRequest) XXX_Unmarshal added in v0.1.2 

func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error

type PrefixByAsNumberModule 

type PrefixByAsNumberModule struct {
	StartTime            int64    `protobuf:"varint,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              int64    `protobuf:"varint,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	InSessionId          []string `protobuf:"bytes,3,rep,name=in_session_id,json=inSessionId,proto3" json:"in_session_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrefixByAsNumberModule) Descriptor 

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

func (*PrefixByAsNumberModule) GetEndTime 

func (m *PrefixByAsNumberModule) GetEndTime() int64

func (*PrefixByAsNumberModule) GetInSessionId 

func (m *PrefixByAsNumberModule) GetInSessionId() []string

func (*PrefixByAsNumberModule) GetStartTime 

func (m *PrefixByAsNumberModule) GetStartTime() int64

func (*PrefixByAsNumberModule) ProtoMessage 

func (*PrefixByAsNumberModule) ProtoMessage()

func (*PrefixByAsNumberModule) Reset 

func (m *PrefixByAsNumberModule) Reset()

func (*PrefixByAsNumberModule) String 

func (m *PrefixByAsNumberModule) String() string

func (*PrefixByAsNumberModule) XXX_DiscardUnknown added in v0.1.2 

func (m *PrefixByAsNumberModule) XXX_DiscardUnknown()

func (*PrefixByAsNumberModule) XXX_Marshal added in v0.1.2 

func (m *PrefixByAsNumberModule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrefixByAsNumberModule) XXX_Merge added in v0.1.2 

func (dst *PrefixByAsNumberModule) XXX_Merge(src proto.Message)

func (*PrefixByAsNumberModule) XXX_Size added in v0.1.2 

func (m *PrefixByAsNumberModule) XXX_Size() int

func (*PrefixByAsNumberModule) XXX_Unmarshal added in v0.1.2 

func (m *PrefixByAsNumberModule) XXX_Unmarshal(b []byte) error

type PrefixHijackModule 

type PrefixHijackModule struct {
	PeriodicSeconds           int32    `protobuf:"varint,1,opt,name=periodic_seconds,json=periodicSeconds,proto3" json:"periodic_seconds,omitempty"`
	TimeoutSeconds            int32    `protobuf:"varint,2,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	InSessionId               []string `protobuf:"bytes,3,rep,name=in_session_id,json=inSessionId,proto3" json:"in_session_id,omitempty"`
	StartTimeSecondsFromEpoch int64    `` /* 143-byte string literal not displayed */
	LookbackDurationSeconds   int64    `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{} `json:"-"`
	XXX_unrecognized          []byte   `json:"-"`
	XXX_sizecache             int32    `json:"-"`
}

func (*PrefixHijackModule) Descriptor 

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

func (*PrefixHijackModule) GetInSessionId 

func (m *PrefixHijackModule) GetInSessionId() []string

func (*PrefixHijackModule) GetLookbackDurationSeconds 

func (m *PrefixHijackModule) GetLookbackDurationSeconds() int64

func (*PrefixHijackModule) GetPeriodicSeconds 

func (m *PrefixHijackModule) GetPeriodicSeconds() int32

func (*PrefixHijackModule) GetStartTimeSecondsFromEpoch 

func (m *PrefixHijackModule) GetStartTimeSecondsFromEpoch() int64

func (*PrefixHijackModule) GetTimeoutSeconds 

func (m *PrefixHijackModule) GetTimeoutSeconds() int32

func (*PrefixHijackModule) ProtoMessage 

func (*PrefixHijackModule) ProtoMessage()

func (*PrefixHijackModule) Reset 

func (m *PrefixHijackModule) Reset()

func (*PrefixHijackModule) String 

func (m *PrefixHijackModule) String() string

func (*PrefixHijackModule) XXX_DiscardUnknown added in v0.1.2 

func (m *PrefixHijackModule) XXX_DiscardUnknown()

func (*PrefixHijackModule) XXX_Marshal added in v0.1.2 

func (m *PrefixHijackModule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrefixHijackModule) XXX_Merge added in v0.1.2 

func (dst *PrefixHijackModule) XXX_Merge(src proto.Message)

func (*PrefixHijackModule) XXX_Size added in v0.1.2 

func (m *PrefixHijackModule) XXX_Size() int

func (*PrefixHijackModule) XXX_Unmarshal added in v0.1.2 

func (m *PrefixHijackModule) XXX_Unmarshal(b []byte) error

type PrefixLocation 

type PrefixLocation struct {
	Prefix               *IPPrefix `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	MeasureDate          string    `protobuf:"bytes,2,opt,name=measure_date,json=measureDate,proto3" json:"measure_date,omitempty"`
	Location             *Location `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
	Source               string    `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*PrefixLocation) Descriptor 

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

func (*PrefixLocation) GetLocation 

func (m *PrefixLocation) GetLocation() *Location

func (*PrefixLocation) GetMeasureDate 

func (m *PrefixLocation) GetMeasureDate() string

func (*PrefixLocation) GetPrefix 

func (m *PrefixLocation) GetPrefix() *IPPrefix

func (*PrefixLocation) GetSource 

func (m *PrefixLocation) GetSource() string

func (*PrefixLocation) ProtoMessage 

func (*PrefixLocation) ProtoMessage()

func (*PrefixLocation) Reset 

func (m *PrefixLocation) Reset()

func (*PrefixLocation) String 

func (m *PrefixLocation) String() string

func (*PrefixLocation) XXX_DiscardUnknown added in v0.1.2 

func (m *PrefixLocation) XXX_DiscardUnknown()

func (*PrefixLocation) XXX_Marshal added in v0.1.2 

func (m *PrefixLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrefixLocation) XXX_Merge added in v0.1.2 

func (dst *PrefixLocation) XXX_Merge(src proto.Message)

func (*PrefixLocation) XXX_Size added in v0.1.2 

func (m *PrefixLocation) XXX_Size() int

func (*PrefixLocation) XXX_Unmarshal added in v0.1.2 

func (m *PrefixLocation) XXX_Unmarshal(b []byte) error

type RunModuleReply 

type RunModuleReply struct {
	ModuleMessage        string   `protobuf:"bytes,3,opt,name=module_message,json=moduleMessage,proto3" json:"module_message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunModuleReply) Descriptor 

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

func (*RunModuleReply) GetModuleMessage 

func (m *RunModuleReply) GetModuleMessage() string

func (*RunModuleReply) ProtoMessage 

func (*RunModuleReply) ProtoMessage()

func (*RunModuleReply) Reset 

func (m *RunModuleReply) Reset()

func (*RunModuleReply) String 

func (m *RunModuleReply) String() string

func (*RunModuleReply) XXX_DiscardUnknown added in v0.1.2 

func (m *RunModuleReply) XXX_DiscardUnknown()

func (*RunModuleReply) XXX_Marshal added in v0.1.2 

func (m *RunModuleReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunModuleReply) XXX_Merge added in v0.1.2 

func (dst *RunModuleReply) XXX_Merge(src proto.Message)

func (*RunModuleReply) XXX_Size added in v0.1.2 

func (m *RunModuleReply) XXX_Size() int

func (*RunModuleReply) XXX_Unmarshal added in v0.1.2 

func (m *RunModuleReply) XXX_Unmarshal(b []byte) error

type RunModuleRequest 

type RunModuleRequest struct {
	Type                   ModuleType              `protobuf:"varint,1,opt,name=type,proto3,enum=bgpmon.ModuleType" json:"type,omitempty"`
	PrefixByAsNumberModule *PrefixByAsNumberModule `` /* 133-byte string literal not displayed */
	PrefixHijackModule     *PrefixHijackModule     `protobuf:"bytes,3,opt,name=prefix_hijack_module,json=prefixHijackModule,proto3" json:"prefix_hijack_module,omitempty"`
	LookingGlassModule     *LookingGlassModule     `protobuf:"bytes,4,opt,name=looking_glass_module,json=lookingGlassModule,proto3" json:"looking_glass_module,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}                `json:"-"`
	XXX_unrecognized       []byte                  `json:"-"`
	XXX_sizecache          int32                   `json:"-"`
}

func (*RunModuleRequest) Descriptor 

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

func (*RunModuleRequest) GetLookingGlassModule 

func (m *RunModuleRequest) GetLookingGlassModule() *LookingGlassModule

func (*RunModuleRequest) GetPrefixByAsNumberModule 

func (m *RunModuleRequest) GetPrefixByAsNumberModule() *PrefixByAsNumberModule

func (*RunModuleRequest) GetPrefixHijackModule 

func (m *RunModuleRequest) GetPrefixHijackModule() *PrefixHijackModule

func (*RunModuleRequest) GetType 

func (m *RunModuleRequest) GetType() ModuleType

func (*RunModuleRequest) ProtoMessage 

func (*RunModuleRequest) ProtoMessage()

func (*RunModuleRequest) Reset 

func (m *RunModuleRequest) Reset()

func (*RunModuleRequest) String 

func (m *RunModuleRequest) String() string

func (*RunModuleRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *RunModuleRequest) XXX_DiscardUnknown()

func (*RunModuleRequest) XXX_Marshal added in v0.1.2 

func (m *RunModuleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunModuleRequest) XXX_Merge added in v0.1.2 

func (dst *RunModuleRequest) XXX_Merge(src proto.Message)

func (*RunModuleRequest) XXX_Size added in v0.1.2 

func (m *RunModuleRequest) XXX_Size() int

func (*RunModuleRequest) XXX_Unmarshal added in v0.1.2 

func (m *RunModuleRequest) XXX_Unmarshal(b []byte) error

type SessionType 

type SessionType int32

Session Messages 

const (
	SessionType_CASSANDRA SessionType = 0
	SessionType_FILE      SessionType = 1
	SessionType_COCKROACH SessionType = 2
	SessionType_SQLITE    SessionType = 3
)

func (SessionType) EnumDescriptor 

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

func (SessionType) String 

func (x SessionType) String() string

type SqliteSession 

type SqliteSession struct {
	Filename             string   `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SqliteSession) Descriptor 

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

func (*SqliteSession) GetFilename 

func (m *SqliteSession) GetFilename() string

func (*SqliteSession) ProtoMessage 

func (*SqliteSession) ProtoMessage()

func (*SqliteSession) Reset 

func (m *SqliteSession) Reset()

func (*SqliteSession) String 

func (m *SqliteSession) String() string

func (*SqliteSession) XXX_DiscardUnknown added in v0.1.2 

func (m *SqliteSession) XXX_DiscardUnknown()

func (*SqliteSession) XXX_Marshal added in v0.1.2 

func (m *SqliteSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SqliteSession) XXX_Merge added in v0.1.2 

func (dst *SqliteSession) XXX_Merge(src proto.Message)

func (*SqliteSession) XXX_Size added in v0.1.2 

func (m *SqliteSession) XXX_Size() int

func (*SqliteSession) XXX_Unmarshal added in v0.1.2 

func (m *SqliteSession) XXX_Unmarshal(b []byte) error

type StartModuleReply 

type StartModuleReply struct {
	ModuleId             string   `protobuf:"bytes,3,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartModuleReply) Descriptor 

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

func (*StartModuleReply) GetModuleId 

func (m *StartModuleReply) GetModuleId() string

func (*StartModuleReply) ProtoMessage 

func (*StartModuleReply) ProtoMessage()

func (*StartModuleReply) Reset 

func (m *StartModuleReply) Reset()

func (*StartModuleReply) String 

func (m *StartModuleReply) String() string

func (*StartModuleReply) XXX_DiscardUnknown added in v0.1.2 

func (m *StartModuleReply) XXX_DiscardUnknown()

func (*StartModuleReply) XXX_Marshal added in v0.1.2 

func (m *StartModuleReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartModuleReply) XXX_Merge added in v0.1.2 

func (dst *StartModuleReply) XXX_Merge(src proto.Message)

func (*StartModuleReply) XXX_Size added in v0.1.2 

func (m *StartModuleReply) XXX_Size() int

func (*StartModuleReply) XXX_Unmarshal added in v0.1.2 

func (m *StartModuleReply) XXX_Unmarshal(b []byte) error

type StartModuleRequest 

type StartModuleRequest struct {
	Type                 ModuleType          `protobuf:"varint,1,opt,name=type,proto3,enum=bgpmon.ModuleType" json:"type,omitempty"`
	ModuleId             string              `protobuf:"bytes,2,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"`
	GobgpLinkModule      *GoBGPLinkModule    `protobuf:"bytes,3,opt,name=gobgp_link_module,json=gobgpLinkModule,proto3" json:"gobgp_link_module,omitempty"`
	PrefixHijackModule   *PrefixHijackModule `protobuf:"bytes,4,opt,name=prefix_hijack_module,json=prefixHijackModule,proto3" json:"prefix_hijack_module,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*StartModuleRequest) Descriptor 

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

func (*StartModuleRequest) GetGobgpLinkModule 

func (m *StartModuleRequest) GetGobgpLinkModule() *GoBGPLinkModule

func (*StartModuleRequest) GetModuleId 

func (m *StartModuleRequest) GetModuleId() string

func (*StartModuleRequest) GetPrefixHijackModule 

func (m *StartModuleRequest) GetPrefixHijackModule() *PrefixHijackModule

func (*StartModuleRequest) GetType 

func (m *StartModuleRequest) GetType() ModuleType

func (*StartModuleRequest) ProtoMessage 

func (*StartModuleRequest) ProtoMessage()

func (*StartModuleRequest) Reset 

func (m *StartModuleRequest) Reset()

func (*StartModuleRequest) String 

func (m *StartModuleRequest) String() string

func (*StartModuleRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *StartModuleRequest) XXX_DiscardUnknown()

func (*StartModuleRequest) XXX_Marshal added in v0.1.2 

func (m *StartModuleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartModuleRequest) XXX_Merge added in v0.1.2 

func (dst *StartModuleRequest) XXX_Merge(src proto.Message)

func (*StartModuleRequest) XXX_Size added in v0.1.2 

func (m *StartModuleRequest) XXX_Size() int

func (*StartModuleRequest) XXX_Unmarshal added in v0.1.2 

func (m *StartModuleRequest) XXX_Unmarshal(b []byte) error

type StopModuleRequest 

type StopModuleRequest struct {
	ModuleId             string   `protobuf:"bytes,1,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopModuleRequest) Descriptor 

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

func (*StopModuleRequest) GetModuleId 

func (m *StopModuleRequest) GetModuleId() string

func (*StopModuleRequest) ProtoMessage 

func (*StopModuleRequest) ProtoMessage()

func (*StopModuleRequest) Reset 

func (m *StopModuleRequest) Reset()

func (*StopModuleRequest) String 

func (m *StopModuleRequest) String() string

func (*StopModuleRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *StopModuleRequest) XXX_DiscardUnknown()

func (*StopModuleRequest) XXX_Marshal added in v0.1.2 

func (m *StopModuleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopModuleRequest) XXX_Merge added in v0.1.2 

func (dst *StopModuleRequest) XXX_Merge(src proto.Message)

func (*StopModuleRequest) XXX_Size added in v0.1.2 

func (m *StopModuleRequest) XXX_Size() int

func (*StopModuleRequest) XXX_Unmarshal added in v0.1.2 

func (m *StopModuleRequest) XXX_Unmarshal(b []byte) error

type WriteRequest 

type WriteRequest struct {
	Type                 WriteRequest_Type  `protobuf:"varint,1,opt,name=type,proto3,enum=bgpmon.WriteRequest_Type" json:"type,omitempty"`
	SessionId            string             `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	AsNumberLocation     *ASNumberLocation  `protobuf:"bytes,3,opt,name=as_number_location,json=asNumberLocation,proto3" json:"as_number_location,omitempty"`
	IpAddressLocation    *IPAddressLocation `protobuf:"bytes,5,opt,name=ip_address_location,json=ipAddressLocation,proto3" json:"ip_address_location,omitempty"`
	PrefixLocation       *PrefixLocation    `protobuf:"bytes,6,opt,name=prefix_location,json=prefixLocation,proto3" json:"prefix_location,omitempty"`
	BgpCapture           *BGPCapture        `protobuf:"bytes,7,opt,name=bgp_capture,json=bgpCapture,proto3" json:"bgp_capture,omitempty"`
	BgpStats             *BGPStats          `protobuf:"bytes,8,opt,name=bgp_stats,json=bgpStats,proto3" json:"bgp_stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Write Messages

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetAsNumberLocation 

func (m *WriteRequest) GetAsNumberLocation() *ASNumberLocation

func (*WriteRequest) GetBgpCapture 

func (m *WriteRequest) GetBgpCapture() *BGPCapture

func (*WriteRequest) GetBgpStats 

func (m *WriteRequest) GetBgpStats() *BGPStats

func (*WriteRequest) GetIpAddressLocation 

func (m *WriteRequest) GetIpAddressLocation() *IPAddressLocation

func (*WriteRequest) GetPrefixLocation 

func (m *WriteRequest) GetPrefixLocation() *PrefixLocation

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

func (*WriteRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal added in v0.1.2 

func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteRequest) XXX_Merge added in v0.1.2 

func (dst *WriteRequest) XXX_Merge(src proto.Message)

func (*WriteRequest) XXX_Size added in v0.1.2 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal added in v0.1.2 

func (m *WriteRequest) XXX_Unmarshal(b []byte) error

type WriteRequest_Type 

type WriteRequest_Type int32
const (
	WriteRequest_AS_NUMBER_LOCATION  WriteRequest_Type = 0
	WriteRequest_IP_ADDRESS_LOCATION WriteRequest_Type = 2
	WriteRequest_PREFIX_LOCATION     WriteRequest_Type = 3
	WriteRequest_BGP_CAPTURE         WriteRequest_Type = 4
	WriteRequest_BGP_STATS           WriteRequest_Type = 5
)

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

Directories

Path Synopsis
Package bgpmonv2 is a generated protocol buffer package.
 Package bgpmonv2 is a generated protocol buffer package.

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.