tracehub

package
v0.0.0-...-2572d14 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TraceHubService_TraceStream_FullMethodName   = "/hbf.v1.tracehub.TraceHubService/TraceStream"
	TraceHubService_FetchTraces_FullMethodName   = "/hbf.v1.tracehub.TraceHubService/FetchTraces"
	TraceHubService_SyncNftTables_FullMethodName = "/hbf.v1.tracehub.TraceHubService/SyncNftTables"
	TraceHubService_FetchNftTable_FullMethodName = "/hbf.v1.tracehub.TraceHubService/FetchNftTable"
)

Variables

View Source 
var File_tracehub_messages_proto protoreflect.FileDescriptor
View Source 
var File_tracehub_service_proto protoreflect.FileDescriptor
View Source 
var TraceHubService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hbf.v1.tracehub.TraceHubService",
	HandlerType: (*TraceHubServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FetchNftTable",
			Handler:    _TraceHubService_FetchNftTable_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TraceStream",
			Handler:       _TraceHubService_TraceStream_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "FetchTraces",
			Handler:       _TraceHubService_FetchTraces_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SyncNftTables",
			Handler:       _TraceHubService_SyncNftTables_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "tracehub/service.proto",
}

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

Functions

func RegisterTraceHubServiceServer 

func RegisterTraceHubServiceServer(s grpc.ServiceRegistrar, srv TraceHubServiceServer)

Types

type FetchNftTableQry 

type FetchNftTableQry struct {

	// Types that are assignable to Scoped:
	//
	//	*FetchNftTableQry_NoScope
	//	*FetchNftTableQry_ScopedByTableId
	Scoped isFetchNftTableQry_Scoped `protobuf_oneof:"scoped"`
	// contains filtered or unexported fields
}

func (*FetchNftTableQry) Descriptor deprecated 

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

Deprecated: Use FetchNftTableQry.ProtoReflect.Descriptor instead.

func (*FetchNftTableQry) GetNoScope 

func (x *FetchNftTableQry) GetNoScope() *FetchNftTableQry_All

func (*FetchNftTableQry) GetScoped 

func (m *FetchNftTableQry) GetScoped() isFetchNftTableQry_Scoped

func (*FetchNftTableQry) GetScopedByTableId 

func (x *FetchNftTableQry) GetScopedByTableId() *FetchNftTableQry_ByTableId

func (*FetchNftTableQry) ProtoMessage 

func (*FetchNftTableQry) ProtoMessage()

func (*FetchNftTableQry) ProtoReflect 

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

func (*FetchNftTableQry) Reset 

func (x *FetchNftTableQry) Reset()

func (*FetchNftTableQry) String 

func (x *FetchNftTableQry) String() string

type FetchNftTableQry_All 

type FetchNftTableQry_All struct {
	// contains filtered or unexported fields
}

func (*FetchNftTableQry_All) Descriptor deprecated 

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

Deprecated: Use FetchNftTableQry_All.ProtoReflect.Descriptor instead.

func (*FetchNftTableQry_All) ProtoMessage 

func (*FetchNftTableQry_All) ProtoMessage()

func (*FetchNftTableQry_All) ProtoReflect 

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

func (*FetchNftTableQry_All) Reset 

func (x *FetchNftTableQry_All) Reset()

func (*FetchNftTableQry_All) String 

func (x *FetchNftTableQry_All) String() string

type FetchNftTableQry_ByTableId 

