protobuf

package module
v0.0.0-...-c933d8c Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2025 License: Apache-2.0 Imports: 10 Imported by: 36

Documentation

Index

Constants

View Source 
const (
	KVM_RegisterAgentIdentity_FullMethodName = "/kvm.KVM/registerAgentIdentity"
	KVM_SendPolicy_FullMethodName            = "/kvm.KVM/sendPolicy"
)
View Source 
const (
	PolicyService_ContainerPolicy_FullMethodName = "/policy.PolicyService/containerPolicy"
	PolicyService_HostPolicy_FullMethodName      = "/policy.PolicyService/hostPolicy"
)
View Source 
const (
	StateAgent_WatchState_FullMethodName = "/state_agent.StateAgent/WatchState"
	StateAgent_GetState_FullMethodName   = "/state_agent.StateAgent/GetState"
)
View Source 
const (
	ProbeService_GetProbeData_FullMethodName = "/policy.ProbeService/getProbeData"
)

Variables

View Source 
var (
	PolicyStatus_name = map[int32]string{
		0: "Failure",
		1: "Applied",
		2: "Deleted",
		3: "Modified",
		4: "NotExist",
		5: "Invalid",
		6: "NotEnabled",
	}
	PolicyStatus_value = map[string]int32{
		"Failure":    0,
		"Applied":    1,
		"Deleted":    2,
		"Modified":   3,
		"NotExist":   4,
		"Invalid":    5,
		"NotEnabled": 6,
	}
)

Enum value maps for PolicyStatus.

View Source 
var File_kubearmor_proto protoreflect.FileDescriptor
View Source 
var File_kvm_proto protoreflect.FileDescriptor
View Source 
var File_policy_proto protoreflect.FileDescriptor
View Source 
var File_state_proto protoreflect.FileDescriptor
View Source 
var KVM_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kvm.KVM",
	HandlerType: (*KVMServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "registerAgentIdentity",
			Handler:    _KVM_RegisterAgentIdentity_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "sendPolicy",
			Handler:       _KVM_SendPolicy_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "kvm.proto",
}

KVM_ServiceDesc is the grpc.ServiceDesc for KVM 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 LogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "feeder.LogService",
	HandlerType: (*LogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HealthCheck",
			Handler:    _LogService_HealthCheck_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchMessages",
			Handler:       _LogService_WatchMessages_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchAlerts",
			Handler:       _LogService_WatchAlerts_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchLogs",
			Handler:       _LogService_WatchLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "kubearmor.proto",
}

LogService_ServiceDesc is the grpc.ServiceDesc for LogService 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 PolicyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "policy.PolicyService",
	HandlerType: (*PolicyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "containerPolicy",
			Handler:    _PolicyService_ContainerPolicy_Handler,
		},
		{
			MethodName: "hostPolicy",
			Handler:    _PolicyService_HostPolicy_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "policy.proto",
}

PolicyService_ServiceDesc is the grpc.ServiceDesc for PolicyService 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 ProbeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "policy.ProbeService",
	HandlerType: (*ProbeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "getProbeData",
			Handler:    _ProbeService_GetProbeData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "policy.proto",
}

ProbeService_ServiceDesc is the grpc.ServiceDesc for ProbeService 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 StateAgent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "state_agent.StateAgent",
	HandlerType: (*StateAgentServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchState",
			Handler:       _StateAgent_WatchState_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetState",
			Handler:       _StateAgent_GetState_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "state.proto",
}

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

Functions

func RegisterKVMServer 

func RegisterKVMServer(s grpc.ServiceRegistrar, srv KVMServer)

func RegisterLogServiceServer 

func RegisterLogServiceServer(s grpc.ServiceRegistrar, srv LogServiceServer)

func RegisterPolicyServiceServer 

func RegisterPolicyServiceServer(s grpc.ServiceRegistrar, srv PolicyServiceServer)

func RegisterProbeServiceServer 

func RegisterProbeServiceServer(s grpc.ServiceRegistrar, srv ProbeServiceServer)

func RegisterStateAgentServer 

func RegisterStateAgentServer(s grpc.ServiceRegistrar, srv StateAgentServer)

Types

type AgentIdentity 

type AgentIdentity struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentIdentity) Descriptor deprecated 

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

Deprecated: Use AgentIdentity.ProtoReflect.Descriptor instead.

func (*AgentIdentity) GetIdentity 

func (x *AgentIdentity) GetIdentity() string

func (*AgentIdentity) ProtoMessage 

func (*AgentIdentity) ProtoMessage()

func (*AgentIdentity) ProtoReflect 

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

func (*AgentIdentity) Reset 

func (x *AgentIdentity) Reset()

func (*AgentIdentity) String 

func (x *AgentIdentity) String() string

type Alert 

type Alert struct {
	Timestamp              int64     `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	UpdatedTime            string    `protobuf:"bytes,2,opt,name=UpdatedTime,proto3" json:"UpdatedTime,omitempty"`
	ClusterName            string    `protobuf:"bytes,3,opt,name=ClusterName,proto3" json:"ClusterName,omitempty"`
	HostName               string    `protobuf:"bytes,4,opt,name=HostName,proto3" json:"HostName,omitempty"`
	NamespaceName          string    `protobuf:"bytes,5,opt,name=NamespaceName,proto3" json:"NamespaceName,omitempty"`
	Owner                  *Podowner `protobuf:"bytes,31,opt,name=Owner,proto3" json:"Owner,omitempty"`
	PodName                string    `protobuf:"bytes,6,opt,name=PodName,proto3" json:"PodName,omitempty"`
	Labels                 string    `protobuf:"bytes,29,opt,name=Labels,proto3" json:"Labels,omitempty"`
	ContainerID            string    `protobuf:"bytes,7,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	ContainerName          string    `protobuf:"bytes,8,opt,name=ContainerName,proto3" json:"ContainerName,omitempty"`
	ContainerImage         string    `protobuf:"bytes,24,opt,name=ContainerImage,proto3" json:"ContainerImage,omitempty"`
	HostPPID               int32     `protobuf:"varint,27,opt,name=HostPPID,proto3" json:"HostPPID,omitempty"`
	HostPID                int32     `protobuf:"varint,9,opt,name=HostPID,proto3" json:"HostPID,omitempty"`
	PPID                   int32     `protobuf:"varint,10,opt,name=PPID,proto3" json:"PPID,"`
	PID                    int32     `protobuf:"varint,11,opt,name=PID,proto3" json:"PID,omitempty"`
	UID                    int32     `protobuf:"varint,12,opt,name=UID,proto3" json:"UID,"`
	ParentProcessName      string    `protobuf:"bytes,25,opt,name=ParentProcessName,proto3" json:"ParentProcessName,omitempty"`
	ProcessName            string    `protobuf:"bytes,26,opt,name=ProcessName,proto3" json:"ProcessName,omitempty"`
	PolicyName             string    `protobuf:"bytes,13,opt,name=PolicyName,proto3" json:"PolicyName,omitempty"`
	Severity               string    `protobuf:"bytes,14,opt,name=Severity,proto3" json:"Severity,omitempty"`
	Tags                   string    `protobuf:"bytes,15,opt,name=Tags,proto3" json:"Tags,omitempty"`
	ATags                  []string  `protobuf:"bytes,30,rep,name=ATags,proto3" json:"ATags,omitempty"`
	Message                string    `protobuf:"bytes,16,opt,name=Message,proto3" json:"Message,omitempty"`
	Type                   string    `protobuf:"bytes,17,opt,name=Type,proto3" json:"Type,omitempty"`
	Source                 string    `protobuf:"bytes,18,opt,name=Source,proto3" json:"Source,omitempty"`
	Operation              string    `protobuf:"bytes,19,opt,name=Operation,proto3" json:"Operation,omitempty"`
	Resource               string    `protobuf:"bytes,20,opt,name=Resource,proto3" json:"Resource,omitempty"`
	Data                   string    `protobuf:"bytes,21,opt,name=Data,proto3" json:"Data,omitempty"`
	Enforcer               string    `protobuf:"bytes,28,opt,name=Enforcer,proto3" json:"Enforcer,omitempty"`
	Action                 string    `protobuf:"bytes,22,opt,name=Action,proto3" json:"Action,omitempty"`
	Result                 string    `protobuf:"bytes,23,opt,name=Result,proto3" json:"Result,omitempty"`
	Cwd                    string    `protobuf:"bytes,32,opt,name=Cwd,proto3" json:"Cwd,omitempty"`
	TTY                    string    `protobuf:"bytes,33,opt,name=TTY,proto3" json:"TTY,omitempty"`
	MaxAlertsPerSec        int32     `protobuf:"varint,34,opt,name=MaxAlertsPerSec,proto3" json:"MaxAlertsPerSec,omitempty"`
	DroppingAlertsInterval int32     `protobuf:"varint,35,opt,name=DroppingAlertsInterval,proto3" json:"DroppingAlertsInterval,omitempty"`
	// contains filtered or unexported fields
}

alert struct

func (*Alert) Descriptor deprecated 

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

Deprecated: Use Alert.ProtoReflect.Descriptor instead.

func (*Alert) GetATags 

func (x *Alert) GetATags() []string

func (*Alert) GetAction 

func (x *Alert) GetAction() string

func (*Alert) GetClusterName 

func (x *Alert) GetClusterName() string

func (*Alert) GetContainerID 

func (x *Alert) GetContainerID() string

func (*Alert) GetContainerImage 

func (x *Alert) GetContainerImage() string

func (*Alert) GetContainerName 

func (x *Alert) GetContainerName() string

func (*Alert) GetCwd 

func (x *Alert) GetCwd() string

func (*Alert) GetData 

func (x *Alert) GetData() string

func (*Alert) GetDroppingAlertsInterval 

func (x *Alert) GetDroppingAlertsInterval() int32

func (*Alert) GetEnforcer 

func (x *Alert) GetEnforcer() string

func (*Alert) GetHostName 

func (x *Alert) GetHostName() string

func (*Alert) GetHostPID 

func (x *Alert) GetHostPID() int32

func (*Alert) GetHostPPID 

func (x *Alert) GetHostPPID() int32

func (*Alert) GetLabels 

func (x *Alert) GetLabels() string

func (*Alert) GetMaxAlertsPerSec 

func (x *Alert) GetMaxAlertsPerSec() int32

func (*Alert) GetMessage 

func (x *Alert) GetMessage() string

func (*Alert) GetNamespaceName 

func (x *Alert) GetNamespaceName() string

func (*Alert) GetOperation 

func (x *Alert) GetOperation() string

func (*Alert) GetOwner 

func (x *Alert) GetOwner() *Podowner

func (*Alert) GetPID 

func (x *Alert) GetPID() int32

func (*Alert) GetPPID 

func (x *Alert) GetPPID() int32

func (*Alert) GetParentProcessName 

func (x *Alert) GetParentProcessName() string

func (*Alert) GetPodName 

func (x *Alert) GetPodName() string

func (*Alert) GetPolicyName 

func (x *Alert) GetPolicyName() string

func (*Alert) GetProcessName 

func (x *Alert) GetProcessName() string

func (*Alert) GetResource 

func (x *Alert) GetResource() string

func (*Alert) GetResult 

func (x *Alert) GetResult() string

func (*Alert) GetSeverity 

func (x *Alert) GetSeverity() string

func (*Alert) GetSource 

func (x *Alert) GetSource() string

func (*Alert) GetTTY 

func (x *Alert) GetTTY() string

func (*Alert) GetTags 

func (x *Alert) GetTags() string

func (*Alert) GetTimestamp 

func (x *Alert) GetTimestamp() int64

func (*Alert) GetType 

func (x *Alert) GetType() string

func (*Alert) GetUID 

func (x *Alert) GetUID() int32

func (*Alert) GetUpdatedTime 

func (x *Alert) GetUpdatedTime() string

func (*Alert) ProtoMessage 

func (*Alert) ProtoMessage()

func (*Alert) ProtoReflect 

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

func (*Alert) Reset 

func (x *Alert) Reset()

func (*Alert) String 

func (x *Alert) String() string

type ContainerData 

type ContainerData struct {
	PolicyList     []string  `protobuf:"bytes,1,rep,name=policyList,proto3" json:"policyList,omitempty"`
	PolicyEnabled  int32     `protobuf:"varint,2,opt,name=policyEnabled,proto3" json:"policyEnabled,omitempty"`
	PolicyDataList []*Policy `protobuf:"bytes,3,rep,name=policyDataList,proto3" json:"policyDataList,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerData) Descriptor deprecated 

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

Deprecated: Use ContainerData.ProtoReflect.Descriptor instead.

func (*ContainerData) GetPolicyDataList 

func (x *ContainerData) GetPolicyDataList() []*Policy

func (*ContainerData) GetPolicyEnabled 

func (x *ContainerData) GetPolicyEnabled() int32

func (*ContainerData) GetPolicyList 

func (x *ContainerData) GetPolicyList() []string

func (*ContainerData) ProtoMessage 

func (*ContainerData) ProtoMessage()

func (*ContainerData) ProtoReflect 

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

func (*ContainerData) Reset 

func (x *ContainerData) Reset()

func (*ContainerData) String 

func (x *ContainerData) String() string

type Empty 

type Empty = empty.Empty

type HostSecurityPolicies 

type HostSecurityPolicies struct {
	PolicyList     []string  `protobuf:"bytes,1,rep,name=policyList,proto3" json:"policyList,omitempty"`
	PolicyDataList []*Policy `protobuf:"bytes,2,rep,name=policyDataList,proto3" json:"policyDataList,omitempty"`
	// contains filtered or unexported fields
}

func (*HostSecurityPolicies) Descriptor deprecated 

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

Deprecated: Use HostSecurityPolicies.ProtoReflect.Descriptor instead.

func (*HostSecurityPolicies) GetPolicyDataList 

func (x *HostSecurityPolicies) GetPolicyDataList() []*Policy

func (*HostSecurityPolicies) GetPolicyList 

func (x *HostSecurityPolicies) GetPolicyList() []string

func (*HostSecurityPolicies) ProtoMessage 

func (*HostSecurityPolicies) ProtoMessage()

func (*HostSecurityPolicies) ProtoReflect 

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

func (*HostSecurityPolicies) Reset 

func (x *HostSecurityPolicies) Reset()

func (*HostSecurityPolicies) String 

func (x *HostSecurityPolicies) String() string

type KVMClient 

type KVMClient interface {
	RegisterAgentIdentity(ctx context.Context, in *AgentIdentity, opts ...grpc.CallOption) (*Status, error)
	SendPolicy(ctx context.Context, opts ...grpc.CallOption) (KVM_SendPolicyClient, error)
}

KVMClient is the client API for KVM 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 NewKVMClient 

func NewKVMClient(cc grpc.ClientConnInterface) KVMClient

type KVMServer 

type KVMServer interface {
	RegisterAgentIdentity(context.Context, *AgentIdentity) (*Status, error)
	SendPolicy(KVM_SendPolicyServer) error
}

KVMServer is the server API for KVM service. All implementations should embed UnimplementedKVMServer for forward compatibility

type KVM_SendPolicyClient 

type KVM_SendPolicyClient interface {
	Send(*Status) error
	Recv() (*PolicyData, error)
	grpc.ClientStream
}

type KVM_SendPolicyServer 

type KVM_SendPolicyServer interface {
	Send(*PolicyData) error
	Recv() (*Status, error)
	grpc.ServerStream
}

type Log 

type Log struct {
	Timestamp         int64     `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	UpdatedTime       string    `protobuf:"bytes,2,opt,name=UpdatedTime,proto3" json:"UpdatedTime,omitempty"`
	ClusterName       string    `protobuf:"bytes,3,opt,name=ClusterName,proto3" json:"ClusterName,omitempty"`
	HostName          string    `protobuf:"bytes,4,opt,name=HostName,proto3" json:"HostName,omitempty"`
	NamespaceName     string    `protobuf:"bytes,5,opt,name=NamespaceName,proto3" json:"NamespaceName,omitempty"`
	Owner             *Podowner `protobuf:"bytes,24,opt,name=Owner,proto3" json:"Owner,omitempty"`
	PodName           string    `protobuf:"bytes,6,opt,name=PodName,proto3" json:"PodName,omitempty"`
	Labels            string    `protobuf:"bytes,23,opt,name=Labels,proto3" json:"Labels,omitempty"`
	ContainerID       string    `protobuf:"bytes,7,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	ContainerName     string    `protobuf:"bytes,8,opt,name=ContainerName,proto3" json:"ContainerName,omitempty"`
	ContainerImage    string    `protobuf:"bytes,19,opt,name=ContainerImage,proto3" json:"ContainerImage,omitempty"`
	ParentProcessName string    `protobuf:"bytes,20,opt,name=ParentProcessName,proto3" json:"ParentProcessName,omitempty"`
	ProcessName       string    `protobuf:"bytes,21,opt,name=ProcessName,proto3" json:"ProcessName,omitempty"`
	HostPPID          int32     `protobuf:"varint,22,opt,name=HostPPID,proto3" json:"HostPPID,omitempty"`
	HostPID           int32     `protobuf:"varint,9,opt,name=HostPID,proto3" json:"HostPID,omitempty"`
	PPID              int32     `protobuf:"varint,10,opt,name=PPID,proto3" json:"PPID,"`
	PID               int32     `protobuf:"varint,11,opt,name=PID,proto3" json:"PID,omitempty"`
	UID               int32     `protobuf:"varint,12,opt,name=UID,proto3" json:"UID,"`
	Type              string    `protobuf:"bytes,13,opt,name=Type,proto3" json:"Type,omitempty"`
	Source            string    `protobuf:"bytes,14,opt,name=Source,proto3" json:"Source,omitempty"`
	Operation         string    `protobuf:"bytes,15,opt,name=Operation,proto3" json:"Operation,omitempty"`
	Resource          string    `protobuf:"bytes,16,opt,name=Resource,proto3" json:"Resource,omitempty"`
	Data              string    `protobuf:"bytes,17,opt,name=Data,proto3" json:"Data,omitempty"`
	Result            string    `protobuf:"bytes,18,opt,name=Result,proto3" json:"Result,omitempty"`
	Cwd               string    `protobuf:"bytes,25,opt,name=Cwd,proto3" json:"Cwd,omitempty"`
	TTY               string    `protobuf:"bytes,26,opt,name=TTY,proto3" json:"TTY,omitempty"`
	// contains filtered or unexported fields
}

log struct

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetClusterName 

func (x *Log) GetClusterName() string

func (*Log) GetContainerID 

func (x *Log) GetContainerID() string

func (*Log) GetContainerImage 

func (x *Log) GetContainerImage() string

func (*Log) GetContainerName 

func (x *Log) GetContainerName() string

func (*Log) GetCwd 

func (x *Log) GetCwd() string

func (*Log) GetData 

func (x *Log) GetData() string

func (*Log) GetHostName 

func (x *Log) GetHostName() string

func (*Log) GetHostPID 

func (x *Log) GetHostPID() int32

func (*Log) GetHostPPID 

func (x *Log) GetHostPPID() int32

func (*Log) GetLabels 

func (x *Log) GetLabels() string

func (*Log) GetNamespaceName 

func (x *Log) GetNamespaceName() string

func (*Log) GetOperation 

func (x *Log) GetOperation() string

func (*Log) GetOwner 

func (x *Log) GetOwner() *Podowner

func (*Log) GetPID 

func (x *Log) GetPID() int32

func (*Log) GetPPID 

func (x *Log) GetPPID() int32

func (*Log) GetParentProcessName 

func (x *Log) GetParentProcessName() string

func (*Log) GetPodName 

func (x *Log) GetPodName() string

func (*Log) GetProcessName 

func (x *Log) GetProcessName() string

func (*Log) GetResource 

func (x *Log) GetResource() string

func (*Log) GetResult 

func (x *Log) GetResult() string

func (*Log) GetSource 

func (x *Log) GetSource() string

func (*Log) GetTTY 

func (x *Log) GetTTY() string

func (*Log) GetTimestamp 

func (x *Log) GetTimestamp() int64

func (*Log) GetType 

func (x *Log) GetType() string

func (*Log) GetUID 

func (x *Log) GetUID() int32

func (*Log) GetUpdatedTime 

func (x *Log) GetUpdatedTime() string

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type LogServiceClient 

type LogServiceClient interface {
	// DEPRECATED: use "google.golang.org/grpc/health/grpc_health_v1"
	HealthCheck(ctx context.Context, in *NonceMessage, opts ...grpc.CallOption) (*ReplyMessage, error)
	WatchMessages(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (LogService_WatchMessagesClient, error)
	WatchAlerts(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (LogService_WatchAlertsClient, error)
	WatchLogs(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (LogService_WatchLogsClient, error)
}

LogServiceClient is the client API for LogService 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 NewLogServiceClient 

func NewLogServiceClient(cc grpc.ClientConnInterface) LogServiceClient

type LogServiceServer 

type LogServiceServer interface {
	// DEPRECATED: use "google.golang.org/grpc/health/grpc_health_v1"
	HealthCheck(context.Context, *NonceMessage) (*ReplyMessage, error)
	WatchMessages(*RequestMessage, LogService_WatchMessagesServer) error
	WatchAlerts(*RequestMessage, LogService_WatchAlertsServer) error
	WatchLogs(*RequestMessage, LogService_WatchLogsServer) error
}

LogServiceServer is the server API for LogService service. All implementations should embed UnimplementedLogServiceServer for forward compatibility

type LogService_WatchAlertsClient 

type LogService_WatchAlertsClient interface {
	Recv() (*Alert, error)
	grpc.ClientStream
}

type LogService_WatchAlertsServer 

type LogService_WatchAlertsServer interface {
	Send(*Alert) error
	grpc.ServerStream
}

type LogService_WatchLogsClient 

type LogService_WatchLogsClient interface {
	Recv() (*Log, error)
	grpc.ClientStream
}

type LogService_WatchLogsServer 

type LogService_WatchLogsServer interface {
	Send(*Log) error
	grpc.ServerStream
}

type LogService_WatchMessagesClient 

type LogService_WatchMessagesClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type LogService_WatchMessagesServer 

type LogService_WatchMessagesServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type Message 

type Message struct {
	Timestamp   int64  `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	UpdatedTime string `protobuf:"bytes,2,opt,name=UpdatedTime,proto3" json:"UpdatedTime,omitempty"`
	ClusterName string `protobuf:"bytes,3,opt,name=ClusterName,proto3" json:"ClusterName,omitempty"`
	HostName    string `protobuf:"bytes,4,opt,name=HostName,proto3" json:"HostName,omitempty"`
	HostIP      string `protobuf:"bytes,5,opt,name=HostIP,proto3" json:"HostIP,omitempty"`
	Type        string `protobuf:"bytes,6,opt,name=Type,proto3" json:"Type,omitempty"`
	Level       string `protobuf:"bytes,7,opt,name=Level,proto3" json:"Level,omitempty"`
	Message     string `protobuf:"bytes,8,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

message struct

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetClusterName 

func (x *Message) GetClusterName() string

func (*Message) GetHostIP 

func (x *Message) GetHostIP() string

func (*Message) GetHostName 

func (x *Message) GetHostName() string

func (*Message) GetLevel 

func (x *Message) GetLevel() string

func (*Message) GetMessage 

func (x *Message) GetMessage() string

func (*Message) GetTimestamp 

func (x *Message) GetTimestamp() int64

func (*Message) GetType 

func (x *Message) GetType() string

func (*Message) GetUpdatedTime 

func (x *Message) GetUpdatedTime() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type NonceMessage 

type NonceMessage struct {
	Nonce int32 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// contains filtered or unexported fields
}

Health check

func (*NonceMessage) Descriptor deprecated 

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

Deprecated: Use NonceMessage.ProtoReflect.Descriptor instead.

func (*NonceMessage) GetNonce 

func (x *NonceMessage) GetNonce() int32

func (*NonceMessage) ProtoMessage 

func (*NonceMessage) ProtoMessage()

func (*NonceMessage) ProtoReflect 

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

func (*NonceMessage) Reset 

func (x *NonceMessage) Reset()

func (*NonceMessage) String 

func (x *NonceMessage) String() string

type Podowner 

type Podowner struct {
	Ref       string `protobuf:"bytes,1,opt,name=Ref,proto3" json:"Ref,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	// contains filtered or unexported fields
}

podowner struct

func (*Podowner) Descriptor deprecated 

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

Deprecated: Use Podowner.ProtoReflect.Descriptor instead.

func (*Podowner) GetName 

func (x *Podowner) GetName() string

func (*Podowner) GetNamespace 

func (x *Podowner) GetNamespace() string

func (*Podowner) GetRef 

func (x *Podowner) GetRef() string

func (*Podowner) ProtoMessage 

func (*Podowner) ProtoMessage()

func (*Podowner) ProtoReflect 

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

func (*Podowner) Reset 

func (x *Podowner) Reset()

func (*Podowner) String 

func (x *Podowner) String() string

type Policy 

type Policy struct {
	Policy []byte `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"`
	// contains filtered or unexported fields
}

func (*Policy) Descriptor deprecated 

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

Deprecated: Use Policy.ProtoReflect.Descriptor instead.

func (*Policy) GetPolicy 

func (x *Policy) GetPolicy() []byte

func (*Policy) ProtoMessage 

func (*Policy) ProtoMessage()

func (*Policy) ProtoReflect 

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

func (*Policy) Reset 

func (x *Policy) Reset()

func (*Policy) String 

func (x *Policy) String() string

type PolicyData 

type PolicyData struct {
	PolicyData []byte `protobuf:"bytes,1,opt,name=policyData,proto3" json:"policyData,omitempty"`
	// contains filtered or unexported fields
}

