Giter VIP home page Giter VIP logo

gofaas's Introduction

gofaas

Go SDK for OpenFaaS This documentation is under (Beta)

This library allows you to quickly and easily use the openFasS API

How to use

Installation

Prerequisites

  • go
  • Installed openFasS

Install Package

	go get github.com/vitwit/gofaas

Setup Environment Variables

Initial Setup

cp .env.example .env

Update OPENFAAS_GATEWAY_ADDR, OPENFAAS_USER, OPENFAAS_PASSWORD, OPENFAAS_CLUSTER_TYPE

Environment Variable

Update the development environment with your keys, for example:

$ export OPENFAAS_GATEWAY_ADDR=http://127.0.0.1:8080
$ export OPENFAAS_USER='admin'
$ export OPENFAAS_PASSWORD='password'
$ export OPENFAAS_CLUSTER_TYPE='swarm'

Quick Start

Create a client

import faas "github.com/vitwit/gofaas"

client := faas.NewClient(&faas.FaasGatewayCredentials{
    Username:       os.Getenv("OPENFAAS_USER"),
    Password:       os.Getenv("OPENFAAS_PASSWORD"),
    GatewayAddress: os.Getenv("OPENFAAS_GATEWAY_ADDR"),
    ClusterType:    os.Getenv("OPENFAAS_CLUSTER_TYPE"),
})
getFunctions

getFunctions

Example

resp, err := cli.GetSystemFunctions()

Responses

Success 2XX

{
  "200": {
    "description": "List of deployed functions.",
    "schema": {
      "type": "array",
      "items": {
        "$ref": "#/definitions/FunctionListEntry"
      }
    }
  }
}
FunctionListEntry
createFunction

createFunction

Example

funcdef := &faas.FunctionDefintion{
   Service:    "nodeinfo12345",
   Network:    "func_functions",
   Image:      "functions/nodeinfo:latest",
   EnvProcess: "node main.js",
   EnvVars: faas.EnvVars{
       AdditionalProp1: "string",
       AdditionalProp2: "string",
       AdditionalProp3: "string",
   },
   Constraints: []string{
       "node.platform.os == linux",
   },
   Labels: map[string]string{
       "example": "func1",
   },
   Annotations: faas.Annotations{
       Topics: "awesome-kafka-topic",
       Foo:    "some",
   },
   RegistryAuth: "dXNlcjpwYXNzd29yZA==",
   Limits: faas.Limits{
       Memory: "128M",
       CPU:    "0.01",
   },
   Requests: faas.Requests{
       Memory: "128M",
       CPU:    "0.01",
   },
   ReadOnlyRootFilesystem: true,
}

resp, err := cli.CreateSystemFunctions(funcdef)

Responses

Success 2XX

{
  "202": {
    "description": "Accepted"
  }
}

Error 4XX