type FetchNftTableQry_ByTableId struct {
	TableId []uint64 `protobuf:"varint,1,rep,packed,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchNftTableQry_ByTableId) Descriptor deprecated 

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

Deprecated: Use FetchNftTableQry_ByTableId.ProtoReflect.Descriptor instead.

func (*FetchNftTableQry_ByTableId) GetTableId 

func (x *FetchNftTableQry_ByTableId) GetTableId() []uint64

func (*FetchNftTableQry_ByTableId) ProtoMessage 

func (*FetchNftTableQry_ByTableId) ProtoMessage()

func (*FetchNftTableQry_ByTableId) ProtoReflect 

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

func (*FetchNftTableQry_ByTableId) Reset 

func (x *FetchNftTableQry_ByTableId) Reset()

func (*FetchNftTableQry_ByTableId) String 

func (x *FetchNftTableQry_ByTableId) String() string

type FetchNftTableQry_NoScope 

type FetchNftTableQry_NoScope struct {
	NoScope *FetchNftTableQry_All `protobuf:"bytes,1,opt,name=no_scope,json=noScope,proto3,oneof"`
}

type FetchNftTableQry_ScopedByTableId 

type FetchNftTableQry_ScopedByTableId struct {
	ScopedByTableId *FetchNftTableQry_ByTableId `protobuf:"bytes,2,opt,name=scoped_by_table_id,json=scopedByTableId,proto3,oneof"`
}

type FetchTrace 

type FetchTrace struct {

	// trace content
	Trace *Trace `protobuf:"bytes,1,opt,name=trace,proto3" json:"trace,omitempty"`
	// table id related to trace
	TableId uint64 `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	// trace creation time
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

FetchTrace: fetch trace from server

func (*FetchTrace) Descriptor deprecated 

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

Deprecated: Use FetchTrace.ProtoReflect.Descriptor instead.

func (*FetchTrace) GetTableId 

func (x *FetchTrace) GetTableId() uint64

func (*FetchTrace) GetTimestamp 

func (x *FetchTrace) GetTimestamp() *timestamppb.Timestamp

func (*FetchTrace) GetTrace 

func (x *FetchTrace) GetTrace() *Trace

func (*FetchTrace) ProtoMessage 

func (*FetchTrace) ProtoMessage()

func (*FetchTrace) ProtoReflect 

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

func (*FetchTrace) Reset 

func (x *FetchTrace) Reset()

func (*FetchTrace) String 

func (x *FetchTrace) String() string

type NftRuleInChain 

type NftRuleInChain struct {

	// nftables chain name
	ChainName string `protobuf:"bytes,1,opt,name=chain_name,json=chainName,proto3" json:"chain_name,omitempty"`
	// rule expression
	Rule string `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"`
	// contains filtered or unexported fields
}

NftRuleInChain: rule to chain

func (*NftRuleInChain) Descriptor deprecated 

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

Deprecated: Use NftRuleInChain.ProtoReflect.Descriptor instead.

func (*NftRuleInChain) GetChainName 

func (x *NftRuleInChain) GetChainName() string

func (*NftRuleInChain) GetRule 

func (x *NftRuleInChain) GetRule() string

func (*NftRuleInChain) ProtoMessage 

func (*NftRuleInChain) ProtoMessage()

func (*NftRuleInChain) ProtoReflect 

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

func (*NftRuleInChain) Reset 

func (x *NftRuleInChain) Reset()

func (*NftRuleInChain) String 

func (x *NftRuleInChain) String() string

type NftTable 

type NftTable struct {

	// nftables table name
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// protocols family
	TableFamily string `protobuf:"bytes,2,opt,name=table_family,json=tableFamily,proto3" json:"table_family,omitempty"`
	// nftables table represented as string
	TableStr string `protobuf:"bytes,3,opt,name=table_str,json=tableStr,proto3" json:"table_str,omitempty"`
	// nftables rules items
	Rules []*NftRuleInChain `protobuf:"bytes,4,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

NftTable: nft tables transmitted to server from client

func (*NftTable) Descriptor deprecated 

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

Deprecated: Use NftTable.ProtoReflect.Descriptor instead.

func (*NftTable) GetRules 

func (x *NftTable) GetRules() []*NftRuleInChain

func (*NftTable) GetTableFamily 

func (x *NftTable) GetTableFamily() string

func (*NftTable) GetTableName 

func (x *NftTable) GetTableName() string

func (*NftTable) GetTableStr 

func (x *NftTable) GetTableStr() string

func (*NftTable) ProtoMessage 

func (*NftTable) ProtoMessage()

func (*NftTable) ProtoReflect 

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

func (*NftTable) Reset 

func (x *NftTable) Reset()

func (*NftTable) String 

func (x *NftTable) String() string

type NftTableList 

type NftTableList struct {

	// fetched tables
	Tables []*NftTableResp `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*NftTableList) Descriptor deprecated 

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

Deprecated: Use NftTableList.ProtoReflect.Descriptor instead.

func (*NftTableList) GetTables 

func (x *NftTableList) GetTables() []*NftTableResp

func (*NftTableList) ProtoMessage 

func (*NftTableList) ProtoMessage()

func (*NftTableList) ProtoReflect 

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

func (*NftTableList) Reset 

func (x *NftTableList) Reset()

func (*NftTableList) String 

func (x *NftTableList) String() string

type NftTableResp 

type NftTableResp struct {

	// table id
	TableId uint64 `protobuf:"varint,1,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	// nftables table represented as string
	TableStr string `protobuf:"bytes,2,opt,name=table_str,json=tableStr,proto3" json:"table_str,omitempty"`
	// timestamp
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

NftTableResp: response nft table from server

func (*NftTableResp) Descriptor deprecated 

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

Deprecated: Use NftTableResp.ProtoReflect.Descriptor instead.

func (*NftTableResp) GetTableId 

func (x *NftTableResp) GetTableId() uint64

func (*NftTableResp) GetTableStr 

func (x *NftTableResp) GetTableStr() string

func (*NftTableResp) GetTimestamp 

func (x *NftTableResp) GetTimestamp() *timestamppb.Timestamp

func (*NftTableResp) ProtoMessage 

func (*NftTableResp) ProtoMessage()

func (*NftTableResp) ProtoReflect 

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

func (*NftTableResp) Reset 

func (x *NftTableResp) Reset()

func (*NftTableResp) String 

func (x *NftTableResp) String() string

type SyncTableReq 

type SyncTableReq struct {

	// nftables tables items
	Table []*NftTable `protobuf:"bytes,1,rep,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncTableReq) Descriptor deprecated 

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

Deprecated: Use SyncTableReq.ProtoReflect.Descriptor instead.

func (*SyncTableReq) GetTable 

func (x *SyncTableReq) GetTable() []*NftTable

func (*SyncTableReq) ProtoMessage 

func (*SyncTableReq) ProtoMessage()

func (*SyncTableReq) ProtoReflect 

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

func (*SyncTableReq) Reset 

func (x *SyncTableReq) Reset()

func (*SyncTableReq) String 

func (x *SyncTableReq) String() string

type TimeRange 

type TimeRange struct {

	// time from
	From *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// time to
	To *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

TimeRange: represents time interval filter parameter

func (*TimeRange) Descriptor deprecated 

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

Deprecated: Use TimeRange.ProtoReflect.Descriptor instead.

func (*TimeRange) GetFrom 

func (x *TimeRange) GetFrom() *timestamppb.Timestamp

func (*TimeRange) GetTo 

func (x *TimeRange) GetTo() *timestamppb.Timestamp

func (*TimeRange) ProtoMessage 

func (*TimeRange) ProtoMessage()

func (*TimeRange) ProtoReflect 

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

func (*TimeRange) Reset 

func (x *TimeRange) Reset()

func (*TimeRange) String 

func (x *TimeRange) String() string

type Trace 

type Trace struct {

	// trace id
	TrId uint32 `protobuf:"varint,1,opt,name=tr_id,json=trId,proto3" json:"tr_id,omitempty"`
	// nftables table name
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// nftables chain name
	Chain string `protobuf:"bytes,3,opt,name=chain,proto3" json:"chain,omitempty"`
	// nftables jump to a target name
	JumpTarget string `protobuf:"bytes,4,opt,name=jump_target,json=jumpTarget,proto3" json:"jump_target,omitempty"`
	// nftables rule number
	RuleHandle uint64 `protobuf:"varint,5,opt,name=rule_handle,json=ruleHandle,proto3" json:"rule_handle,omitempty"`
	// protocols family
	Family string `protobuf:"bytes,6,opt,name=family,proto3" json:"family,omitempty"`
	// input network interface
	Iifname string `protobuf:"bytes,7,opt,name=iifname,proto3" json:"iifname,omitempty"`
	// output network interface
	Oifname string `protobuf:"bytes,8,opt,name=oifname,proto3" json:"oifname,omitempty"`
	// source mac address
	SMacAddr string `protobuf:"bytes,9,opt,name=s_mac_addr,json=sMacAddr,proto3" json:"s_mac_addr,omitempty"`
	// destination mac address
	DMacAddr string `protobuf:"bytes,10,opt,name=d_mac_addr,json=dMacAddr,proto3" json:"d_mac_addr,omitempty"`
	// source ip address
	SAddr string `protobuf:"bytes,11,opt,name=s_addr,json=sAddr,proto3" json:"s_addr,omitempty"`
	// destination ip address
	DAddr string `protobuf:"bytes,12,opt,name=d_addr,json=dAddr,proto3" json:"d_addr,omitempty"`
	// source port
	SPort uint32 `protobuf:"varint,13,opt,name=s_port,json=sPort,proto3" json:"s_port,omitempty"`
	// destination port
	DPort uint32 `protobuf:"varint,14,opt,name=d_port,json=dPort,proto3" json:"d_port,omitempty"`
	// length packet
	Length uint32 `protobuf:"varint,15,opt,name=length,proto3" json:"length,omitempty"`
	// ip protocol (tcp/udp/icmp/...)
	IpProto string `protobuf:"bytes,16,opt,name=ip_proto,json=ipProto,proto3" json:"ip_proto,omitempty"`
	// verdict for the rule
	Verdict string `protobuf:"bytes,17,opt,name=verdict,proto3" json:"verdict,omitempty"`
	// rule expression
	Rule string `protobuf:"bytes,18,opt,name=rule,proto3" json:"rule,omitempty"`
	// name of the security group for src ip
	SSgName string `protobuf:"bytes,19,opt,name=s_sg_name,json=sSgName,proto3" json:"s_sg_name,omitempty"`
	// name of the security group for dst ip
	DSgName string `protobuf:"bytes,20,opt,name=d_sg_name,json=dSgName,proto3" json:"d_sg_name,omitempty"`
	// name of the network for src ip
	SSgNet string `protobuf:"bytes,21,opt,name=s_sg_net,json=sSgNet,proto3" json:"s_sg_net,omitempty"`
	// name of the network for dst ip
	DSgNet string `protobuf:"bytes,22,opt,name=d_sg_net,json=dSgNet,proto3" json:"d_sg_net,omitempty"`
	// contains filtered or unexported fields
}

Trace: traces of network packets transmitted to the server

func (*Trace) Descriptor deprecated 

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

Deprecated: Use Trace.ProtoReflect.Descriptor instead.

func (*Trace) GetChain 

func (x *Trace) GetChain() string

func (*Trace) GetDAddr 

func (x *Trace) GetDAddr() string

func (*Trace) GetDMacAddr 

func (x *Trace) GetDMacAddr() string

func (*Trace) GetDPort 

func (x *Trace) GetDPort() uint32

func (*Trace) GetDSgName 

func (x *Trace) GetDSgName() string

func (*Trace) GetDSgNet 

func (x *Trace) GetDSgNet() string

func (*Trace) GetFamily 

func (x *Trace) GetFamily() string

func (*Trace) GetIifname 

func (x *Trace) GetIifname() string

func (*Trace) GetIpProto 

func (x *Trace) GetIpProto() string

func (*Trace) GetJumpTarget 

func (x *Trace) GetJumpTarget() string

func (*Trace) GetLength 

func (x *Trace) GetLength() uint32

func (*Trace) GetOifname 

func (x *Trace) GetOifname() string

func (*Trace) GetRule 

func (x *Trace) GetRule() string

func (*Trace) GetRuleHandle 

func (x *Trace) GetRuleHandle() uint64

func (*Trace) GetSAddr 

func (x *Trace) GetSAddr() string

func (*Trace) GetSMacAddr 

func (x *Trace) GetSMacAddr() string

func (*Trace) GetSPort 

func (x *Trace) GetSPort() uint32

func (*Trace) GetSSgName 

func (x *Trace) GetSSgName() string

func (*Trace) GetSSgNet 

func (x *Trace) GetSSgNet() string

func (*Trace) GetTable 

func (x *Trace) GetTable() string

func (*Trace) GetTrId 

func (x *Trace) GetTrId() uint32

func (*Trace) GetVerdict 

func (x *Trace) GetVerdict() string

func (*Trace) ProtoMessage 

func (*Trace) ProtoMessage()

func (*Trace) ProtoReflect 

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

func (*Trace) Reset 

func (x *Trace) Reset()

func (*Trace) String 

func (x *Trace) String() string

type TraceHubServiceClient 

type TraceHubServiceClient interface {
	TraceStream(ctx context.Context, opts ...grpc.CallOption) (TraceHubService_TraceStreamClient, error)
	FetchTraces(ctx context.Context, in *TraceScope, opts ...grpc.CallOption) (TraceHubService_FetchTracesClient, error)
	SyncNftTables(ctx context.Context, opts ...grpc.CallOption) (TraceHubService_SyncNftTablesClient, error)
	FetchNftTable(ctx context.Context, in *FetchNftTableQry, opts ...grpc.CallOption) (*NftTableList, error)
}

TraceHubServiceClient is the client API for TraceHubService 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 NewTraceHubServiceClient 

func NewTraceHubServiceClient(cc grpc.ClientConnInterface) TraceHubServiceClient

type TraceHubServiceServer 

type TraceHubServiceServer interface {
	TraceStream(TraceHubService_TraceStreamServer) error
	FetchTraces(*TraceScope, TraceHubService_FetchTracesServer) error
	SyncNftTables(TraceHubService_SyncNftTablesServer) error
	FetchNftTable(context.Context, *FetchNftTableQry) (*NftTableList, error)
	// contains filtered or unexported methods
}

TraceHubServiceServer is the server API for TraceHubService service. All implementations must embed UnimplementedTraceHubServiceServer for forward compatibility

type TraceHubService_FetchTracesClient 

type TraceHubService_FetchTracesClient interface {
	Recv() (*TraceList, error)
	grpc.ClientStream
}

type TraceHubService_FetchTracesServer 

type TraceHubService_FetchTracesServer interface {
	Send(*TraceList) error
	grpc.ServerStream
}

type TraceHubService_SyncNftTablesClient 

type TraceHubService_SyncNftTablesClient interface {
	Send(*SyncTableReq) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type TraceHubService_SyncNftTablesServer 

type TraceHubService_SyncNftTablesServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*SyncTableReq, error)
	grpc.ServerStream
}

type TraceHubService_TraceStreamClient 

type TraceHubService_TraceStreamClient interface {
	Send(*Traces) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type TraceHubService_TraceStreamServer 

type TraceHubService_TraceStreamServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*Traces, error)
	grpc.ServerStream
}

type TraceList 

type TraceList struct {
	Traces []*FetchTrace `protobuf:"bytes,1,rep,name=traces,proto3" json:"traces,omitempty"`
	// contains filtered or unexported fields
}

TraceList: represents list of traces fetched from server

func (*TraceList) Descriptor deprecated 

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

Deprecated: Use TraceList.ProtoReflect.Descriptor instead.

func (*TraceList) GetTraces 

func (x *TraceList) GetTraces() []*FetchTrace

func (*TraceList) ProtoMessage 

func (*TraceList) ProtoMessage()

func (*TraceList) ProtoReflect 

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

func (*TraceList) Reset 

func (x *TraceList) Reset()

func (*TraceList) String 

func (x *TraceList) String() string

type TraceScope 

type TraceScope struct {

	// trace id
	TrId []uint32 `protobuf:"varint,1,rep,packed,name=tr_id,json=trId,proto3" json:"tr_id,omitempty"`
	// nftables table name
	Table []string `protobuf:"bytes,2,rep,name=table,proto3" json:"table,omitempty"`
	// nftables chain name
	Chain []string `protobuf:"bytes,3,rep,name=chain,proto3" json:"chain,omitempty"`
	// nftables jump to a target name
	JumpTarget []string `protobuf:"bytes,4,rep,name=jump_target,json=jumpTarget,proto3" json:"jump_target,omitempty"`
	// nftables rule number
	RuleHandle []uint64 `protobuf:"varint,5,rep,packed,name=rule_handle,json=ruleHandle,proto3" json:"rule_handle,omitempty"`
	// protocols family
	Family []string `protobuf:"bytes,6,rep,name=family,proto3" json:"family,omitempty"`
	// input network interface
	Iifname []string `protobuf:"bytes,7,rep,name=iifname,proto3" json:"iifname,omitempty"`
	// output network interface
	Oifname []string `protobuf:"bytes,8,rep,name=oifname,proto3" json:"oifname,omitempty"`
	// source mac address
	SMacAddr []string `protobuf:"bytes,9,rep,name=s_mac_addr,json=sMacAddr,proto3" json:"s_mac_addr,omitempty"`
	// destination mac address
	DMacAddr []string `protobuf:"bytes,10,rep,name=d_mac_addr,json=dMacAddr,proto3" json:"d_mac_addr,omitempty"`
	// source ip address
	SAddr []string `protobuf:"bytes,11,rep,name=s_addr,json=sAddr,proto3" json:"s_addr,omitempty"`
	// destination ip address
	DAddr []string `protobuf:"bytes,12,rep,name=d_addr,json=dAddr,proto3" json:"d_addr,omitempty"`
	// source port
	SPort []uint32 `protobuf:"varint,13,rep,packed,name=s_port,json=sPort,proto3" json:"s_port,omitempty"`
	// destination port
	DPort []uint32 `protobuf:"varint,14,rep,packed,name=d_port,json=dPort,proto3" json:"d_port,omitempty"`
	// length packet
	Length []uint32 `protobuf:"varint,15,rep,packed,name=length,proto3" json:"length,omitempty"`
	// ip protocol (tcp/udp/icmp/...)
	IpProto []string `protobuf:"bytes,16,rep,name=ip_proto,json=ipProto,proto3" json:"ip_proto,omitempty"`
	// verdict for the rule
	Verdict []string `protobuf:"bytes,17,rep,name=verdict,proto3" json:"verdict,omitempty"`
	// rule expression
	Rule []string `protobuf:"bytes,18,rep,name=rule,proto3" json:"rule,omitempty"`
	// name of the security group for src ip
	SSgName []string `protobuf:"bytes,19,rep,name=s_sg_name,json=sSgName,proto3" json:"s_sg_name,omitempty"`
	// name of the security group for dst ip
	DSgName []string `protobuf:"bytes,20,rep,name=d_sg_name,json=dSgName,proto3" json:"d_sg_name,omitempty"`
	// name of the network for src ip
	SSgNet []string `protobuf:"bytes,21,rep,name=s_sg_net,json=sSgNet,proto3" json:"s_sg_net,omitempty"`
	// name of the network for dst ip
	DSgNet []string `protobuf:"bytes,22,rep,name=d_sg_net,json=dSgNet,proto3" json:"d_sg_net,omitempty"`
	// follow mode on/off
	FollowMode bool `protobuf:"varint,23,opt,name=follow_mode,json=followMode,proto3" json:"follow_mode,omitempty"`
	// time interval filter parameter
	Time *TimeRange `protobuf:"bytes,24,opt,name=time,proto3" json:"time,omitempty"`
	// complex query filter parameter
	Query string `protobuf:"bytes,25,opt,name=query,proto3" json:"query,omitempty"`
	// list of visor agents identifiers
	AgentsIds []string `protobuf:"bytes,26,rep,name=agents_ids,json=agentsIds,proto3" json:"agents_ids,omitempty"`
	// contains filtered or unexported fields
}

TraceScope -

func (*TraceScope) Descriptor deprecated 

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

Deprecated: Use TraceScope.ProtoReflect.Descriptor instead.

func (*TraceScope) GetAgentsIds 

func (x *TraceScope) GetAgentsIds() []string

func (*TraceScope) GetChain 

func (x *TraceScope) GetChain() []string

func (*TraceScope) GetDAddr 

func (x *TraceScope) GetDAddr() []string

func (*TraceScope) GetDMacAddr 

func (x *TraceScope) GetDMacAddr() []string

func (*TraceScope) GetDPort 

func (x *TraceScope) GetDPort() []uint32

func (*TraceScope) GetDSgName 

func (x *TraceScope) GetDSgName() []string

func (*TraceScope) GetDSgNet 

func (x *TraceScope) GetDSgNet() []string

func (*TraceScope) GetFamily 

func (x *TraceScope) GetFamily() []string

func (*TraceScope) GetFollowMode 

func (x *TraceScope) GetFollowMode() bool

func (*TraceScope) GetIifname 

func (x *TraceScope) GetIifname() []string

func (*TraceScope) GetIpProto 

func (x *TraceScope) GetIpProto() []string

func (*TraceScope) GetJumpTarget 

func (x *TraceScope) GetJumpTarget() []string

func (*TraceScope) GetLength 

func (x *TraceScope) GetLength() []uint32

func (*TraceScope) GetOifname 

func (x *TraceScope) GetOifname() []string

func (*TraceScope) GetQuery 

func (x *TraceScope) GetQuery() string

func (*TraceScope) GetRule 

func (x *TraceScope) GetRule() []string

func (*TraceScope) GetRuleHandle 

func (x *TraceScope) GetRuleHandle() []uint64

func (*TraceScope) GetSAddr 

func (x *TraceScope) GetSAddr() []string

func (*TraceScope) GetSMacAddr 

func (x *TraceScope) GetSMacAddr() []string

func (*TraceScope) GetSPort 

func (x *TraceScope) GetSPort() []uint32

func (*TraceScope) GetSSgName 

func (x *TraceScope) GetSSgName() []string

func (*TraceScope) GetSSgNet 

func (x *TraceScope) GetSSgNet() []string

func (*TraceScope) GetTable 

func (x *TraceScope) GetTable() []string

func (*TraceScope) GetTime 

func (x *TraceScope) GetTime() *TimeRange

func (*TraceScope) GetTrId 

func (x *TraceScope) GetTrId() []uint32

func (*TraceScope) GetVerdict 

func (x *TraceScope) GetVerdict() []string

func (*TraceScope) ProtoMessage 

func (*TraceScope) ProtoMessage()

func (*TraceScope) ProtoReflect 

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

func (*TraceScope) Reset 

func (x *TraceScope) Reset()

func (*TraceScope) String 

func (x *TraceScope) String() string

type Traces 

type Traces struct {

	// trace items
	Traces []*Trace `protobuf:"bytes,1,rep,name=traces,proto3" json:"traces,omitempty"`
	// contains filtered or unexported fields
}

Traces: represents subject of traces

func (*Traces) Descriptor deprecated 

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

Deprecated: Use Traces.ProtoReflect.Descriptor instead.

func (*Traces) GetTraces 

func (x *Traces) GetTraces() []*Trace

func (*Traces) ProtoMessage 

func (*Traces) ProtoMessage()

func (*Traces) ProtoReflect 

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

func (*Traces) Reset 

func (x *Traces) Reset()

func (*Traces) String 

func (x *Traces) String() string

type UnimplementedTraceHubServiceServer 

type UnimplementedTraceHubServiceServer struct {
}

UnimplementedTraceHubServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTraceHubServiceServer) FetchNftTable 

func (UnimplementedTraceHubServiceServer) FetchNftTable(context.Context, *FetchNftTableQry) (*NftTableList, error)

func (UnimplementedTraceHubServiceServer) FetchTraces 

func (UnimplementedTraceHubServiceServer) FetchTraces(*TraceScope, TraceHubService_FetchTracesServer) error

func (UnimplementedTraceHubServiceServer) SyncNftTables 

func (UnimplementedTraceHubServiceServer) SyncNftTables(TraceHubService_SyncNftTablesServer) error

func (UnimplementedTraceHubServiceServer) TraceStream 

func (UnimplementedTraceHubServiceServer) TraceStream(TraceHubService_TraceStreamServer) error

type UnsafeTraceHubServiceServer 

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

UnsafeTraceHubServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TraceHubServiceServer 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.