server

package
v0.0.0-...-20dd9da Latest Latest
Warning

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

Go to latest
Published: Nov 16, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

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

Types

type Server

type Server struct {
	pb.UnimplementedKVMServer

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

func (*Server) RegisterAgentIdentity

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

func (*Server) SendPolicy

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

func (*Server) UpdateETCDLabelToIdentitiesMaps

func (s *Server) UpdateETCDLabelToIdentitiesMaps(identity uint16)

Jump to

Keyboard shortcuts

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