servers

Documentation

Overview

nolint: golint

Index

• type Kubernetes
  • func NewKubernetesManagementServer(config *types.Configuration) (*Kubernetes, error)
  • func (k *Kubernetes) Create(ctx context.Context, r *module.ModuleCreateRequest) (*module.ModuleCreateResponse, error)
  • func (k *Kubernetes) Delete(ctx context.Context, r *module.ModuleDeleteRequest) (*module.ModuleDeleteResponse, error)
  • func (k *Kubernetes) Get(ctx context.Context, r *module.ModuleGetRequest) (*module.ModuleGetResponse, error)
  • func (k *Kubernetes) List(ctx context.Context, r *module.ModuleListRequest) (*module.ModuleListResponse, error)

Types

type Kubernetes

type Kubernetes struct {
	AzureSPSecretRef          string
	AzureBlobStorageSecretRef string
	AzureServiceBusSecretRef  string
	MongoDBSecretRef          string
	DispatcherImageName       string
	ID                        string
	// contains filtered or unexported fields
}

Kubernetes management server

func NewKubernetesManagementServer

func NewKubernetesManagementServer(config *types.Configuration) (*Kubernetes, error)

NewKubernetesManagementServer creates and initializes a new Kubernetes management server

func (*Kubernetes) Create

func (k *Kubernetes) Create(ctx context.Context, r *module.ModuleCreateRequest) (*module.ModuleCreateResponse, error)

Create will create the necessary services to support the execution of a module. This includes a configmap to hold the module's configuration and a deployment that runs a disptcher pod. The dispatcher pod will orchestrate the execution of the module itself.

func (*Kubernetes) Delete

func (k *Kubernetes) Delete(ctx context.Context, r *module.ModuleDeleteRequest) (*module.ModuleDeleteResponse, error)

Delete will delete all the components associated with a module deployment. This includes deleting the configmap that holds the module's configuration and the deployment of the module's dispatcher.

func (*Kubernetes) Get

func (k *Kubernetes) Get(ctx context.Context, r *module.ModuleGetRequest) (*module.ModuleGetResponse, error)

Get will get information about a deployed module

func (*Kubernetes) List

func (k *Kubernetes) List(ctx context.Context, r *module.ModuleListRequest) (*module.ModuleListResponse, error)

List will list all the deployments that have been created by this management server. It will simply list the deployment modules name.