agentv1

package
v0.3.1-rc1 Latest Latest
Warning

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

Go to latest
Published: Jun 23, 2026 License: MIT Imports: 21 Imported by: 0

Documentation

Overview

Package agentv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
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

View Source
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.

View Source
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)

View Source
var File_agent_v1_domains_proto protoreflect.FileDescriptor
View Source
var File_agent_v1_queries_proto protoreflect.FileDescriptor
View Source
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) Enum

func (x ConnState) Enum() *ConnState

func (ConnState) EnumDescriptor deprecated

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

Deprecated: Use ConnState.Descriptor instead.

func (ConnState) Number

func (x ConnState) Number() protoreflect.EnumNumber

func (ConnState) String

func (x ConnState) String() string

func (ConnState) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Nftables.ProtoReflect.Descriptor instead.

func (*Nftables) GetJson

func (x *Nftables) GetJson() string

func (*Nftables) GetText

func (x *Nftables) GetText() string

func (*Nftables) ProtoMessage

func (*Nftables) ProtoMessage()

func (*Nftables) ProtoReflect

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

func (*Nftables) Reset

func (x *Nftables) Reset()

func (*Nftables) String

func (x *Nftables) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use SockStat.ProtoReflect.Descriptor instead.

func (*SockStat) GetFamily

func (x *SockStat) GetFamily() common.IpAddrFamily

func (*SockStat) GetIfname

func (x *SockStat) GetIfname() string

func (*SockStat) GetInode

func (x *SockStat) GetInode() int64

func (*SockStat) GetLocalAddr

func (x *SockStat) GetLocalAddr() string

func (*SockStat) GetLocalPort

func (x *SockStat) GetLocalPort() int32

func (*SockStat) GetProcesses

func (x *SockStat) GetProcesses() []*ProcessInfo

func (*SockStat) GetProtocol

func (x *SockStat) GetProtocol() string

func (*SockStat) GetRemoteAddr

func (x *SockStat) GetRemoteAddr() string

func (*SockStat) GetRemotePort

func (x *SockStat) GetRemotePort() int32

func (*SockStat) GetState

func (x *SockStat) GetState() ConnState

func (*SockStat) ProtoMessage

func (*SockStat) ProtoMessage()

func (*SockStat) ProtoReflect

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

func (*SockStat) Reset

func (x *SockStat) Reset()

func (*SockStat) String

func (x *SockStat) String() string

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

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL