server

package module
v0.0.0-...-54a4afe Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2023 License: Apache-2.0 Imports: 14 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	PolicyChan  chan tp.K8sKubeArmorHostPolicyEventWithIdentity
	ClusterIp   string
	Clusterport string

	EtcdClient *etcd.EtcdClient
)

Functions

func GetIdentityFromContext

func GetIdentityFromContext(ctx context.Context) uint16

func IsIdentityServing

func IsIdentityServing(identity string) int

func UpdateETCDLabelToIdentitiesMaps

func UpdateETCDLabelToIdentitiesMaps(identity uint16)

Types

type CLIServer

type CLIServer struct {
	pb.HandleCliServer
}

Variables / Struct

func (*CLIServer) HandleCliRequest

func (c *CLIServer) HandleCliRequest(ctx context.Context, request *pb.CliRequest) (*pb.ResponseStatus, error)

type KVMServer

type KVMServer struct {
	pb.UnimplementedKVMServer
}

func (*KVMServer) RegisterAgentIdentity

func (s *KVMServer) RegisterAgentIdentity(ctx context.Context, in *pb.AgentIdentity) (*pb.Status, error)

func (*KVMServer) SendPolicy

func (s *KVMServer) SendPolicy(stream pb.KVM_SendPolicyServer) error

type Server

type Server struct {
	EtcdClient *etcd.EtcdClient
	// contains filtered or unexported fields
}

Variables / Struct

func NewServerInit

func NewServerInit(ipAddress, ClusterIpAddress, portVal string, Etcd *etcd.EtcdClient) *Server

func (*Server) InitServer

func (s *Server) InitServer()

Jump to

Keyboard shortcuts

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