Documentation
¶
Overview ¶
Package agentv1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func RegisterAgentAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAgentAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentAPIClient) error
- func RegisterAgentAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAgentAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentAPIServer) error
- func RegisterAgentAPIServer(s grpc.ServiceRegistrar, srv AgentAPIServer)
- type AgentAPIClient
- type AgentAPIServer
- type AgentAPI_WatchNftablesClient
- type AgentAPI_WatchNftablesServer
- type AgentAPI_WatchSocketStatisticsClient
- type AgentAPI_WatchSocketStatisticsServer
- type ConnState
- type Nftables
- type NftablesReq
- type NftablesReq_List
- type NftablesReq_Watch
- type NftablesResp
- type NftablesResp_List
- func (*NftablesResp_List) Descriptor() ([]byte, []int)deprecated
- func (x *NftablesResp_List) GetNftables() []*Nftables
- func (*NftablesResp_List) ProtoMessage()
- func (x *NftablesResp_List) ProtoReflect() protoreflect.Message
- func (x *NftablesResp_List) Reset()
- func (x *NftablesResp_List) String() string
- type NftablesResp_Watch
- func (*NftablesResp_Watch) Descriptor() ([]byte, []int)deprecated
- func (x *NftablesResp_Watch) GetNftables() []*Nftables
- func (*NftablesResp_Watch) ProtoMessage()
- func (x *NftablesResp_Watch) ProtoReflect() protoreflect.Message
- func (x *NftablesResp_Watch) Reset()
- func (x *NftablesResp_Watch) String() string
- type ProcessInfo
- func (*ProcessInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessInfo) GetCmdLine() string
- func (x *ProcessInfo) GetComm() string
- func (x *ProcessInfo) GetExe() string
- func (x *ProcessInfo) GetFd() int32
- func (x *ProcessInfo) GetPid() int32
- func (*ProcessInfo) ProtoMessage()
- func (x *ProcessInfo) ProtoReflect() protoreflect.Message
- func (x *ProcessInfo) Reset()
- func (x *ProcessInfo) String() string
- type SockStat
- func (*SockStat) Descriptor() ([]byte, []int)deprecated
- func (x *SockStat) GetFamily() common.IpAddrFamily
- func (x *SockStat) GetIfname() string
- func (x *SockStat) GetInode() int64
- func (x *SockStat) GetLocalAddr() string
- func (x *SockStat) GetLocalPort() int32
- func (x *SockStat) GetProcesses() []*ProcessInfo
- func (x *SockStat) GetProtocol() string
- func (x *SockStat) GetRemoteAddr() string
- func (x *SockStat) GetRemotePort() int32
- func (x *SockStat) GetState() ConnState
- func (*SockStat) ProtoMessage()
- func (x *SockStat) ProtoReflect() protoreflect.Message
- func (x *SockStat) Reset()
- func (x *SockStat) String() string
- type SockStat_Selectors
- func (*SockStat_Selectors) Descriptor() ([]byte, []int)deprecated
- func (x *SockStat_Selectors) GetComm() string
- func (x *SockStat_Selectors) GetFamily() common.IpAddrFamily
- func (x *SockStat_Selectors) GetIfname() string
- func (x *SockStat_Selectors) GetInode() int64
- func (x *SockStat_Selectors) GetLocalAddr() string
- func (x *SockStat_Selectors) GetLocalPort() int32
- func (x *SockStat_Selectors) GetPid() int32
- func (x *SockStat_Selectors) GetProtocol() string
- func (x *SockStat_Selectors) GetRemoteAddr() string
- func (x *SockStat_Selectors) GetRemotePort() int32
- func (x *SockStat_Selectors) GetState() ConnState
- func (*SockStat_Selectors) ProtoMessage()
- func (x *SockStat_Selectors) ProtoReflect() protoreflect.Message
- func (x *SockStat_Selectors) Reset()
- func (x *SockStat_Selectors) String() string
- type SocketStatReq
- type SocketStatReq_List
- func (*SocketStatReq_List) Descriptor() ([]byte, []int)deprecated
- func (x *SocketStatReq_List) GetSelectors() []*SockStat_Selectors
- func (*SocketStatReq_List) ProtoMessage()
- func (x *SocketStatReq_List) ProtoReflect() protoreflect.Message
- func (x *SocketStatReq_List) Reset()
- func (x *SocketStatReq_List) String() string
- type SocketStatReq_Watch
- func (*SocketStatReq_Watch) Descriptor() ([]byte, []int)deprecated
- func (x *SocketStatReq_Watch) GetSelectors() []*SockStat_Selectors
- func (*SocketStatReq_Watch) ProtoMessage()
- func (x *SocketStatReq_Watch) ProtoReflect() protoreflect.Message
- func (x *SocketStatReq_Watch) Reset()
- func (x *SocketStatReq_Watch) String() string
- type SocketStatResp
- type SocketStatResp_List
- func (*SocketStatResp_List) Descriptor() ([]byte, []int)deprecated
- func (x *SocketStatResp_List) GetStats() []*SockStat
- func (*SocketStatResp_List) ProtoMessage()
- func (x *SocketStatResp_List) ProtoReflect() protoreflect.Message
- func (x *SocketStatResp_List) Reset()
- func (x *SocketStatResp_List) String() string
- type SocketStatResp_Watch
- func (*SocketStatResp_Watch) Descriptor() ([]byte, []int)deprecated
- func (x *SocketStatResp_Watch) GetStats() []*SockStat
- func (*SocketStatResp_Watch) ProtoMessage()
- func (x *SocketStatResp_Watch) ProtoReflect() protoreflect.Message
- func (x *SocketStatResp_Watch) Reset()
- func (x *SocketStatResp_Watch) String() string
- type UnimplementedAgentAPIServer
- func (UnimplementedAgentAPIServer) ListNftables(context.Context, *NftablesReq_List) (*NftablesResp_List, error)
- func (UnimplementedAgentAPIServer) ListSocketStatistics(context.Context, *SocketStatReq_List) (*SocketStatResp_List, error)
- func (UnimplementedAgentAPIServer) WatchNftables(*NftablesReq_Watch, grpc.ServerStreamingServer[NftablesResp_Watch]) error
- func (UnimplementedAgentAPIServer) WatchSocketStatistics(*SocketStatReq_Watch, grpc.ServerStreamingServer[SocketStatResp_Watch]) error
- type UnsafeAgentAPIServer
Constants ¶
const ( AgentAPI_ListSocketStatistics_FullMethodName = "/agent.v1.AgentAPI/ListSocketStatistics" AgentAPI_WatchSocketStatistics_FullMethodName = "/agent.v1.AgentAPI/WatchSocketStatistics" AgentAPI_ListNftables_FullMethodName = "/agent.v1.AgentAPI/ListNftables" AgentAPI_WatchNftables_FullMethodName = "/agent.v1.AgentAPI/WatchNftables" )
Variables ¶
var ( ConnState_name = map[int32]string{ 0: "CONN_UNDEF", 1: "ESTABLISHED", 2: "SYN_SENT", 3: "SYN_RECV", 4: "FIN_WAIT1", 5: "FIN_WAIT2", 6: "TIME_WAIT", 7: "CLOSE", 8: "CLOSE_WAIT", 9: "LAST_ACK", 10: "LISTEN", 11: "CLOSING", 12: "NEW_SYN_RECV", } ConnState_value = map[string]int32{ "CONN_UNDEF": 0, "ESTABLISHED": 1, "SYN_SENT": 2, "SYN_RECV": 3, "FIN_WAIT1": 4, "FIN_WAIT2": 5, "TIME_WAIT": 6, "CLOSE": 7, "CLOSE_WAIT": 8, "LAST_ACK": 9, "LISTEN": 10, "CLOSING": 11, "NEW_SYN_RECV": 12, } )
Enum value maps for ConnState.
var AgentAPI_ServiceDesc = grpc.ServiceDesc{ ServiceName: "agent.v1.AgentAPI", HandlerType: (*AgentAPIServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListSocketStatistics", Handler: _AgentAPI_ListSocketStatistics_Handler, }, { MethodName: "ListNftables", Handler: _AgentAPI_ListNftables_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "WatchSocketStatistics", Handler: _AgentAPI_WatchSocketStatistics_Handler, ServerStreams: true, }, { StreamName: "WatchNftables", Handler: _AgentAPI_WatchNftables_Handler, ServerStreams: true, }, }, Metadata: "agent/v1/services.proto", }
AgentAPI_ServiceDesc is the grpc.ServiceDesc for AgentAPI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_agent_v1_domains_proto protoreflect.FileDescriptor
var File_agent_v1_queries_proto protoreflect.FileDescriptor
var File_agent_v1_services_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAgentAPIHandler ¶
func RegisterAgentAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterAgentAPIHandler registers the http handlers for service AgentAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAgentAPIHandlerClient ¶
func RegisterAgentAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentAPIClient) error
RegisterAgentAPIHandlerClient registers the http handlers for service AgentAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AgentAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AgentAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AgentAPIClient" to call the correct interceptors. This client ignores the HTTP middlewares.
func RegisterAgentAPIHandlerFromEndpoint ¶
func RegisterAgentAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAgentAPIHandlerFromEndpoint is same as RegisterAgentAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAgentAPIHandlerServer ¶
func RegisterAgentAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentAPIServer) error
RegisterAgentAPIHandlerServer registers the http handlers for service AgentAPI to "mux". UnaryRPC :call AgentAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAgentAPIHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.
func RegisterAgentAPIServer ¶
func RegisterAgentAPIServer(s grpc.ServiceRegistrar, srv AgentAPIServer)
Types ¶
type AgentAPIClient ¶
type AgentAPIClient interface {
// ListSocketStatistics: list socket statistics
ListSocketStatistics(ctx context.Context, in *SocketStatReq_List, opts ...grpc.CallOption) (*SocketStatResp_List, error)
// WatchSocketStatistics: watch socket statistics
WatchSocketStatistics(ctx context.Context, in *SocketStatReq_Watch, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SocketStatResp_Watch], error)
// ListNftables: list nftables information
ListNftables(ctx context.Context, in *NftablesReq_List, opts ...grpc.CallOption) (*NftablesResp_List, error)
// WatchNftables: watch nftables information
WatchNftables(ctx context.Context, in *NftablesReq_Watch, opts ...grpc.CallOption) (grpc.ServerStreamingClient[NftablesResp_Watch], error)
}
AgentAPIClient is the client API for AgentAPI 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.
AgentAPI: defines the agent API service
func NewAgentAPIClient ¶
func NewAgentAPIClient(cc grpc.ClientConnInterface) AgentAPIClient
type AgentAPIServer ¶
type AgentAPIServer interface {
// ListSocketStatistics: list socket statistics
ListSocketStatistics(context.Context, *SocketStatReq_List) (*SocketStatResp_List, error)
// WatchSocketStatistics: watch socket statistics
WatchSocketStatistics(*SocketStatReq_Watch, grpc.ServerStreamingServer[SocketStatResp_Watch]) error
// ListNftables: list nftables information
ListNftables(context.Context, *NftablesReq_List) (*NftablesResp_List, error)
// WatchNftables: watch nftables information
WatchNftables(*NftablesReq_Watch, grpc.ServerStreamingServer[NftablesResp_Watch]) error
// contains filtered or unexported methods
}
AgentAPIServer is the server API for AgentAPI service. All implementations must embed UnimplementedAgentAPIServer for forward compatibility.
AgentAPI: defines the agent API service
type AgentAPI_WatchNftablesClient ¶
type AgentAPI_WatchNftablesClient = grpc.ServerStreamingClient[NftablesResp_Watch]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentAPI_WatchNftablesServer ¶
type AgentAPI_WatchNftablesServer = grpc.ServerStreamingServer[NftablesResp_Watch]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentAPI_WatchSocketStatisticsClient ¶
type AgentAPI_WatchSocketStatisticsClient = grpc.ServerStreamingClient[SocketStatResp_Watch]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentAPI_WatchSocketStatisticsServer ¶
type AgentAPI_WatchSocketStatisticsServer = grpc.ServerStreamingServer[SocketStatResp_Watch]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ConnState ¶
type ConnState int32
ConnState: represents connection state
const ( // CONN_UNDEF: undefined connection state ConnState_CONN_UNDEF ConnState = 0 // ESTABLISHED: connection is established ConnState_ESTABLISHED ConnState = 1 // SYN_SENT: connection is in SYN_SENT state ConnState_SYN_SENT ConnState = 2 // SYN_RECV: connection is in SYN_RECV state ConnState_SYN_RECV ConnState = 3 // FIN_WAIT1: connection is in FIN_WAIT1 state ConnState_FIN_WAIT1 ConnState = 4 // FIN_WAIT2: connection is in FIN_WAIT2 state ConnState_FIN_WAIT2 ConnState = 5 // TIME_WAIT: connection is in TIME_WAIT state ConnState_TIME_WAIT ConnState = 6 // CLOSE: connection is closed ConnState_CLOSE ConnState = 7 // CLOSE_WAIT: connection is in CLOSE_WAIT state ConnState_CLOSE_WAIT ConnState = 8 // LAST_ACK: connection is in LAST_ACK state ConnState_LAST_ACK ConnState = 9 // LISTEN: connection is in LISTEN state ConnState_LISTEN ConnState = 10 // CLOSING: connection is in CLOSING state ConnState_CLOSING ConnState = 11 // NEW_SYN_RECV: connection is in NEW_SYN_RECV state ConnState_NEW_SYN_RECV ConnState = 12 )
func (ConnState) Descriptor ¶
func (ConnState) Descriptor() protoreflect.EnumDescriptor
func (ConnState) EnumDescriptor
deprecated
func (ConnState) Number ¶
func (x ConnState) Number() protoreflect.EnumNumber
func (ConnState) Type ¶
func (ConnState) Type() protoreflect.EnumType
type Nftables ¶
type Nftables struct {
// Text: nftables information in text format
Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
// Json: nftables information in json format
Json string `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"`
// contains filtered or unexported fields
}
Nftables: represents nftables information
func (*Nftables) Descriptor
deprecated
func (*Nftables) ProtoMessage ¶
func (*Nftables) ProtoMessage()
func (*Nftables) ProtoReflect ¶
func (x *Nftables) ProtoReflect() protoreflect.Message
type NftablesReq ¶
type NftablesReq struct {
// contains filtered or unexported fields
}
NftablesReq: request for nftables information
func (*NftablesReq) Descriptor
deprecated
func (*NftablesReq) Descriptor() ([]byte, []int)
Deprecated: Use NftablesReq.ProtoReflect.Descriptor instead.
func (*NftablesReq) ProtoMessage ¶
func (*NftablesReq) ProtoMessage()
func (*NftablesReq) ProtoReflect ¶
func (x *NftablesReq) ProtoReflect() protoreflect.Message
func (*NftablesReq) Reset ¶
func (x *NftablesReq) Reset()
func (*NftablesReq) String ¶
func (x *NftablesReq) String() string
type NftablesReq_List ¶
type NftablesReq_List struct {
// contains filtered or unexported fields
}
List: request for listing nftables information
func (*NftablesReq_List) Descriptor
deprecated
func (*NftablesReq_List) Descriptor() ([]byte, []int)
Deprecated: Use NftablesReq_List.ProtoReflect.Descriptor instead.
func (*NftablesReq_List) ProtoMessage ¶
func (*NftablesReq_List) ProtoMessage()
func (*NftablesReq_List) ProtoReflect ¶
func (x *NftablesReq_List) ProtoReflect() protoreflect.Message
func (*NftablesReq_List) Reset ¶
func (x *NftablesReq_List) Reset()
func (*NftablesReq_List) String ¶
func (x *NftablesReq_List) String() string
type NftablesReq_Watch ¶
type NftablesReq_Watch struct {
// contains filtered or unexported fields
}
Watch: request for watching nftables information
func (*NftablesReq_Watch) Descriptor
deprecated
func (*NftablesReq_Watch) Descriptor() ([]byte, []int)
Deprecated: Use NftablesReq_Watch.ProtoReflect.Descriptor instead.
func (*NftablesReq_Watch) ProtoMessage ¶
func (*NftablesReq_Watch) ProtoMessage()
func (*NftablesReq_Watch) ProtoReflect ¶
func (x *NftablesReq_Watch) ProtoReflect() protoreflect.Message
func (*NftablesReq_Watch) Reset ¶
func (x *NftablesReq_Watch) Reset()
func (*NftablesReq_Watch) String ¶
func (x *NftablesReq_Watch) String() string
type NftablesResp ¶
type NftablesResp struct {
// contains filtered or unexported fields
}
NftablesResp: response for nftables information requests
func (*NftablesResp) Descriptor
deprecated
func (*NftablesResp) Descriptor() ([]byte, []int)
Deprecated: Use NftablesResp.ProtoReflect.Descriptor instead.
func (*NftablesResp) ProtoMessage ¶
func (*NftablesResp) ProtoMessage()
func (*NftablesResp) ProtoReflect ¶
func (x *NftablesResp) ProtoReflect() protoreflect.Message
func (*NftablesResp) Reset ¶
func (x *NftablesResp) Reset()
func (*NftablesResp) String ¶
func (x *NftablesResp) String() string
type NftablesResp_List ¶
type NftablesResp_List struct {
// Nftables: list of nftables information
Nftables []*Nftables `protobuf:"bytes,1,rep,name=nftables,proto3" json:"nftables,omitempty"`
// contains filtered or unexported fields
}
List: response for ListNftables
func (*NftablesResp_List) Descriptor
deprecated
func (*NftablesResp_List) Descriptor() ([]byte, []int)
Deprecated: Use NftablesResp_List.ProtoReflect.Descriptor instead.
func (*NftablesResp_List) GetNftables ¶
func (x *NftablesResp_List) GetNftables() []*Nftables
func (*NftablesResp_List) ProtoMessage ¶
func (*NftablesResp_List) ProtoMessage()
func (*NftablesResp_List) ProtoReflect ¶
func (x *NftablesResp_List) ProtoReflect() protoreflect.Message
func (*NftablesResp_List) Reset ¶
func (x *NftablesResp_List) Reset()
func (*NftablesResp_List) String ¶
func (x *NftablesResp_List) String() string
type NftablesResp_Watch ¶
type NftablesResp_Watch struct {
// Nftables: list of nftables information
Nftables []*Nftables `protobuf:"bytes,1,rep,name=nftables,proto3" json:"nftables,omitempty"`
// contains filtered or unexported fields
}
Watch: response for WatchNftables
func (*NftablesResp_Watch) Descriptor
deprecated
func (*NftablesResp_Watch) Descriptor() ([]byte, []int)
Deprecated: Use NftablesResp_Watch.ProtoReflect.Descriptor instead.
func (*NftablesResp_Watch) GetNftables ¶
func (x *NftablesResp_Watch) GetNftables() []*Nftables
func (*NftablesResp_Watch) ProtoMessage ¶
func (*NftablesResp_Watch) ProtoMessage()
func (*NftablesResp_Watch) ProtoReflect ¶
func (x *NftablesResp_Watch) ProtoReflect() protoreflect.Message
func (*NftablesResp_Watch) Reset ¶
func (x *NftablesResp_Watch) Reset()
func (*NftablesResp_Watch) String ¶
func (x *NftablesResp_Watch) String() string
type ProcessInfo ¶
type ProcessInfo struct {
// Pid: process ID
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
// Comm: process command name
Comm string `protobuf:"bytes,2,opt,name=comm,proto3" json:"comm,omitempty"`
// CmdLine: process command line
CmdLine string `protobuf:"bytes,3,opt,name=cmd_line,json=cmdLine,proto3" json:"cmd_line,omitempty"`
// Exe: process executable path
Exe string `protobuf:"bytes,4,opt,name=exe,proto3" json:"exe,omitempty"`
// Fd: process file descriptor associated with the socket
Fd int32 `protobuf:"varint,5,opt,name=fd,proto3" json:"fd,omitempty"`
// contains filtered or unexported fields
}
ProcessInfo: represents process information
func (*ProcessInfo) Descriptor
deprecated
func (*ProcessInfo) Descriptor() ([]byte, []int)
Deprecated: Use ProcessInfo.ProtoReflect.Descriptor instead.
func (*ProcessInfo) GetCmdLine ¶
func (x *ProcessInfo) GetCmdLine() string
func (*ProcessInfo) GetComm ¶
func (x *ProcessInfo) GetComm() string
func (*ProcessInfo) GetExe ¶
func (x *ProcessInfo) GetExe() string
func (*ProcessInfo) GetFd ¶
func (x *ProcessInfo) GetFd() int32
func (*ProcessInfo) GetPid ¶
func (x *ProcessInfo) GetPid() int32
func (*ProcessInfo) ProtoMessage ¶
func (*ProcessInfo) ProtoMessage()
func (*ProcessInfo) ProtoReflect ¶
func (x *ProcessInfo) ProtoReflect() protoreflect.Message
func (*ProcessInfo) Reset ¶
func (x *ProcessInfo) Reset()
func (*ProcessInfo) String ¶
func (x *ProcessInfo) String() string
type SockStat ¶
type SockStat struct {
// Protocol: socket protocol
Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
// Family: socket address family
Family common.IpAddrFamily `protobuf:"varint,2,opt,name=family,proto3,enum=common.IpAddrFamily" json:"family,omitempty"`
// State: connection state
State ConnState `protobuf:"varint,3,opt,name=state,proto3,enum=agent.v1.ConnState" json:"state,omitempty"`
// LocalAddr: local ip address
LocalAddr string `protobuf:"bytes,4,opt,name=local_addr,json=localAddr,proto3" json:"local_addr,omitempty"`
// LocalPort: local port
LocalPort int32 `protobuf:"varint,5,opt,name=local_port,json=localPort,proto3" json:"local_port,omitempty"`
// RemoteAddr: remote ip address
RemoteAddr string `protobuf:"bytes,6,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
// RemotePort: remote port
RemotePort int32 `protobuf:"varint,7,opt,name=remote_port,json=remotePort,proto3" json:"remote_port,omitempty"`
// Ifname: interface name
Ifname string `protobuf:"bytes,8,opt,name=ifname,proto3" json:"ifname,omitempty"`
// Inode: socket inode number
Inode int64 `protobuf:"varint,9,opt,name=inode,proto3" json:"inode,omitempty"`
// Processes: associated processes
Processes []*ProcessInfo `protobuf:"bytes,10,rep,name=processes,proto3" json:"processes,omitempty"`
// contains filtered or unexported fields
}
SockStat: represents socket statistics
func (*SockStat) Descriptor
deprecated
func (*SockStat) GetFamily ¶
func (x *SockStat) GetFamily() common.IpAddrFamily
func (*SockStat) GetLocalAddr ¶
func (*SockStat) GetLocalPort ¶
func (*SockStat) GetProcesses ¶
func (x *SockStat) GetProcesses() []*ProcessInfo
func (*SockStat) GetProtocol ¶
func (*SockStat) GetRemoteAddr ¶
func (*SockStat) GetRemotePort ¶
func (*SockStat) ProtoMessage ¶
func (*SockStat) ProtoMessage()
func (*SockStat) ProtoReflect ¶
func (x *SockStat) ProtoReflect() protoreflect.Message
type SockStat_Selectors ¶
type SockStat_Selectors struct {
// Protocol: socket protocol
Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
// Family: socket address family
Family common.IpAddrFamily `protobuf:"varint,2,opt,name=family,proto3,enum=common.IpAddrFamily" json:"family,omitempty"`
// State: connection state
State ConnState `protobuf:"varint,3,opt,name=state,proto3,enum=agent.v1.ConnState" json:"state,omitempty"`
// LocalAddr: local ip address
LocalAddr string `protobuf:"bytes,4,opt,name=local_addr,json=localAddr,proto3" json:"local_addr,omitempty"`
// LocalPort: local port
LocalPort *int32 `protobuf:"varint,5,opt,name=local_port,json=localPort,proto3,oneof" json:"local_port,omitempty"`
// RemoteAddr: remote ip address
RemoteAddr string `protobuf:"bytes,6,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
// RemotePort: remote port
RemotePort *int32 `protobuf:"varint,7,opt,name=remote_port,json=remotePort,proto3,oneof" json:"remote_port,omitempty"`
// Ifname: interface name
Ifname string `protobuf:"bytes,8,opt,name=ifname,proto3" json:"ifname,omitempty"`
// Inode: socket inode number
Inode *int64 `protobuf:"varint,9,opt,name=inode,proto3,oneof" json:"inode,omitempty"`
// Pid: process ID
Pid *int32 `protobuf:"varint,10,opt,name=pid,proto3,oneof" json:"pid,omitempty"`
// Comm: process command name
Comm string `protobuf:"bytes,11,opt,name=comm,proto3" json:"comm,omitempty"`
// contains filtered or unexported fields
}
Selectors: request to select socket statistics
func (*SockStat_Selectors) Descriptor
deprecated
func (*SockStat_Selectors) Descriptor() ([]byte, []int)
Deprecated: Use SockStat_Selectors.ProtoReflect.Descriptor instead.
func (*SockStat_Selectors) GetComm ¶
func (x *SockStat_Selectors) GetComm() string
func (*SockStat_Selectors) GetFamily ¶
func (x *SockStat_Selectors) GetFamily() common.IpAddrFamily
func (*SockStat_Selectors) GetIfname ¶
func (x *SockStat_Selectors) GetIfname() string
func (*SockStat_Selectors) GetInode ¶
func (x *SockStat_Selectors) GetInode() int64
func (*SockStat_Selectors) GetLocalAddr ¶
func (x *SockStat_Selectors) GetLocalAddr() string
func (*SockStat_Selectors) GetLocalPort ¶
func (x *SockStat_Selectors) GetLocalPort() int32
func (*SockStat_Selectors) GetPid ¶
func (x *SockStat_Selectors) GetPid() int32
func (*SockStat_Selectors) GetProtocol ¶
func (x *SockStat_Selectors) GetProtocol() string
func (*SockStat_Selectors) GetRemoteAddr ¶
func (x *SockStat_Selectors) GetRemoteAddr() string
func (*SockStat_Selectors) GetRemotePort ¶
func (x *SockStat_Selectors) GetRemotePort() int32
func (*SockStat_Selectors) GetState ¶
func (x *SockStat_Selectors) GetState() ConnState
func (*SockStat_Selectors) ProtoMessage ¶
func (*SockStat_Selectors) ProtoMessage()
func (*SockStat_Selectors) ProtoReflect ¶
func (x *SockStat_Selectors) ProtoReflect() protoreflect.Message
func (*SockStat_Selectors) Reset ¶
func (x *SockStat_Selectors) Reset()
func (*SockStat_Selectors) String ¶
func (x *SockStat_Selectors) String() string
type SocketStatReq ¶
type SocketStatReq struct {
// contains filtered or unexported fields
}
SocketStatReq: request for socket statistics
func (*SocketStatReq) Descriptor
deprecated
func (*SocketStatReq) Descriptor() ([]byte, []int)
Deprecated: Use SocketStatReq.ProtoReflect.Descriptor instead.
func (*SocketStatReq) ProtoMessage ¶
func (*SocketStatReq) ProtoMessage()
func (*SocketStatReq) ProtoReflect ¶
func (x *SocketStatReq) ProtoReflect() protoreflect.Message
func (*SocketStatReq) Reset ¶
func (x *SocketStatReq) Reset()
func (*SocketStatReq) String ¶
func (x *SocketStatReq) String() string
type SocketStatReq_List ¶
type SocketStatReq_List struct {
// Selectors: list of selectors
Selectors []*SockStat_Selectors `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
// contains filtered or unexported fields
}
List: request for listing socket statistics
func (*SocketStatReq_List) Descriptor
deprecated
func (*SocketStatReq_List) Descriptor() ([]byte, []int)
Deprecated: Use SocketStatReq_List.ProtoReflect.Descriptor instead.
func (*SocketStatReq_List) GetSelectors ¶
func (x *SocketStatReq_List) GetSelectors() []*SockStat_Selectors
func (*SocketStatReq_List) ProtoMessage ¶
func (*SocketStatReq_List) ProtoMessage()
func (*SocketStatReq_List) ProtoReflect ¶
func (x *SocketStatReq_List) ProtoReflect() protoreflect.Message
func (*SocketStatReq_List) Reset ¶
func (x *SocketStatReq_List) Reset()
func (*SocketStatReq_List) String ¶
func (x *SocketStatReq_List) String() string
type SocketStatReq_Watch ¶
type SocketStatReq_Watch struct {
// Selectors: list of selectors
Selectors []*SockStat_Selectors `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
// contains filtered or unexported fields
}
Watch: request for watching socket statistics
func (*SocketStatReq_Watch) Descriptor
deprecated
func (*SocketStatReq_Watch) Descriptor() ([]byte, []int)
Deprecated: Use SocketStatReq_Watch.ProtoReflect.Descriptor instead.
func (*SocketStatReq_Watch) GetSelectors ¶
func (x *SocketStatReq_Watch) GetSelectors() []*SockStat_Selectors
func (*SocketStatReq_Watch) ProtoMessage ¶
func (*SocketStatReq_Watch) ProtoMessage()
func (*SocketStatReq_Watch) ProtoReflect ¶
func (x *SocketStatReq_Watch) ProtoReflect() protoreflect.Message
func (*SocketStatReq_Watch) Reset ¶
func (x *SocketStatReq_Watch) Reset()
func (*SocketStatReq_Watch) String ¶
func (x *SocketStatReq_Watch) String() string
type SocketStatResp ¶
type SocketStatResp struct {
// contains filtered or unexported fields
}
SocketStatResp: response for socket statistics requests
func (*SocketStatResp) Descriptor
deprecated
func (*SocketStatResp) Descriptor() ([]byte, []int)
Deprecated: Use SocketStatResp.ProtoReflect.Descriptor instead.
func (*SocketStatResp) ProtoMessage ¶
func (*SocketStatResp) ProtoMessage()
func (*SocketStatResp) ProtoReflect ¶
func (x *SocketStatResp) ProtoReflect() protoreflect.Message
func (*SocketStatResp) Reset ¶
func (x *SocketStatResp) Reset()
func (*SocketStatResp) String ¶
func (x *SocketStatResp) String() string
type SocketStatResp_List ¶
type SocketStatResp_List struct {
// Stats: list of socket statistics
Stats []*SockStat `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
// contains filtered or unexported fields
}
List: response for ListSocketStatistics
func (*SocketStatResp_List) Descriptor
deprecated
func (*SocketStatResp_List) Descriptor() ([]byte, []int)
Deprecated: Use SocketStatResp_List.ProtoReflect.Descriptor instead.
func (*SocketStatResp_List) GetStats ¶
func (x *SocketStatResp_List) GetStats() []*SockStat
func (*SocketStatResp_List) ProtoMessage ¶
func (*SocketStatResp_List) ProtoMessage()
func (*SocketStatResp_List) ProtoReflect ¶
func (x *SocketStatResp_List) ProtoReflect() protoreflect.Message
func (*SocketStatResp_List) Reset ¶
func (x *SocketStatResp_List) Reset()
func (*SocketStatResp_List) String ¶
func (x *SocketStatResp_List) String() string
type SocketStatResp_Watch ¶
type SocketStatResp_Watch struct {
// Stats: list of socket statistics
Stats []*SockStat `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
// contains filtered or unexported fields
}
Watch: response for WatchSocketStatistics
func (*SocketStatResp_Watch) Descriptor
deprecated
func (*SocketStatResp_Watch) Descriptor() ([]byte, []int)
Deprecated: Use SocketStatResp_Watch.ProtoReflect.Descriptor instead.
func (*SocketStatResp_Watch) GetStats ¶
func (x *SocketStatResp_Watch) GetStats() []*SockStat
func (*SocketStatResp_Watch) ProtoMessage ¶
func (*SocketStatResp_Watch) ProtoMessage()
func (*SocketStatResp_Watch) ProtoReflect ¶
func (x *SocketStatResp_Watch) ProtoReflect() protoreflect.Message
func (*SocketStatResp_Watch) Reset ¶
func (x *SocketStatResp_Watch) Reset()
func (*SocketStatResp_Watch) String ¶
func (x *SocketStatResp_Watch) String() string
type UnimplementedAgentAPIServer ¶
type UnimplementedAgentAPIServer struct{}
UnimplementedAgentAPIServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAgentAPIServer) ListNftables ¶
func (UnimplementedAgentAPIServer) ListNftables(context.Context, *NftablesReq_List) (*NftablesResp_List, error)
func (UnimplementedAgentAPIServer) ListSocketStatistics ¶
func (UnimplementedAgentAPIServer) ListSocketStatistics(context.Context, *SocketStatReq_List) (*SocketStatResp_List, error)
func (UnimplementedAgentAPIServer) WatchNftables ¶
func (UnimplementedAgentAPIServer) WatchNftables(*NftablesReq_Watch, grpc.ServerStreamingServer[NftablesResp_Watch]) error
func (UnimplementedAgentAPIServer) WatchSocketStatistics ¶
func (UnimplementedAgentAPIServer) WatchSocketStatistics(*SocketStatReq_Watch, grpc.ServerStreamingServer[SocketStatResp_Watch]) error
type UnsafeAgentAPIServer ¶
type UnsafeAgentAPIServer interface {
// contains filtered or unexported methods
}
UnsafeAgentAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentAPIServer will result in compilation errors.