{
  "400": {
    "description": "Bad Request"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionListEntry
updateFunction

updateFunction

Example

update := &faas.FunctionDefintion{
   Service: "nodeinfo",
   Image:   "functions/nodeinfo:latest",
   Labels: map[string]string{
       "changedlabelkey": "changedlabelval",
   },
},
resp, err := cli.UpdateSystemFunctions(update)

Responses

Success 2XX

{
  "200": {
    "description": "Accepted"
  }
}

Error 4XX

{
  "400": {
    "description": "Bad Request"
  },
  "404": {
    "description": "Not Found"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionDefintion FunctionListEntry
deleteFunction

deleteFunction

Example

resp, err := cli.DeleteSystemFunction(&faas.DeleteFunctionBodyOpts{FunctionName: "nodeinfo"})

Responses

Success 2XX

{
  "200": {
    "description": "OK"
  }
}

Error 4XX

{
  "400": {
    "description": "Bad Request"
  },
  "404": {
    "description": "Not Found"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest FunctionListEntry
handleAlert

handleAlert

Example

sysalert := &faas.SystemAlertBodyOpts{
   Receiver: "scale-up",
   Status:   "firing",
   Alerts: []SystemAlertsStruct{
   {
   Status: "firing",
   Labels: SystemAlertLables{
       Alertname:    "APIHighInvocationRate",
       Code:         "200",
       FunctionName: "func_nodeinfo",
       Instance:     os.Getenv("OPENFAAS_GATEWAY_ADDR"),
       Job:          "gateway",
       Monitor:      "faas-monitor",
       Service:      "gateway",
       Severity:     "major",
       Value:        "8.998200359928017",
   },
   Annotations: SystemAlertAnnotations{
       Description: "High invocation total on gateway:8080",
       Summary:     "High invocation total on gateway:8080",
   },
   StartsAt: time.Now(),
   EndsAt:   time.Now().Add(time.Hour * 24),
   },
   },
   GroupLabels: GroupLabels{
   Alertname: "APIHighInvocationRate",
   Service:   "gateway",
   },
   CommonLabels: CommonLabels{
   Alertname:    "APIHighInvocationRate",
   Code:         "200",
   FunctionName: "func_nodeinfo",
   Instance:     os.Getenv("OPENFAAS_GATEWAY_ADDR"),
   Job:          "gateway",
   Monitor:      "faas-monitor",
   Service:      "gateway",
   Severity:     "major",
   Value:        "8.998200359928017",
   },
   CommonAnnotations: CommonAnnotations{
   Description: "High invocation total on gateway:8080",
   Summary:     "High invocation total on gateway:8080",
   },
   ExternalURL: os.Getenv("OPENFAAS_GATEWAY_ADDR"),
   Version:     "3",
}
resp, err := cli.SystemAlert(syslert)

Responses

Success 2XX

{
  "200": {
    "description": "Alert handled successfully"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal error with swarm or request JSON invalid"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined FunctionListEntry
invokeFunctionAsync

invokeFunctionAsync

Example

resp, err := cli.AsyncFunction(&faas.AsyncInvocationOpts{
    Body:         "Hey there!",
    FunctionName: "nodeinfo",
    CallbackURL:  "http://localhost:5000",
})

Responses

Success 2XX

{
  "202": {
    "description": "Request accepted and queued"
  }
}

Error 4XX

{
  "404": {
    "description": "Not Found"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined FunctionListEntry
invokeFunction

invokeFunction

Example

resp, err := cli.InvokeFunction(&faas.SyncInvocationOpts{
   Body:         "Hi there!",
   FunctionName: "nodeinfo",
})

Responses

Success 2XX

{
  "200": {
    "description": "Value returned from function"
  }
}

Error 4XX

{
  "404": {
    "description": "Not Found"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal server error"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined FunctionListEntry
scaleFunction

scaleFunction

Example

resp, err := cli.ScaleFunction(&faas.ScaleFunctionBodyOpts{
    Service:  "nodeinfo",
    Replicas: 2,
})

Responses

Success 2XX

{
  "200": {
    "description": "Scaling OK"
  },
  "202": {
    "description": "Scaling OK"
  }
}

Error 4XX

{
  "404": {
    "description": "Function not found"
  }
}

Error 5XX

{
  "500": {
    "description": "Error scaling function"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined FunctionListEntry
getFunctionSummary

getFunctionSummary

Example

resp, err := cli.GetFunctionSummary("nodeinfo")

Responses

Success 2XX

{
  "200": {
    "description": "Function Summary",
    "schema": {
      "$ref": "#/definitions/FunctionListEntry"
    }
  }
}

Error 4XX

{
  "404": {
    "description": "Not Found"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined FunctionListEntry FunctionListEntry
getSecrets

getSecrets

Example

resp, err := client.getSecrets()

Responses

Success 2XX

{
  "200": {
    "description": "List of submitted secrets.",
    "schema": {
      "$ref": "#/definitions/SecretName"
    }
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined FunctionListEntry FunctionListEntry SecretName
createSecret

createSecret

Example

resp, err := cli.CreateNewSecret(&faas.SecretBodyOpts{
    Name:  "key",
    Value: "val",
})

Responses

Success 2XX

{
  "201": {
    "description": "Created"
  }
}

Error 4XX

{
  "400": {
    "description": "Bad Request"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined Secret FunctionListEntry FunctionListEntry SecretName
updateSecret

updateSecret

Example

resp, err := cli.UpdateSecret(&faas.SecretBodyOpts{
    Name:  "key",
    Value: "updatedval",
})

Responses

Success 2XX

{
  "200": {
    "description": "Ok"
  }
}

Error 4XX

{
  "400": {
    "description": "Bad Request"
  },
  "404": {
    "description": "Not Found"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined Secret Secret FunctionListEntry FunctionListEntry SecretName
deleteSecret

deleteSecret

Example

resp, err := cli.DeleteSecret(&faas.SecretNameBodyOpts{
   Name: "key",
})

Responses

Success 2XX

{
  "204": {
    "description": "OK"
  }
}

Error 4XX

{
  "400": {
    "description": "Bad Request"
  },
  "404": {
    "description": "Not Found"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined Secret Secret SecretName FunctionListEntry FunctionListEntry SecretName
getLogsOfAFunction

getLogsOfAFunction

Example

resp, err := cli.GetSystemLogs(&faas.SystemLogsQueryOpts{
   Name:   "nodeinfo",
   Tail:   10,
   Follow: false,
   Since: "2020-01-22T07:48:18+00:00"
})

Responses

Success 2XX

{
  "200": {
    "description": "Newline delimited stream of log messages",
    "schema": {
      "$ref": "#/definitions/LogEntry"
    }
  }
}

Error 4XX

{
  "404": {
    "description": "Not Found"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined Secret Secret SecretName FunctionListEntry FunctionListEntry SecretName LogEntry
getInfo

getInfo

Example

resp, err := cli.GetSystemInfo()

Responses

Success 2XX

{
  "200": {
    "description": "Info result",
    "schema": {
      "$ref": "#/definitions/Info"
    }
  }
}

Error 4XX

{
  "404": {
    "description": "Provider does not support info endpoint"
  }
}

Error 5XX

{
  "500": {
    "description": "Internal Server Error"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined Secret Secret SecretName FunctionListEntry FunctionListEntry SecretName LogEntry Info
checkHealth

checkHealth

Example

resp, err := cli.GetHealthz()

Responses

Success 2XX

{
  "200": {
    "description": "Healthy"
  }
}

Error 5XX

{
  "500": {
    "description": "Not healthy"
  }
}
FunctionDefintion FunctionDefintion DeleteFunctionRequest undefined Secret Secret SecretName FunctionListEntry FunctionListEntry SecretName LogEntry Info

Modal Definations

Info-modal

{
 "type": "object",
 "properties": {
   "provider": {
     "type": "object",
     "description": "The OpenFaaS Provider",
     "properties": {
       "provider": {
         "type": "string",
         "example": "faas-swarm"
       },
       "orchestration": {
         "type": "string",
         "example": "swarm"
       },
       "version": {
         "type": "object",
         "description": "Version of the OpenFaaS Provider",
         "properties": {
           "commit_message": {
             "type": "string",
             "example": "Sample Message"
           },
           "sha": {
             "type": "string",
             "example": "7108418d9dd6b329ddff40e7393b3166f8160a88"
           },
           "release": {
             "type": "string",
             "format": "semver",
             "example": "0.2.6"
           }
         }
       }
     }
   },
   "version": {
     "type": "object",
     "description": "Version of the Gateway",
     "properties": {
       "commit_message": {
         "type": "string",
         "example": "Sample Message"
       },
       "sha": {
         "type": "string",
         "example": "7108418d9dd6b329ddff40e7393b3166f8160a88"
       },
       "release": {
         "type": "string",
         "format": "semver",
         "example": "0.8.9"
       }
     }
   },
   "arch": {
     "type": "string",
     "description": "Platform architecture",
     "example": "x86_64"
   }
 },
 "required": [
   "provider",
   "version"
 ]
}

DeleteFunctionRequest-modal

{
 "type": "object",
 "properties": {
   "functionName": {
     "type": "string",
     "description": "Name of deployed function",
     "example": "nodeinfo"
   }
 },
 "required": [
   "functionName"
 ]
}

FunctionDefintion-modal

{
 "type": "object",
 "properties": {
   "service": {
     "type": "string",
     "description": "Name of deployed function",
     "example": "nodeinfo"
   },
   "network": {
     "type": "string",
     "description": "Docker swarm network, usually func_functions",
     "example": "func_functions"
   },
   "image": {
     "type": "string",
     "description": "Docker image in accessible registry",
     "example": "functions/nodeinfo:latest"
   },
   "envProcess": {
     "type": "string",
     "description": "Process for watchdog to fork",
     "example": "node main.js"
   },
   "envVars": {
     "type": "object",
     "additionalProperties": {
       "type": "string"
     },
     "description": "Overrides to environmental variables"
   },
   "constraints": {
     "type": "array",
     "items": {
       "type": "string",
       "description": "Constraints are specific to OpenFaaS Provider",
       "example": "node.platform.os == linux"
     }
   },
   "labels": {
     "description": "A map of labels for making scheduling or routing decisions",
     "type": "object",
     "additionalProperties": {
       "type": "string"
     },
     "example": {
       "foo": "bar"
     }
   },
   "annotations": {
     "description": "A map of annotations for management, orchestration, events and build tasks",
     "type": "object",
     "additionalProperties": {
       "type": "string"
     },
     "example": {
       "topics": "awesome-kafka-topic",
       "foo": "bar"
     }
   },
   "secrets": {
     "type": "array",
     "items": {
       "type": "string",
       "description": "An array of names of secrets that are required to be loaded from the Docker Swarm.",
       "example": "secret-name-1"
     }
   },
   "registryAuth": {
     "type": "string",
     "description": "Private registry base64-encoded basic auth (as present in ~/.docker/config.json)",
     "example": "dXNlcjpwYXNzd29yZA=="
   },
   "limits": {
     "type": "object",
     "properties": {
       "memory": {
         "type": "string",
         "example": "128M"
       },
       "cpu": {
         "type": "string",
         "example": "0.01"
       }
     }
   },
   "requests": {
     "type": "object",
     "properties": {
       "memory": {
         "type": "string",
         "example": "128M"
       },
       "cpu": {
         "type": "string",
         "example": "0.01"
       }
     }
   },
   "readOnlyRootFilesystem": {
     "type": "boolean",
     "description": "Make the root filesystem of the function read-only"
   }
 },
 "required": [
   "service",
   "image",
   "envProcess"
 ]
}

FunctionListEntry-modal

{
 "type": "object",
 "properties": {
   "name": {
     "description": "The name of the function",
     "type": "string",
     "example": "nodeinfo"
   },
   "image": {
     "description": "The fully qualified docker image name of the function",
     "type": "string",
     "example": "functions/nodeinfo:latest"
   },
   "invocationCount": {
     "description": "The amount of invocations for the specified function",
     "type": "number",
     "format": "integer",
     "example": 1337
   },
   "replicas": {
     "description": "The current minimal ammount of replicas",
     "type": "number",
     "format": "integer",
     "example": 2
   },
   "availableReplicas": {
     "description": "The current available amount of replicas",
     "type": "number",
     "format": "integer",
     "example": 2
   },
   "envProcess": {
     "description": "Process for watchdog to fork",
     "type": "string",
     "example": "node main.js"
   },
   "labels": {
     "description": "A map of labels for making scheduling or routing decisions",
     "type": "object",
     "additionalProperties": {
       "type": "string"
     },
     "example": {
       "foo": "bar"
     }
   },
   "annotations": {
     "description": "A map of annotations for management, orchestration, events and build tasks",
     "type": "object",
     "additionalProperties": {
       "type": "string"
     },
     "example": {
       "topics": "awesome-kafka-topic",
       "foo": "bar"
     }
   }
 },
 "required": [
   "name",
   "image",
   "invocationCount",
   "replicas",
   "availableReplicas",
   "envProcess",
   "labels"
 ]
}

Secret-modal

{
 "type": "object",
 "properties": {
   "name": {
     "type": "string",
     "description": "Name of secret",
     "example": "aws-key"
   },
   "value": {
     "type": "string",
     "description": "Value of secret in plain-text",
     "example": "changeme"
   }
 },
 "required": [
   "name"
 ]
}

LogEntry-modal

{
 "type": "object",
 "properties": {
   "name": {
     "type": "string",
     "description": "the function name"
   },
   "instance": {
     "type": "string",
     "description": "the name/id of the specific function instance"
   },
   "timestamp": {
     "type": "string",
     "format": "date-time",
     "description": "the timestamp of when the log message was recorded"
   },
   "text": {
     "type": "string",
     "description": "raw log message content"
   }
 }
}

SecretName-modal

{
 "type": "object",
 "properties": {
   "name": {
     "type": "string",
     "description": "Name of secret",
     "example": "aws-key"
   }
 }
}

gofaas's People

Contributors

akshay-root avatar akshaydotsh avatar anilcse avatar gosuri avatar prathyushalakkireddy avatar

Stargazers

avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar

Watchers

avatar avatar avatar

Forkers

gosuri bhavyabindumetla backwardn ftwh

gofaas's Issues

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.