Traffic split annotations - canary deployment

src/strategyHelpers/blueGreen/smiBlueGreenHelper.ts

@@ -74,7 +74,7 @@ export async function rejectBlueGreenSMI(
    // get all kubernetes objects defined in manifest files
    const manifestObjects: BlueGreenManifests = getManifestObjects(filePaths)
 
-   // route trafficsplit to stable deploymetns
+   // route trafficsplit to stable deployments
    await routeBlueGreenSMI(
       kubectl,
       NONE_LABEL_VALUE,

src/strategyHelpers/canary/canaryHelper.ts

@@ -77,9 +77,10 @@ export function getNewCanaryResource(
 export async function fetchResource(
    kubectl: Kubectl,
    kind: string,
-   name: string
+   name: string,
+   annotations: {[key: string] : string} = {}
 ) {
-   const result = await kubectl.getResource(kind, name)
+   const result = await kubectl.getResource(kind, name, annotations)
 
    if (!result || result?.stderr) {
       return null

src/strategyHelpers/canary/smiCanaryHelper.ts

@@ -25,12 +25,14 @@ export async function deploySMICanary(filePaths: string[], kubectl: Kubectl) {
       yaml.safeLoadAll(fileContents, (inputObject) => {
          const name = inputObject.metadata.name
          const kind = inputObject.kind
+         const annotations = inputObject.metadata.annotations
 
          if (isDeploymentEntity(kind)) {
             const stableObject = canaryDeploymentHelper.fetchResource(
                kubectl,
                kind,
-               name
+               name,
+               annotations
             )
 
             if (!stableObject) {

src/types/kubectl.test.ts

@@ -289,12 +289,13 @@ describe('Kubectl class', () => {
       it('gets resource', async () => {
          const resourceType = 'type'
          const name = 'name'
-         expect(await kubectl.getResource(resourceType, name)).toBe(execReturn)
+         const annotations: {[key: string] : string} = {}
+         expect(await kubectl.getResource(resourceType, name, annotations)).toBe(execReturn)
          expect(exec.getExecOutput).toBeCalledWith(
             kubectlPath,
             [
                'get',
-               `${resourceType}/${name}`,
+               `${resourceType}/${name}/${annotations}`,
                '-o',
                'json',
                '--namespace',

src/types/kubectl.ts

@@ -135,11 +135,12 @@ export class Kubectl {
 
    public async getResource(
       resourceType: string,
-      name: string
+      name: string,
+      annotations: {[key: string] : string} = {}
    ): Promise<ExecOutput> {
       return await this.execute([
          'get',
-         `${resourceType}/${name}`,
+         `${resourceType}/${name}/${annotations}`,
          '-o',
          'json'
       ])