utils

Documentation

Index

• Constants
• func AddYunikornQueue(cfg *types.Config, kubeClientset kubernetes.Interface, svc *types.Service) error
• func DeleteYunikornQueue(cfg *types.Config, kubeClientset kubernetes.Interface, svc *types.Service) error
• func GenerateToken() string
• type MinIOAdminClient
  • func MakeMinIOAdminClient(cfg *types.Config) (*MinIOAdminClient, error)
  • func (minIOAdminClient *MinIOAdminClient) AddServiceToAllUsersGroup(bucketName string) error
  • func (minIOAdminClient *MinIOAdminClient) CreateAllUsersGroup() error
  • func (minIOAdminClient *MinIOAdminClient) CreateMinIOUser(ak string, sk string) error
  • func (minIOAdminClient *MinIOAdminClient) CreateServiceGroup(bucketName string) error
  • func (minIOAdminClient *MinIOAdminClient) PrivateToPublicBucket(bucketName string) error
  • func (minIOAdminClient *MinIOAdminClient) PublicToPrivateBucket(bucketName string, allowedUsers []string) error
  • func (minIOAdminClient *MinIOAdminClient) RegisterWebhook(name string, token string) error
  • func (minIOAdminClient *MinIOAdminClient) RemoveWebhook(name string) error
  • func (minIOAdminClient *MinIOAdminClient) RemovedServiceFromAllUsersGroup(bucketName string) error
  • func (minIOAdminClient *MinIOAdminClient) RestartServer() error
  • func (minIOAdminClient *MinIOAdminClient) UpdateUsersInGroup(users []string, groupName string, remove bool) error
• type OpenfaasScaler
  • func NewOFScaler(kubeClientset kubernetes.Interface, cfg *types.Config) *OpenfaasScaler
  • func (ofs *OpenfaasScaler) Start()
• type Policy
• type Statement

Constants

const ALL_USERS_GROUP = "all_users_group"

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 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

Types

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) AddServiceToAllUsersGroup

func (minIOAdminClient *MinIOAdminClient) AddServiceToAllUsersGroup(bucketName string) error

AddServiceToAllUsersGroup associates policy of all users to a service

func (*MinIOAdminClient) CreateAllUsersGroup

func (minIOAdminClient *MinIOAdminClient) CreateAllUsersGroup() error

CreateAllUsersGroup creates a group used for public services

func (*MinIOAdminClient) CreateMinIOUser

func (minIOAdminClient *MinIOAdminClient) CreateMinIOUser(ak string, sk string) error

CreateMinIOUser creates a new user for multitenancy

func (*MinIOAdminClient) CreateServiceGroup

func (minIOAdminClient *MinIOAdminClient) CreateServiceGroup(bucketName string) error

CreateServiceGroup creates a MinIO group and its associated policy for a service

func (*MinIOAdminClient) PrivateToPublicBucket

func (minIOAdminClient *MinIOAdminClient) PrivateToPublicBucket(bucketName string) error

func (*MinIOAdminClient) PublicToPrivateBucket

func (minIOAdminClient *MinIOAdminClient) PublicToPrivateBucket(bucketName string, allowedUsers []string) error

TODO refactor to delete duplicated code

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) RemovedServiceFromAllUsersGroup

func (minIOAdminClient *MinIOAdminClient) RemovedServiceFromAllUsersGroup(bucketName string) error

AddServiceToAllUsersGroup associates policy of all users to a service

func (*MinIOAdminClient) RestartServer

func (minIOAdminClient *MinIOAdminClient) RestartServer() error

RestartServer restarts a MinIO server to apply the configuration changes

func (*MinIOAdminClient) UpdateUsersInGroup

func (minIOAdminClient *MinIOAdminClient) UpdateUsersInGroup(users []string, groupName string, remove bool) error

UpdateUsersGroup

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

type Policy

type Policy struct {
	Version   string      `json:"Version"`
	Statement []Statement `json:"Statement"`
}

type Statement

type Statement struct {
	Effect   string   `json:"Effect"`
	Action   []string `json:"Action"`
	Resource []string `json:"Resource"`
}

Define the policy structure using Go structs