func (*PolicyData) Descriptor deprecated 

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

Deprecated: Use PolicyData.ProtoReflect.Descriptor instead.

func (*PolicyData) GetPolicyData 

func (x *PolicyData) GetPolicyData() []byte

func (*PolicyData) ProtoMessage 

func (*PolicyData) ProtoMessage()

func (*PolicyData) ProtoReflect 

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

func (*PolicyData) Reset 

func (x *PolicyData) Reset()

func (*PolicyData) String 

func (x *PolicyData) String() string

type PolicyServiceClient 

type PolicyServiceClient interface {
	ContainerPolicy(ctx context.Context, in *Policy, opts ...grpc.CallOption) (*Response, error)
	HostPolicy(ctx context.Context, in *Policy, opts ...grpc.CallOption) (*Response, error)
}

PolicyServiceClient is the client API for PolicyService 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 NewPolicyServiceClient 

func NewPolicyServiceClient(cc grpc.ClientConnInterface) PolicyServiceClient

type PolicyServiceServer 

type PolicyServiceServer interface {
	ContainerPolicy(context.Context, *Policy) (*Response, error)
	HostPolicy(context.Context, *Policy) (*Response, error)
}

PolicyServiceServer is the server API for PolicyService service. All implementations should embed UnimplementedPolicyServiceServer for forward compatibility.

type PolicyStatus 

type PolicyStatus int32
const (
	PolicyStatus_Failure    PolicyStatus = 0
	PolicyStatus_Applied    PolicyStatus = 1
	PolicyStatus_Deleted    PolicyStatus = 2
	PolicyStatus_Modified   PolicyStatus = 3
	PolicyStatus_NotExist   PolicyStatus = 4
	PolicyStatus_Invalid    PolicyStatus = 5
	PolicyStatus_NotEnabled PolicyStatus = 6
)

func (PolicyStatus) Descriptor 

func (PolicyStatus) Descriptor() protoreflect.EnumDescriptor

func (PolicyStatus) Enum 

func (x PolicyStatus) Enum() *PolicyStatus

func (PolicyStatus) EnumDescriptor deprecated 

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

Deprecated: Use PolicyStatus.Descriptor instead.

func (PolicyStatus) Number 

func (x PolicyStatus) Number() protoreflect.EnumNumber

func (PolicyStatus) String 

func (x PolicyStatus) String() string

func (PolicyStatus) Type 

func (PolicyStatus) Type() protoreflect.EnumType

type ProbeResponse 

