Documentation
¶
Overview ¶
nolint: golint
Index ¶
- type Kubernetes
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files