server

Documentation

Overview

Package server implements a gRPC server that streams the entities stored in Workloadmeta.

Index

• type Server
  • func NewServer(store workloadmeta.Component) *Server
  • func (s *Server) StreamEntities(in *pb.WorkloadmetaStreamRequest, ...) error

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server is a grpc server that streams workloadmeta entities

func NewServer

func NewServer(store workloadmeta.Component) *Server

NewServer returns a new server with a workloadmeta instance

func (*Server) StreamEntities

func (s *Server) StreamEntities(in *pb.WorkloadmetaStreamRequest, out pb.AgentSecure_WorkloadmetaStreamEntitiesServer) error

StreamEntities streams entities from the workloadmeta store applying the given filter