server

Documentation

Index

• Variables
• func GetIdentityFromContext(ctx context.Context) uint16
• func IsIdentityServing(identity string) int
• func UpdateETCDLabelToIdentitiesMaps(identity uint16)
• type CLIServer
  • func (c *CLIServer) HandleCliRequest(ctx context.Context, request *pb.CliRequest) (*pb.ResponseStatus, error)
• type KVMServer
  • func (s *KVMServer) RegisterAgentIdentity(ctx context.Context, in *pb.AgentIdentity) (*pb.Status, error)
  • func (s *KVMServer) SendPolicy(stream pb.KVM_SendPolicyServer) error
• type Server
  • func NewServerInit(ipAddress, ClusterIpAddress, portVal string, Etcd *etcd.EtcdClient) *Server
  • func (s *Server) InitServer()

Variables

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