rpc

Documentation

Index

• func NewAuditServiceServer(logger logging.Logger, eventStream audit.EventStream, auditDataDirPath string) rpcv1.AuditServiceServer
• func NewEndpointOrchestratorServer(logger logging.Logger, epHost endpoint.Host) rpcv1.EndpointOrchestratorServiceServer
• func NewHealthServer(checker health.Checker, watchCheckPeriod time.Duration, logger logging.Logger) v1.HealthServer
• func NewPCAPServer(pcapDataDir string, recorder pcap.Recorder) rpcv1.PCAPServiceServer
• func NewProfilingServer() rpcv1.ProfilingServiceServer
• func PathToGRPCError(err error) error
• type INetMockAPI
  • func NewINetMockAPI(u *url.URL, logger logging.Logger, checker health.Checker, ...) INetMockAPI

Functions

func NewAuditServiceServer

func NewAuditServiceServer(logger logging.Logger, eventStream audit.EventStream, auditDataDirPath string) rpcv1.AuditServiceServer

func NewEndpointOrchestratorServer

func NewEndpointOrchestratorServer(
	logger logging.Logger,
	epHost endpoint.Host,
) rpcv1.EndpointOrchestratorServiceServer

func NewHealthServer

func NewHealthServer(checker health.Checker, watchCheckPeriod time.Duration, logger logging.Logger) v1.HealthServer

func NewPCAPServer

func NewPCAPServer(pcapDataDir string, recorder pcap.Recorder) rpcv1.PCAPServiceServer

func NewProfilingServer

func NewProfilingServer() rpcv1.ProfilingServiceServer

func PathToGRPCError

func PathToGRPCError(err error) error

Types

type INetMockAPI

type INetMockAPI interface {
	StartServer() error
	StopServer()
}

func NewINetMockAPI

func NewINetMockAPI(
	u *url.URL,
	logger logging.Logger,
	checker health.Checker,
	eventStream audit.EventStream,
	epHost endpoint.Host,
	auditDataDir, pcapDataDir string,
) INetMockAPI