utils

Documentation

Index

• Variables
• func AddYunikornQueue(cfg *types.Config, kubeClientset kubernetes.Interface, svc *types.Service) error
• func CreateExpose(expose Expose, kubeClientset kubernetes.Interface, cfg types.Config) error
• func DeleteExpose(expose Expose, kubeClientset kubernetes.Interface) error
• func DeleteYunikornQueue(cfg *types.Config, kubeClientset kubernetes.Interface, svc *types.Service) error
• func GenerateToken() string
• func ListExpose(expose Expose, kubeClientset kubernetes.Interface) error
• func UpdateExpose(expose Expose, kubeClientset kubernetes.Interface, cfg types.Config) error
• func ValidateService(serv types.Service) types.Service
• type Expose
• type MinIOAdminClient
  • func MakeMinIOAdminClient(cfg *types.Config) (*MinIOAdminClient, error)
  • func (minIOAdminClient *MinIOAdminClient) RegisterWebhook(name string, token string) error
  • func (minIOAdminClient *MinIOAdminClient) RemoveWebhook(name string) error
  • func (minIOAdminClient *MinIOAdminClient) RestartServer() error
• type OpenfaasScaler
  • func NewOFScaler(kubeClientset kubernetes.Interface, cfg *types.Config) *OpenfaasScaler
  • func (ofs *OpenfaasScaler) Start()

Variables

var ExposeLogger = log.New(os.Stdout, "[EXPOSED-SERVICE] ", log.Flags())

Custom logger

Functions

func AddYunikornQueue

func AddYunikornQueue(cfg *types.Config, kubeClientset kubernetes.Interface, svc *types.Service) error

AddYunikornQueue Add (or update) a service's queue to Yunikorn's config

func CreateExpose

func CreateExpose(expose Expose, kubeClientset kubernetes.Interface, cfg types.Config) error

/ Main function that creates all the kubernetes components

func DeleteExpose

func DeleteExpose(expose Expose, kubeClientset kubernetes.Interface) error

/Main function that deletes all the kubernetes components

func DeleteYunikornQueue

func DeleteYunikornQueue(cfg *types.Config, kubeClientset kubernetes.Interface, svc *types.Service) error

DeleteYunikornQueue delete a service's queue in Yunikorn's config

func GenerateToken

func GenerateToken() string

GenerateToken generates a random hexadecimal token

func ListExpose

func ListExpose(expose Expose, kubeClientset kubernetes.Interface) error

/Main function that list all the kubernetes components This function is not used, in the future could be usefull

func UpdateExpose

func UpdateExpose(expose Expose, kubeClientset kubernetes.Interface, cfg types.Config) error

/Main function that updates all the kubernetes components

func ValidateService

func ValidateService(serv types.Service) types.Service

Validate the input variables of the service Change the values if it is necesary

Types

type Expose

type Expose struct {
	Name         string ` binding:"required"`
	NameSpace    string ` binding:"required"`
	Image        string ` `
	Variables    map[string]string
	MaxScale     int32 `default:"10"`
	MinScale     int32 `default:"1"`
	Port         int   ` binding:"required" default:"80"`
	CpuThreshold int32 `default:"80"`
	EnableSGX    bool
}

type MinIOAdminClient

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

MinIOAdminClient struct to represent a MinIO Admin client to configure webhook notifications

func MakeMinIOAdminClient

func MakeMinIOAdminClient(cfg *types.Config) (*MinIOAdminClient, error)

MakeMinIOAdminClient creates a new MinIO Admin client to configure webhook notifications

func (*MinIOAdminClient) RegisterWebhook

func (minIOAdminClient *MinIOAdminClient) RegisterWebhook(name string, token string) error

RegisterWebhook registers a new webhook in the MinIO configuration

func (*MinIOAdminClient) RemoveWebhook

func (minIOAdminClient *MinIOAdminClient) RemoveWebhook(name string) error

RemoveWebhook removes an existent webhook in the MinIO configuration

func (*MinIOAdminClient) RestartServer

func (minIOAdminClient *MinIOAdminClient) RestartServer() error

RestartServer restarts a MinIO server to apply the configuration changes

type OpenfaasScaler

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

OpenfaasScaler struct to store the parameters required to scale OpenFaaS functions

func NewOFScaler

func NewOFScaler(kubeClientset kubernetes.Interface, cfg *types.Config) *OpenfaasScaler

NewOFScaler returns a pointer to a new OpenfaasScaler struct

func (*OpenfaasScaler) Start

func (ofs *OpenfaasScaler) Start()

Start starts the OpenFaaS scaler