type ProbeResponse struct {
	ContainerList []string                         `protobuf:"bytes,1,rep,name=containerList,proto3" json:"containerList,omitempty"`
	ContainerMap  map[string]*ContainerData        `` /* 151-byte string literal not displayed */
	HostMap       map[string]*HostSecurityPolicies `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProbeResponse) Descriptor deprecated 

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

Deprecated: Use ProbeResponse.ProtoReflect.Descriptor instead.

func (*ProbeResponse) GetContainerList 

func (x *ProbeResponse) GetContainerList() []string

func (*ProbeResponse) GetContainerMap 

func (x *ProbeResponse) GetContainerMap() map[string]*ContainerData

func (*ProbeResponse) GetHostMap 

func (x *ProbeResponse) GetHostMap() map[string]*HostSecurityPolicies

func (*ProbeResponse) ProtoMessage 

func (*ProbeResponse) ProtoMessage()

func (*ProbeResponse) ProtoReflect 

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

func (*ProbeResponse) Reset 

func (x *ProbeResponse) Reset()

func (*ProbeResponse) String 

func (x *ProbeResponse) String() string

type ProbeServiceClient 

type ProbeServiceClient interface {
	GetProbeData(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ProbeResponse, error)
}

ProbeServiceClient is the client API for ProbeService 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 NewProbeServiceClient 

func NewProbeServiceClient(cc grpc.ClientConnInterface) ProbeServiceClient

type ProbeServiceServer 

type ProbeServiceServer interface {
	GetProbeData(context.Context, *empty.Empty) (*ProbeResponse, error)
}

ProbeServiceServer is the server API for ProbeService service. All implementations should embed UnimplementedProbeServiceServer for forward compatibility.

type ReplyMessage 

type ReplyMessage struct {
	Retval int32 `protobuf:"varint,1,opt,name=Retval,proto3" json:"Retval,omitempty"`
	// contains filtered or unexported fields
}

reply message

func (*ReplyMessage) Descriptor deprecated 

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

Deprecated: Use ReplyMessage.ProtoReflect.Descriptor instead.

func (*ReplyMessage) GetRetval 

func (x *ReplyMessage) GetRetval() int32

func (*ReplyMessage) ProtoMessage 

func (*ReplyMessage) ProtoMessage()

func (*ReplyMessage) ProtoReflect 

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

func (*ReplyMessage) Reset 

func (x *ReplyMessage) Reset()

func (*ReplyMessage) String 

func (x *ReplyMessage) String() string

type RequestMessage 

type RequestMessage struct {
	Filter string `protobuf:"bytes,1,opt,name=Filter,proto3" json:"Filter,omitempty"`
	// contains filtered or unexported fields
}

request message

func (*RequestMessage) Descriptor deprecated 

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

Deprecated: Use RequestMessage.ProtoReflect.Descriptor instead.

func (*RequestMessage) GetFilter 

func (x *RequestMessage) GetFilter() string

func (*RequestMessage) ProtoMessage 

func (*RequestMessage) ProtoMessage()

func (*RequestMessage) ProtoReflect 

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

func (*RequestMessage) Reset 

func (x *RequestMessage) Reset()

func (*RequestMessage) String 

func (x *RequestMessage) String() string

type Response 

type Response struct {
	Status PolicyStatus `protobuf:"varint,1,opt,name=status,proto3,enum=policy.PolicyStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetStatus 

func (x *Response) GetStatus() PolicyStatus

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type StateAgentClient 

type StateAgentClient interface {
	// stream which continuously pushes state events
	WatchState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (StateAgent_WatchStateClient, error)
	// get all state events in one go
	GetState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (StateAgent_GetStateClient, error)
}

StateAgentClient is the client API for StateAgent 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 NewStateAgentClient 

func NewStateAgentClient(cc grpc.ClientConnInterface) StateAgentClient

type StateAgentServer 

type StateAgentServer interface {
	// stream which continuously pushes state events
	WatchState(*emptypb.Empty, StateAgent_WatchStateServer) error
	// get all state events in one go
	GetState(*emptypb.Empty, StateAgent_GetStateServer) error
}

StateAgentServer is the server API for StateAgent service. All implementations should embed UnimplementedStateAgentServer for forward compatibility

type StateAgent_GetStateClient 

type StateAgent_GetStateClient interface {
	Recv() (*StateEvents, error)
	grpc.ClientStream
}

type StateAgent_GetStateServer 

type StateAgent_GetStateServer interface {
	Send(*StateEvents) error
	grpc.ServerStream
}

type StateAgent_WatchStateClient 

type StateAgent_WatchStateClient interface {
	Recv() (*StateEvent, error)
	grpc.ClientStream
}

type StateAgent_WatchStateServer 

type StateAgent_WatchStateServer interface {
	Send(*StateEvent) error
	grpc.ServerStream
}

type StateEvent 

type StateEvent struct {
	Kind   string `protobuf:"bytes,1,opt,name=Kind,proto3" json:"Kind,omitempty"`
	Type   string `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty"`
	Name   string `protobuf:"bytes,3,opt,name=Name,proto3" json:"Name,omitempty"`
	Object []byte `protobuf:"bytes,4,opt,name=Object,proto3" json:"Object,omitempty"`
	// contains filtered or unexported fields
}

func (*StateEvent) Descriptor deprecated 

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

Deprecated: Use StateEvent.ProtoReflect.Descriptor instead.

func (*StateEvent) GetKind 

func (x *StateEvent) GetKind() string

func (*StateEvent) GetName 

func (x *StateEvent) GetName() string

func (*StateEvent) GetObject 

func (x *StateEvent) GetObject() []byte

func (*StateEvent) GetType 

func (x *StateEvent) GetType() string

func (*StateEvent) ProtoMessage 

func (*StateEvent) ProtoMessage()

func (*StateEvent) ProtoReflect 

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

func (*StateEvent) Reset 

func (x *StateEvent) Reset()

func (*StateEvent) String 

func (x *StateEvent) String() string

type StateEvents 

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

func (*StateEvents) Descriptor deprecated 

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

Deprecated: Use StateEvents.ProtoReflect.Descriptor instead.

func (*StateEvents) GetStateEvents 

func (x *StateEvents) GetStateEvents() []*StateEvent

func (*StateEvents) ProtoMessage 

func (*StateEvents) ProtoMessage()

func (*StateEvents) ProtoReflect 

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

func (*StateEvents) Reset 

func (x *StateEvents) Reset()

func (*StateEvents) String 

func (x *StateEvents) String() string

type Status 

type Status struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetStatus 

func (x *Status) GetStatus() int32

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type UnimplementedKVMServer 

type UnimplementedKVMServer struct {
}

UnimplementedKVMServer should be embedded to have forward compatible implementations.

func (UnimplementedKVMServer) RegisterAgentIdentity 

func (UnimplementedKVMServer) RegisterAgentIdentity(context.Context, *AgentIdentity) (*Status, error)

func (UnimplementedKVMServer) SendPolicy 

func (UnimplementedKVMServer) SendPolicy(KVM_SendPolicyServer) error

type UnimplementedLogServiceServer 

type UnimplementedLogServiceServer struct {
}

UnimplementedLogServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedLogServiceServer) HealthCheck 

