README
¶
Kubernetes Virtual Kubelet with Service Fabric Mesh
Service Fabric Mesh is a fully managed service that enables developers to deploy microservices applications without managing virtual machines, storage, or networking. Applications hosted on Service Fabric Mesh run and scale without you worrying about the infrastructure powering them.
The Virtual kubelet integration allows you to use the Kubernetes API to burst out compute to Service Fabric Mesh and schedule pods as Mesh Applications.
Status: Experimental
This provider is currently in the experimental stages. Contributions are welcome!
Setup
The provider expects the following environment variables to be configured:
- AZURE_CLIENT_ID
- AZURE_CLIENT_SECRET
- AZURE_SUBSCRIPTION_ID
- AZURE_TENANT_ID
- RESOURCE_GROUP
- REGION
Quick Start
Run the Virtual Kubelet
./virtual-kubelet --provider=sfmesh --taint azure.com/sfmesh
Create pod yaml:
$ cat pod-nginx
apiVersion: v1
kind: Pod
metadata:
name: nginx
spec:
nodeName: virtual-kubelet
containers:
- name: nginx
image: nginx:latest
ports:
- containerPort: 80
tolerations:
- key: azure.com/sfmesh
effect: NoSchedule
create pod
$ kubectl create -f pod-nginx
list containers on Service Fabric Mesh
$ az mesh app list -o table
Name ResourceGroup ProvisioningState Location
------ --------------- ------------------- ----------
nginx myResourceGroup Succeeded eastus
Documentation
¶
Index ¶
- type AuthConfig
- type SFMeshProvider
- func (p *SFMeshProvider) Capacity(ctx context.Context) v1.ResourceList
- func (p *SFMeshProvider) CreatePod(ctx context.Context, pod *v1.Pod) error
- func (p *SFMeshProvider) DeletePod(ctx context.Context, pod *v1.Pod) (err error)
- func (p *SFMeshProvider) ExecInContainer(name string, uid types.UID, container string, cmd []string, in io.Reader, ...) error
- func (p *SFMeshProvider) GetContainerLogs(ctx context.Context, namespace, podName, containerName string, tail int) (string, error)
- func (p *SFMeshProvider) GetPod(ctx context.Context, namespace, name string) (pod *v1.Pod, err error)
- func (p *SFMeshProvider) GetPodFullName(namespace string, pod string) string
- func (p *SFMeshProvider) GetPodStatus(ctx context.Context, namespace, name string) (*v1.PodStatus, error)
- func (p *SFMeshProvider) GetPods(ctx context.Context) ([]*v1.Pod, error)
- func (p *SFMeshProvider) NodeAddresses(ctx context.Context) []v1.NodeAddress
- func (p *SFMeshProvider) NodeConditions(ctx context.Context) []v1.NodeCondition
- func (p *SFMeshProvider) NodeDaemonEndpoints(ctx context.Context) *v1.NodeDaemonEndpoints
- func (p *SFMeshProvider) OperatingSystem() string
- func (p *SFMeshProvider) UpdatePod(ctx context.Context, pod *v1.Pod) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthConfig ¶
type AuthConfig struct {
Username string `json:"username,omitempty"`
Password string `json:"password,omitempty"`
Auth string `json:"auth,omitempty"`
Email string `json:"email,omitempty"`
ServerAddress string `json:"serveraddress,omitempty"`
IdentityToken string `json:"identitytoken,omitempty"`
RegistryToken string `json:"registrytoken,omitempty"`
}
AuthConfig is the secret returned from an ImageRegistryCredential
type SFMeshProvider ¶
type SFMeshProvider struct {
// contains filtered or unexported fields
}
SFMeshProvider implements the Virtual Kubelet provider interface
func NewSFMeshProvider ¶
func NewSFMeshProvider(rm *manager.ResourceManager, nodeName, operatingSystem string, internalIP string, daemonEndpointPort int32) (*SFMeshProvider, error)
NewSFMeshProvider creates a new SFMeshProvider
func (*SFMeshProvider) Capacity ¶
func (p *SFMeshProvider) Capacity(ctx context.Context) v1.ResourceList
Capacity returns a resource list containing the capacity limits set for SF Mesh.
func (*SFMeshProvider) ExecInContainer ¶
func (p *SFMeshProvider) ExecInContainer(name string, uid types.UID, container string, cmd []string, in io.Reader, out, err io.WriteCloser, tty bool, resize <-chan remotecommand.TerminalSize, timeout time.Duration) error
ExecInContainer executes a command in a container in the pod, copying data between in/out/err and the container's stdin/stdout/stderr.
func (*SFMeshProvider) GetContainerLogs ¶
func (p *SFMeshProvider) GetContainerLogs(ctx context.Context, namespace, podName, containerName string, tail int) (string, error)
GetContainerLogs retrieves the logs of a container by name.
func (*SFMeshProvider) GetPod ¶
func (p *SFMeshProvider) GetPod(ctx context.Context, namespace, name string) (pod *v1.Pod, err error)
GetPod returns a pod by name that is running inside SF Mesh. returns nil if a pod by that name is not found.
func (*SFMeshProvider) GetPodFullName ¶
func (p *SFMeshProvider) GetPodFullName(namespace string, pod string) string
GetPodFullName gets the full pod name as defined in the provider context
func (*SFMeshProvider) GetPodStatus ¶
func (p *SFMeshProvider) GetPodStatus(ctx context.Context, namespace, name string) (*v1.PodStatus, error)
GetPodStatus returns the status of a pod by name that is "running". returns nil if a pod by that name is not found.
func (*SFMeshProvider) GetPods ¶
GetPods returns a list of all pods known to be running within SF Mesh.
func (*SFMeshProvider) NodeAddresses ¶
func (p *SFMeshProvider) NodeAddresses(ctx context.Context) []v1.NodeAddress
NodeAddresses returns a list of addresses for the node status within Kubernetes.
func (*SFMeshProvider) NodeConditions ¶
func (p *SFMeshProvider) NodeConditions(ctx context.Context) []v1.NodeCondition
NodeConditions returns a list of conditions (Ready, OutOfDisk, etc), for updates to the node status within Kubernetes.
func (*SFMeshProvider) NodeDaemonEndpoints ¶
func (p *SFMeshProvider) NodeDaemonEndpoints(ctx context.Context) *v1.NodeDaemonEndpoints
NodeDaemonEndpoints returns NodeDaemonEndpoints for the node status within Kubernetes.
func (*SFMeshProvider) OperatingSystem ¶
func (p *SFMeshProvider) OperatingSystem() string
OperatingSystem returns the operating system for this provider. This is a noop to default to Linux for now.
Source Files