Documentation ¶
Index ¶
- Constants
- 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 (minIOAdminClient *MinIOAdminClient) AddServiceToAllUsersGroup(bucketName string) error
- func (minIOAdminClient *MinIOAdminClient) AddUserToGroup(users []string, groupName 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) DeleteServiceGroup(groupName string) error
- func (minIOAdminClient *MinIOAdminClient) RegisterWebhook(name string, token string) error
- func (minIOAdminClient *MinIOAdminClient) RemoveWebhook(name string) error
- func (minIOAdminClient *MinIOAdminClient) RestartServer() error
- type OpenfaasScaler
Constants ¶
const ALL_USERS_GROUP = "all_users_group"
Variables ¶
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 ¶
/ 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 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 ¶
/Main function that updates all the kubernetes components
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) AddUserToGroup ¶
func (minIOAdminClient *MinIOAdminClient) AddUserToGroup(users []string, groupName string) error
AddUserToGroup adds user/users to a group
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) DeleteServiceGroup ¶
func (minIOAdminClient *MinIOAdminClient) DeleteServiceGroup(groupName string) error
DeleteServiceGroup empty the service group and policy
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