workload

Documentation

Overview

Package workload contains service specific code for the Workload Configuration Collection Module.

Index

• func NewServer(opts ...service.ServiceOption[Server]) collection.CollectionServer
• func WithOAuth2Authorizer(config *clientcredentials.Config) service.ServiceOption[Server]
• type Server
  • func (srv *Server) Authorizer() clapi.Authorizer
  • func (srv *Server) SetAuthorizer(auth clapi.Authorizer)
  • func (srv *Server) StartCollecting(_ context.Context, req *collection.StartCollectingRequest) (resp *collection.StartCollectingResponse, err error)
  • func (*Server) StopCollecting(_ context.Context, _ *collection.StopCollectingRequest) (*emptypb.Empty, error)

Functions

func NewServer

func NewServer(opts ...service.ServiceOption[Server]) collection.CollectionServer

NewServer creates a new workload server with default values.

func WithOAuth2Authorizer

func WithOAuth2Authorizer(config *clientcredentials.Config) service.ServiceOption[Server]

WithOAuth2Authorizer is an option to use an OAuth 2.0 authorizer

Types

type Server

type Server struct {
	collection.UnimplementedCollectionServer
	// contains filtered or unexported fields
}

Server is an implementation of the Workload Configuration service.

func (*Server) Authorizer

func (srv *Server) Authorizer() clapi.Authorizer

Authorizer implements UsesAuthorizer

func (*Server) SetAuthorizer

func (srv *Server) SetAuthorizer(auth clapi.Authorizer)

SetAuthorizer implements UsesAuthorizer

func (*Server) StartCollecting

func (srv *Server) StartCollecting(_ context.Context, req *collection.StartCollectingRequest) (
	resp *collection.StartCollectingResponse, err error)

StartCollecting starts collecting configurations from Kubernetes and OpenStack, creates evidences and sends the evidences to the Evaluation Manager.

func (*Server) StopCollecting

func (*Server) StopCollecting(_ context.Context, _ *collection.StopCollectingRequest) (*emptypb.Empty, error)

StopCollecting stops collecting configurations