func (UnimplementedLogServiceServer) HealthCheck(context.Context, *NonceMessage) (*ReplyMessage, error)

func (UnimplementedLogServiceServer) WatchAlerts 

func (UnimplementedLogServiceServer) WatchAlerts(*RequestMessage, LogService_WatchAlertsServer) error

func (UnimplementedLogServiceServer) WatchLogs 

func (UnimplementedLogServiceServer) WatchLogs(*RequestMessage, LogService_WatchLogsServer) error

func (UnimplementedLogServiceServer) WatchMessages 

func (UnimplementedLogServiceServer) WatchMessages(*RequestMessage, LogService_WatchMessagesServer) error

type UnimplementedPolicyServiceServer 

type UnimplementedPolicyServiceServer struct{}

UnimplementedPolicyServiceServer should 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 (UnimplementedPolicyServiceServer) ContainerPolicy 

func (UnimplementedPolicyServiceServer) ContainerPolicy(context.Context, *Policy) (*Response, error)

func (UnimplementedPolicyServiceServer) HostPolicy 

func (UnimplementedPolicyServiceServer) HostPolicy(context.Context, *Policy) (*Response, error)

type UnimplementedProbeServiceServer 

type UnimplementedProbeServiceServer struct{}

UnimplementedProbeServiceServer should 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 (UnimplementedProbeServiceServer) GetProbeData 

func (UnimplementedProbeServiceServer) GetProbeData(context.Context, *empty.Empty) (*ProbeResponse, error)

type UnimplementedStateAgentServer 

type UnimplementedStateAgentServer struct {
}

UnimplementedStateAgentServer should be embedded to have forward compatible implementations.

func (UnimplementedStateAgentServer) GetState 

func (UnimplementedStateAgentServer) GetState(*emptypb.Empty, StateAgent_GetStateServer) error

func (UnimplementedStateAgentServer) WatchState 

func (UnimplementedStateAgentServer) WatchState(*emptypb.Empty, StateAgent_WatchStateServer) error

type UnsafeKVMServer 

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

UnsafeKVMServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KVMServer will result in compilation errors.

type UnsafeLogServiceServer 

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

UnsafeLogServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogServiceServer will result in compilation errors.

type UnsafePolicyServiceServer 

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

UnsafePolicyServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PolicyServiceServer will result in compilation errors.

type UnsafeProbeServiceServer 

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

UnsafeProbeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProbeServiceServer will result in compilation errors.

type UnsafeStateAgentServer 

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

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