totole/m3o-go
1
0
Fork 0
mirror of https://github.com/kevin-DL/m3o-go.git synced 2026-01-24 07:25:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Compare commits

base: totole:v0.5.0
Branches Tags
totole:main totole:task/update_opening_hours_type totole:beta totole:ci totole:master totole:addservices totole:fix totole:concept
totole:v0.8.0 totole:v0.7.0 totole:v0.6.0 totole:v0.5.0 totole:v0.4.0 totole:v0.3.0 totole:v0.2.0 totole:v0.1.0
..
compare: totole:master
Branches Tags
totole:task/update_opening_hours_type totole:main totole:beta totole:ci totole:master totole:addservices totole:fix totole:concept
totole:v0.8.0 totole:v0.7.0 totole:v0.6.0 totole:v0.5.0 totole:v0.4.0 totole:v0.3.0 totole:v0.2.0 totole:v0.1.0

2 Commits
v0.5.0 ... master

Author SHA1 Message Date
Asim Aslam
a8ae6694c6 add notes example 2021-11-02 11:59:39 +00:00
m3o-actions
58743a5a31 Commit from m3o/m3o action 2021-11-01 15:38:48 +00:00
307 changed files with 1102 additions and 7862 deletions
Expand all files Collapse all files

31
.github/workflows/generate.yml vendored
View File

@@ -1,31 +0,0 @@
name: Test Clients
on:
push:
branches:
- main
- beta
- ci
jobs:
generate:
name: Test Clients
runs-on: ubuntu-latest
steps:
- name: Check out repo
uses: actions/checkout@v2
with:
path: clients
#ref: main
- name: Test
working-directory: clients
env:
M3O_API_TOKEN: ${{ secrets.M3O_API_TOKEN }}
run: |
# stream is temporarily excluded as it hangs forever because test does not close connection
# @TODO remove "idempotent: true" from stream example
O=$(find . -name ".run" | grep -v stream | xargs -n1 dirname | xargs -n1 go run)
echo $O
if grep -q Detail "$O"; then
exit 1
fi

8
address/address.go
View File

@@ -18,10 +18,8 @@ type AddressService struct {
// Lookup a list of UK addresses by postcode // Lookup a list of UK addresses by postcode
func (t *AddressService) LookupPostcode(request *LookupPostcodeRequest) (*LookupPostcodeResponse, error) { func (t *AddressService) LookupPostcode(request *LookupPostcodeRequest) (*LookupPostcodeResponse, error) {
rsp := &LookupPostcodeResponse{} rsp := &LookupPostcodeResponse{}
return rsp, t.client.Call("address", "LookupPostcode", request, rsp) return rsp, t.client.Call("address", "LookupPostcode", request, rsp)
} }
type LookupPostcodeRequest struct { type LookupPostcodeRequest struct {
@@ -35,13 +33,13 @@ type LookupPostcodeResponse struct {
type Record struct { type Record struct {
// building name // building name
BuildingName string `json:"building_name"` BuildingName string `json:"buildingName"`
// the county // the county
County string `json:"county"` County string `json:"county"`
// line one of address // line one of address
LineOne string `json:"line_one"` LineOne string `json:"lineOne"`
// line two of address // line two of address
LineTwo string `json:"line_two"` LineTwo string `json:"lineTwo"`
// dependent locality // dependent locality
Locality string `json:"locality"` Locality string `json:"locality"`
// organisation if present // organisation if present

2
answer/answer.go
View File

@@ -18,10 +18,8 @@ type AnswerService struct {
// Ask a question and receive an instant answer // Ask a question and receive an instant answer
func (t *AnswerService) Question(request *QuestionRequest) (*QuestionResponse, error) { func (t *AnswerService) Question(request *QuestionRequest) (*QuestionResponse, error) {
rsp := &QuestionResponse{} rsp := &QuestionResponse{}
return rsp, t.client.Call("answer", "Question", request, rsp) return rsp, t.client.Call("answer", "Question", request, rsp)
} }
type QuestionRequest struct { type QuestionRequest struct {

202
app/app.go
View File

@@ -1,202 +0,0 @@
package app
import (
"go.m3o.com/client"
)
func NewAppService(token string) *AppService {
return &AppService{
client: client.NewClient(&client.Options{
Token: token,
}),
}
}
type AppService struct {
client *client.Client
}
// Delete an app
func (t *AppService) Delete(request *DeleteRequest) (*DeleteResponse, error) {
rsp := &DeleteResponse{}
return rsp, t.client.Call("app", "Delete", request, rsp)
}
// List all the apps
func (t *AppService) List(request *ListRequest) (*ListResponse, error) {
rsp := &ListResponse{}
return rsp, t.client.Call("app", "List", request, rsp)
}
// Return the support regions
func (t *AppService) Regions(request *RegionsRequest) (*RegionsResponse, error) {
rsp := &RegionsResponse{}
return rsp, t.client.Call("app", "Regions", request, rsp)
}
// Reserve apps beyond the free quota. Call Run after.
func (t *AppService) Reserve(request *ReserveRequest) (*ReserveResponse, error) {
rsp := &ReserveResponse{}
return rsp, t.client.Call("app", "Reserve", request, rsp)
}
// Resolve an app by id to its raw backend endpoint
func (t *AppService) Resolve(request *ResolveRequest) (*ResolveResponse, error) {
rsp := &ResolveResponse{}
return rsp, t.client.Call("app", "Resolve", request, rsp)
}
// Run an app from a source repo. Specify region etc.
func (t *AppService) Run(request *RunRequest) (*RunResponse, error) {
rsp := &RunResponse{}
return rsp, t.client.Call("app", "Run", request, rsp)
}
// Get the status of an app
func (t *AppService) Status(request *StatusRequest) (*StatusResponse, error) {
rsp := &StatusResponse{}
return rsp, t.client.Call("app", "Status", request, rsp)
}
// Update the app. The latest source code will be downloaded, built and deployed.
func (t *AppService) Update(request *UpdateRequest) (*UpdateResponse, error) {
rsp := &UpdateResponse{}
return rsp, t.client.Call("app", "Update", request, rsp)
}
type DeleteRequest struct {
// name of the app
Name string `json:"name"`
}
type DeleteResponse struct {
}
type ListRequest struct {
}
type ListResponse struct {
// all the apps
Services []Service `json:"services"`
}
type RegionsRequest struct {
}
type RegionsResponse struct {
Regions []string `json:"regions"`
}
type Reservation struct {
// time of reservation
Created string `json:"created"`
// time reservation expires
Expires string `json:"expires"`
// name of the app
Name string `json:"name"`
// owner id
Owner string `json:"owner"`
// associated token
Token string `json:"token"`
}
type ReserveRequest struct {
// name of your app e.g helloworld
Name string `json:"name"`
}
type ReserveResponse struct {
// The app reservation
Reservation *Reservation `json:"reservation"`
}
type ResolveRequest struct {
// the service id
Id string `json:"id"`
}
type ResolveResponse struct {
// the end provider url
Url string `json:"url"`
}
type RunRequest struct {
// branch. defaults to master
Branch string `json:"branch"`
// associatede env vars to pass in
EnvVars map[string]string `json:"env_vars"`
// name of the app
Name string `json:"name"`
// port to run on
Port int32 `json:"port"`
// region to run in
Region string `json:"region"`
// source repository
Repo string `json:"repo"`
}
type RunResponse struct {
// The running service
Service *Service `json:"service"`
}
type Service struct {
// branch of code
Branch string `json:"branch"`
// time of creation
Created string `json:"created"`
// custom domains
CustomDomains string `json:"custom_domains"`
// associated env vars
EnvVars map[string]string `json:"env_vars"`
// unique id
Id string `json:"id"`
// name of the app
Name string `json:"name"`
// port running on
Port int32 `json:"port"`
// region running in
Region string `json:"region"`
// source repository
Repo string `json:"repo"`
// status of the app
Status string `json:"status"`
// last updated
Updated string `json:"updated"`
// app url
Url string `json:"url"`
}
type StatusRequest struct {
// name of the app
Name string `json:"name"`
}
type StatusResponse struct {
// running service info
Service *Service `json:"service"`
}
type UpdateRequest struct {
// name of the app
Name string `json:"name"`
}
type UpdateResponse struct {
}

46
avatar/avatar.go
View File

@@ -1,46 +0,0 @@
package avatar
import (
"go.m3o.com/client"
)
func NewAvatarService(token string) *AvatarService {
return &AvatarService{
client: client.NewClient(&client.Options{
Token: token,
}),
}
}
type AvatarService struct {
client *client.Client
}
//
func (t *AvatarService) Generate(request *GenerateRequest) (*GenerateResponse, error) {
rsp := &GenerateResponse{}
return rsp, t.client.Call("avatar", "Generate", request, rsp)
}
type GenerateRequest struct {
// encode format of avatar image, `png` or `jpeg`, default is `jpeg`
Format string `json:"format"`
// avatar's gender, `male` or `female`, default is `male`
Gender string `json:"gender"`
// if upload to m3o CDN, default is `false`
// if update = true, then it'll return the CDN url
Upload bool `json:"upload"`
// avatar's username, unique username will generates the unique avatar;
// if username == "", will generate a random avatar in every request
// if upload == true, username will be used as CDN filename rather than a random uuid string
Username string `json:"username"`
}
type GenerateResponse struct {
// base64encode string of the avatar image
Base64 string `json:"base64"`
// Micro's CDN url of the avatar image
Url string `json:"url"`
}

18
cache/cache.go vendored
View File

@@ -16,44 +16,34 @@ type CacheService struct {
client *client.Client client *client.Client
} }
// Decrement a value (if it's a number). If key not found it is equivalent to set. // Decrement a value (if it's a number)
func (t *CacheService) Decrement(request *DecrementRequest) (*DecrementResponse, error) { func (t *CacheService) Decrement(request *DecrementRequest) (*DecrementResponse, error) {
rsp := &DecrementResponse{} rsp := &DecrementResponse{}
return rsp, t.client.Call("cache", "Decrement", request, rsp) return rsp, t.client.Call("cache", "Decrement", request, rsp)
} }
// Delete a value from the cache. If key not found a success response is returned. // Delete a value from the cache
func (t *CacheService) Delete(request *DeleteRequest) (*DeleteResponse, error) { func (t *CacheService) Delete(request *DeleteRequest) (*DeleteResponse, error) {
rsp := &DeleteResponse{} rsp := &DeleteResponse{}
return rsp, t.client.Call("cache", "Delete", request, rsp) return rsp, t.client.Call("cache", "Delete", request, rsp)
} }
// Get an item from the cache by key. If key is not found, an empty response is returned. // Get an item from the cache by key
func (t *CacheService) Get(request *GetRequest) (*GetResponse, error) { func (t *CacheService) Get(request *GetRequest) (*GetResponse, error) {
rsp := &GetResponse{} rsp := &GetResponse{}
return rsp, t.client.Call("cache", "Get", request, rsp) return rsp, t.client.Call("cache", "Get", request, rsp)
} }
// Increment a value (if it's a number). If key not found it is equivalent to set. // Increment a value (if it's a number)
func (t *CacheService) Increment(request *IncrementRequest) (*IncrementResponse, error) { func (t *CacheService) Increment(request *IncrementRequest) (*IncrementResponse, error) {
rsp := &IncrementResponse{} rsp := &IncrementResponse{}
return rsp, t.client.Call("cache", "Increment", request, rsp) return rsp, t.client.Call("cache", "Increment", request, rsp)
} }
// Set an item in the cache. Overwrites any existing value already set. // Set an item in the cache. Overwrites any existing value already set.
func (t *CacheService) Set(request *SetRequest) (*SetResponse, error) { func (t *CacheService) Set(request *SetRequest) (*SetResponse, error) {
rsp := &SetResponse{} rsp := &SetResponse{}
return rsp, t.client.Call("cache", "Set", request, rsp) return rsp, t.client.Call("cache", "Set", request, rsp)
} }
type DecrementRequest struct { type DecrementRequest struct {

4
client/client_test.go
View File

@@ -6,10 +6,6 @@ import (
) )
func TestBasicCall(t *testing.T) { func TestBasicCall(t *testing.T) {
if v := os.Getenv("IN_TRAVIS"); v == "yes" {
return
}
response := map[string]interface{}{} response := map[string]interface{}{}
if err := NewClient(&Options{ if err := NewClient(&Options{
Token: os.Getenv("TOKEN"), Token: os.Getenv("TOKEN"),

16
crypto/crypto.go
View File

@@ -18,34 +18,26 @@ type CryptoService struct {
// Returns the history for the previous close // Returns the history for the previous close
func (t *CryptoService) History(request *HistoryRequest) (*HistoryResponse, error) { func (t *CryptoService) History(request *HistoryRequest) (*HistoryResponse, error) {
rsp := &HistoryResponse{} rsp := &HistoryResponse{}
return rsp, t.client.Call("crypto", "History", request, rsp) return rsp, t.client.Call("crypto", "History", request, rsp)
} }
// Get news related to a currency // Get news related to a currency
func (t *CryptoService) News(request *NewsRequest) (*NewsResponse, error) { func (t *CryptoService) News(request *NewsRequest) (*NewsResponse, error) {
rsp := &NewsResponse{} rsp := &NewsResponse{}
return rsp, t.client.Call("crypto", "News", request, rsp) return rsp, t.client.Call("crypto", "News", request, rsp)
} }
// Get the last price for a given crypto ticker // Get the last price for a given crypto ticker
func (t *CryptoService) Price(request *PriceRequest) (*PriceResponse, error) { func (t *CryptoService) Price(request *PriceRequest) (*PriceResponse, error) {
rsp := &PriceResponse{} rsp := &PriceResponse{}
return rsp, t.client.Call("crypto", "Price", request, rsp) return rsp, t.client.Call("crypto", "Price", request, rsp)
} }
// Get the last quote for a given crypto ticker // Get the last quote for a given crypto ticker
func (t *CryptoService) Quote(request *QuoteRequest) (*QuoteResponse, error) { func (t *CryptoService) Quote(request *QuoteRequest) (*QuoteResponse, error) {
rsp := &QuoteResponse{} rsp := &QuoteResponse{}
return rsp, t.client.Call("crypto", "Quote", request, rsp) return rsp, t.client.Call("crypto", "Quote", request, rsp)
} }
type Article struct { type Article struct {
@@ -114,13 +106,13 @@ type QuoteRequest struct {
type QuoteResponse struct { type QuoteResponse struct {
// the asking price // the asking price
AskPrice float64 `json:"ask_price"` AskPrice float64 `json:"askPrice"`
// the ask size // the ask size
AskSize float64 `json:"ask_size"` AskSize float64 `json:"askSize"`
// the bidding price // the bidding price
BidPrice float64 `json:"bid_price"` BidPrice float64 `json:"bidPrice"`
// the bid size // the bid size
BidSize float64 `json:"bid_size"` BidSize float64 `json:"bidSize"`
// the crypto symbol // the crypto symbol
Symbol string `json:"symbol"` Symbol string `json:"symbol"`
// the UTC timestamp of the quote // the UTC timestamp of the quote

8
currency/currency.go
View File

@@ -18,34 +18,26 @@ type CurrencyService struct {
// Codes returns the supported currency codes for the API // Codes returns the supported currency codes for the API
func (t *CurrencyService) Codes(request *CodesRequest) (*CodesResponse, error) { func (t *CurrencyService) Codes(request *CodesRequest) (*CodesResponse, error) {
rsp := &CodesResponse{} rsp := &CodesResponse{}
return rsp, t.client.Call("currency", "Codes", request, rsp) return rsp, t.client.Call("currency", "Codes", request, rsp)
} }
// Convert returns the currency conversion rate between two pairs e.g USD/GBP // Convert returns the currency conversion rate between two pairs e.g USD/GBP
func (t *CurrencyService) Convert(request *ConvertRequest) (*ConvertResponse, error) { func (t *CurrencyService) Convert(request *ConvertRequest) (*ConvertResponse, error) {
rsp := &ConvertResponse{} rsp := &ConvertResponse{}
return rsp, t.client.Call("currency", "Convert", request, rsp) return rsp, t.client.Call("currency", "Convert", request, rsp)
} }
// Returns the historic rates for a currency on a given date // Returns the historic rates for a currency on a given date
func (t *CurrencyService) History(request *HistoryRequest) (*HistoryResponse, error) { func (t *CurrencyService) History(request *HistoryRequest) (*HistoryResponse, error) {
rsp := &HistoryResponse{} rsp := &HistoryResponse{}
return rsp, t.client.Call("currency", "History", request, rsp) return rsp, t.client.Call("currency", "History", request, rsp)
} }
// Rates returns the currency rates for a given code e.g USD // Rates returns the currency rates for a given code e.g USD
func (t *CurrencyService) Rates(request *RatesRequest) (*RatesResponse, error) { func (t *CurrencyService) Rates(request *RatesRequest) (*RatesResponse, error) {
rsp := &RatesResponse{} rsp := &RatesResponse{}
return rsp, t.client.Call("currency", "Rates", request, rsp) return rsp, t.client.Call("currency", "Rates", request, rsp)
} }
type Code struct { type Code struct {

66
db/db.go
View File

@@ -18,74 +18,38 @@ type DbService struct {
// Count records in a table // Count records in a table
func (t *DbService) Count(request *CountRequest) (*CountResponse, error) { func (t *DbService) Count(request *CountRequest) (*CountResponse, error) {
rsp := &CountResponse{} rsp := &CountResponse{}
return rsp, t.client.Call("db", "Count", request, rsp) return rsp, t.client.Call("db", "Count", request, rsp)
} }
// Create a record in the database. Optionally include an "id" field otherwise it's set automatically. // Create a record in the database. Optionally include an "id" field otherwise it's set automatically.
func (t *DbService) Create(request *CreateRequest) (*CreateResponse, error) { func (t *DbService) Create(request *CreateRequest) (*CreateResponse, error) {
rsp := &CreateResponse{} rsp := &CreateResponse{}
return rsp, t.client.Call("db", "Create", request, rsp) return rsp, t.client.Call("db", "Create", request, rsp)
} }
// Delete a record in the database by id. // Delete a record in the database by id.
func (t *DbService) Delete(request *DeleteRequest) (*DeleteResponse, error) { func (t *DbService) Delete(request *DeleteRequest) (*DeleteResponse, error) {
rsp := &DeleteResponse{} rsp := &DeleteResponse{}
return rsp, t.client.Call("db", "Delete", request, rsp) return rsp, t.client.Call("db", "Delete", request, rsp)
}
// Drop a table in the DB
func (t *DbService) DropTable(request *DropTableRequest) (*DropTableResponse, error) {
rsp := &DropTableResponse{}
return rsp, t.client.Call("db", "DropTable", request, rsp)
}
// List tables in the DB
func (t *DbService) ListTables(request *ListTablesRequest) (*ListTablesResponse, error) {
rsp := &ListTablesResponse{}
return rsp, t.client.Call("db", "ListTables", request, rsp)
} }
// Read data from a table. Lookup can be by ID or via querying any field in the record. // Read data from a table. Lookup can be by ID or via querying any field in the record.
func (t *DbService) Read(request *ReadRequest) (*ReadResponse, error) { func (t *DbService) Read(request *ReadRequest) (*ReadResponse, error) {
rsp := &ReadResponse{} rsp := &ReadResponse{}
return rsp, t.client.Call("db", "Read", request, rsp) return rsp, t.client.Call("db", "Read", request, rsp)
}
// Rename a table
func (t *DbService) RenameTable(request *RenameTableRequest) (*RenameTableResponse, error) {
rsp := &RenameTableResponse{}
return rsp, t.client.Call("db", "RenameTable", request, rsp)
} }
// Truncate the records in a table // Truncate the records in a table
func (t *DbService) Truncate(request *TruncateRequest) (*TruncateResponse, error) { func (t *DbService) Truncate(request *TruncateRequest) (*TruncateResponse, error) {
rsp := &TruncateResponse{} rsp := &TruncateResponse{}
return rsp, t.client.Call("db", "Truncate", request, rsp) return rsp, t.client.Call("db", "Truncate", request, rsp)
} }
// Update a record in the database. Include an "id" in the record to update. // Update a record in the database. Include an "id" in the record to update.
func (t *DbService) Update(request *UpdateRequest) (*UpdateResponse, error) { func (t *DbService) Update(request *UpdateRequest) (*UpdateResponse, error) {
rsp := &UpdateResponse{} rsp := &UpdateResponse{}
return rsp, t.client.Call("db", "Update", request, rsp) return rsp, t.client.Call("db", "Update", request, rsp)
} }
type CountRequest struct { type CountRequest struct {
@@ -99,8 +63,6 @@ type CountResponse struct {
} }
type CreateRequest struct { type CreateRequest struct {
// optional record id to use
Id string `json:"id"`
// JSON encoded record or records (can be array or object) // JSON encoded record or records (can be array or object)
Record map[string]interface{} `json:"record"` Record map[string]interface{} `json:"record"`
// Optional table name. Defaults to 'default' // Optional table name. Defaults to 'default'
@@ -122,21 +84,6 @@ type DeleteRequest struct {
type DeleteResponse struct { type DeleteResponse struct {
} }
type DropTableRequest struct {
Table string `json:"table"`
}
type DropTableResponse struct {
}
type ListTablesRequest struct {
}
type ListTablesResponse struct {
// list of tables
Tables []string `json:"tables"`
}
type ReadRequest struct { type ReadRequest struct {
// Read by id. Equivalent to 'id == "your-id"' // Read by id. Equivalent to 'id == "your-id"'
Id string `json:"id"` Id string `json:"id"`
@@ -163,21 +110,14 @@ type ReadResponse struct {
Records []map[string]interface{} `json:"records"` Records []map[string]interface{} `json:"records"`
} }
type RenameTableRequest struct {
// current table name
From string `json:"from"`
// new table name
To string `json:"to"`
}
type RenameTableResponse struct {
}
type TruncateRequest struct { type TruncateRequest struct {
// Optional table name. Defaults to 'default'
Table string `json:"table"` Table string `json:"table"`
} }
type TruncateResponse struct { type TruncateResponse struct {
// The table truncated
Table string `json:"table"`
} }
type UpdateRequest struct { type UpdateRequest struct {

8
email/email.go
View File

@@ -18,23 +18,21 @@ type EmailService struct {
// Send an email by passing in from, to, subject, and a text or html body // Send an email by passing in from, to, subject, and a text or html body
func (t *EmailService) Send(request *SendRequest) (*SendResponse, error) { func (t *EmailService) Send(request *SendRequest) (*SendResponse, error) {
rsp := &SendResponse{} rsp := &SendResponse{}
return rsp, t.client.Call("email", "Send", request, rsp) return rsp, t.client.Call("email", "Send", request, rsp)
} }
type SendRequest struct { type SendRequest struct {
// the display name of the sender // the display name of the sender
From string `json:"from"` From string `json:"from"`
// the html body // the html body
HtmlBody string `json:"html_body"` HtmlBody string `json:"htmlBody"`
// an optional reply to email address // an optional reply to email address
ReplyTo string `json:"reply_to"` ReplyTo string `json:"replyTo"`
// the email subject // the email subject
Subject string `json:"subject"` Subject string `json:"subject"`
// the text body // the text body
TextBody string `json:"text_body"` TextBody string `json:"textBody"`
// the email address of the recipient // the email address of the recipient
To string `json:"to"` To string `json:"to"`
} }

8
emoji/emoji.go
View File

@@ -18,35 +18,27 @@ type EmojiService struct {
// Find an emoji by its alias e.g :beer: // Find an emoji by its alias e.g :beer:
func (t *EmojiService) Find(request *FindRequest) (*FindResponse, error) { func (t *EmojiService) Find(request *FindRequest) (*FindResponse, error) {
rsp := &FindResponse{} rsp := &FindResponse{}
return rsp, t.client.Call("emoji", "Find", request, rsp) return rsp, t.client.Call("emoji", "Find", request, rsp)
} }
// Get the flag for a country. Requires country code e.g GB for great britain // Get the flag for a country. Requires country code e.g GB for great britain
func (t *EmojiService) Flag(request *FlagRequest) (*FlagResponse, error) { func (t *EmojiService) Flag(request *FlagRequest) (*FlagResponse, error) {
rsp := &FlagResponse{} rsp := &FlagResponse{}
return rsp, t.client.Call("emoji", "Flag", request, rsp) return rsp, t.client.Call("emoji", "Flag", request, rsp)
} }
// Print text and renders the emojis with aliases e.g // Print text and renders the emojis with aliases e.g
// let's grab a :beer: becomes let's grab a 🍺 // let's grab a :beer: becomes let's grab a 🍺
func (t *EmojiService) Print(request *PrintRequest) (*PrintResponse, error) { func (t *EmojiService) Print(request *PrintRequest) (*PrintResponse, error) {
rsp := &PrintResponse{} rsp := &PrintResponse{}
return rsp, t.client.Call("emoji", "Print", request, rsp) return rsp, t.client.Call("emoji", "Print", request, rsp)
} }
// Send an emoji to anyone via SMS. Messages are sent in the form '<message> Sent from <from>' // Send an emoji to anyone via SMS. Messages are sent in the form '<message> Sent from <from>'
func (t *EmojiService) Send(request *SendRequest) (*SendResponse, error) { func (t *EmojiService) Send(request *SendRequest) (*SendResponse, error) {
rsp := &SendResponse{} rsp := &SendResponse{}
return rsp, t.client.Call("emoji", "Send", request, rsp) return rsp, t.client.Call("emoji", "Send", request, rsp)
} }
type FindRequest struct { type FindRequest struct {

104
evchargers/evchargers.go
View File

@@ -18,66 +18,62 @@ type EvchargersService struct {
// Retrieve reference data as used by this API and in conjunction with the Search endpoint // Retrieve reference data as used by this API and in conjunction with the Search endpoint
func (t *EvchargersService) ReferenceData(request *ReferenceDataRequest) (*ReferenceDataResponse, error) { func (t *EvchargersService) ReferenceData(request *ReferenceDataRequest) (*ReferenceDataResponse, error) {
rsp := &ReferenceDataResponse{} rsp := &ReferenceDataResponse{}
return rsp, t.client.Call("evchargers", "ReferenceData", request, rsp) return rsp, t.client.Call("evchargers", "ReferenceData", request, rsp)
} }
// Search by giving a coordinate and a max distance, or bounding box and optional filters // Search by giving a coordinate and a max distance, or bounding box and optional filters
func (t *EvchargersService) Search(request *SearchRequest) (*SearchResponse, error) { func (t *EvchargersService) Search(request *SearchRequest) (*SearchResponse, error) {
rsp := &SearchResponse{} rsp := &SearchResponse{}
return rsp, t.client.Call("evchargers", "Search", request, rsp) return rsp, t.client.Call("evchargers", "Search", request, rsp)
} }
type Address struct { type Address struct {
// Any comments about how to access the charger // Any comments about how to access the charger
AccessComments string `json:"access_comments"` AccessComments string `json:"accessComments"`
AddressLine1 string `json:"address_line_1"` AddressLine1 string `json:"addressLine1"`
AddressLine2 string `json:"address_line_2"` AddressLine2 string `json:"addressLine2"`
Country *Country `json:"country"` Country *Country `json:"country"`
CountryId string `json:"country_id"` CountryId string `json:"countryId"`
LatLng string `json:"lat_lng"` LatLng string `json:"latLng"`
Location *Coordinates `json:"location"` Location *Coordinates `json:"location"`
Postcode string `json:"postcode"` Postcode string `json:"postcode"`
StateOrProvince string `json:"state_or_province"` StateOrProvince string `json:"stateOrProvince"`
Title string `json:"title"` Title string `json:"title"`
Town string `json:"town"` Town string `json:"town"`
} }
type BoundingBox struct { type BoundingBox struct {
BottomLeft *Coordinates `json:"bottom_left"` BottomLeft *Coordinates `json:"bottomLeft"`
TopRight *Coordinates `json:"top_right"` TopRight *Coordinates `json:"topRight"`
} }
type ChargerType struct { type ChargerType struct {
Comments string `json:"comments"` Comments string `json:"comments"`
Id string `json:"id"` Id string `json:"id"`
// Is this 40KW+ // Is this 40KW+
IsFastChargeCapable bool `json:"is_fast_charge_capable"` IsFastChargeCapable bool `json:"isFastChargeCapable"`
Title string `json:"title"` Title string `json:"title"`
} }
type CheckinStatusType struct { type CheckinStatusType struct {
Id string `json:"id"` Id string `json:"id"`
IsAutomated bool `json:"is_automated"` IsAutomated bool `json:"isAutomated"`
IsPositive bool `json:"is_positive"` IsPositive bool `json:"isPositive"`
Title string `json:"title"` Title string `json:"title"`
} }
type Connection struct { type Connection struct {
// The amps offered // The amps offered
Amps float64 `json:"amps"` Amps float64 `json:"amps"`
ConnectionType *ConnectionType `json:"connection_type"` ConnectionType *ConnectionType `json:"connectionType"`
// The ID of the connection type // The ID of the connection type
ConnectionTypeId string `json:"connection_type_id"` ConnectionTypeId string `json:"connectionTypeId"`
// The current // The current
Current string `json:"current"` Current string `json:"current"`
Level *ChargerType `json:"level"` Level *ChargerType `json:"level"`
// The level of charging power available // The level of charging power available
LevelId string `json:"level_id"` LevelId string `json:"levelId"`
// The power in KW // The power in KW
Power float64 `json:"power"` Power float64 `json:"power"`
Reference string `json:"reference"` Reference string `json:"reference"`
@@ -86,10 +82,10 @@ type Connection struct {
} }
type ConnectionType struct { type ConnectionType struct {
FormalName string `json:"formal_name"` FormalName string `json:"formalName"`
Id string `json:"id"` Id string `json:"id"`
IsDiscontinued bool `json:"is_discontinued"` IsDiscontinued bool `json:"isDiscontinued"`
IsObsolete bool `json:"is_obsolete"` IsObsolete bool `json:"isObsolete"`
Title string `json:"title"` Title string `json:"title"`
} }
@@ -99,9 +95,9 @@ type Coordinates struct {
} }
type Country struct { type Country struct {
ContinentCode string `json:"continent_code"` ContinentCode string `json:"continentCode"`
Id string `json:"id"` Id string `json:"id"`
IsoCode string `json:"iso_code"` IsoCode string `json:"isoCode"`
Title string `json:"title"` Title string `json:"title"`
} }
@@ -113,7 +109,7 @@ type CurrentType struct {
type DataProvider struct { type DataProvider struct {
Comments string `json:"comments"` Comments string `json:"comments"`
DataProviderStatusType *DataProviderStatusType `json:"data_provider_status_type"` DataProviderStatusType *DataProviderStatusType `json:"dataProviderStatusType"`
Id string `json:"id"` Id string `json:"id"`
// How is this data licensed // How is this data licensed
License string `json:"license"` License string `json:"license"`
@@ -123,19 +119,19 @@ type DataProvider struct {
type DataProviderStatusType struct { type DataProviderStatusType struct {
Id string `json:"id"` Id string `json:"id"`
IsProviderEnabled bool `json:"is_provider_enabled"` IsProviderEnabled bool `json:"isProviderEnabled"`
Title string `json:"title"` Title string `json:"title"`
} }
type Operator struct { type Operator struct {
Comments string `json:"comments"` Comments string `json:"comments"`
ContactEmail string `json:"contact_email"` ContactEmail string `json:"contactEmail"`
FaultReportEmail string `json:"fault_report_email"` FaultReportEmail string `json:"faultReportEmail"`
Id string `json:"id"` Id string `json:"id"`
// Is this operator a private individual vs a company // Is this operator a private individual vs a company
IsPrivateIndividual bool `json:"is_private_individual"` IsPrivateIndividual bool `json:"isPrivateIndividual"`
PhonePrimary string `json:"phone_primary"` PhonePrimary string `json:"phonePrimary"`
PhoneSecondary string `json:"phone_secondary"` PhoneSecondary string `json:"phoneSecondary"`
Title string `json:"title"` Title string `json:"title"`
Website string `json:"website"` Website string `json:"website"`
} }
@@ -148,19 +144,19 @@ type Poi struct {
// The cost of charging // The cost of charging
Cost string `json:"cost"` Cost string `json:"cost"`
// The ID of the data provider // The ID of the data provider
DataProviderId string `json:"data_provider_id"` DataProviderId string `json:"dataProviderId"`
// The ID of the charger // The ID of the charger
Id string `json:"id"` Id string `json:"id"`
// The number of charging points // The number of charging points
NumPoints int64 `json:"num_points,string"` NumPoints int64 `json:"numPoints,string"`
// The operator // The operator
Operator *Operator `json:"operator"` Operator *Operator `json:"operator"`
// The ID of the operator of the charger // The ID of the operator of the charger
OperatorId string `json:"operator_id"` OperatorId string `json:"operatorId"`
// The type of usage // The type of usage
UsageType *UsageType `json:"usage_type"` UsageType *UsageType `json:"usageType"`
// The type of usage for this charger point (is it public, membership required, etc) // The type of usage for this charger point (is it public, membership required, etc)
UsageTypeId string `json:"usage_type_id"` UsageTypeId string `json:"usageTypeId"`
} }
type ReferenceDataRequest struct { type ReferenceDataRequest struct {
@@ -168,36 +164,36 @@ type ReferenceDataRequest struct {
type ReferenceDataResponse struct { type ReferenceDataResponse struct {
// The types of charger // The types of charger
ChargerTypes *ChargerType `json:"charger_types"` ChargerTypes *ChargerType `json:"chargerTypes"`
// The types of checkin status // The types of checkin status
CheckinStatusTypes *CheckinStatusType `json:"checkin_status_types"` CheckinStatusTypes *CheckinStatusType `json:"checkinStatusTypes"`
// The types of connection // The types of connection
ConnectionTypes *ConnectionType `json:"connection_types"` ConnectionTypes *ConnectionType `json:"connectionTypes"`
// The countries // The countries
Countries []Country `json:"countries"` Countries []Country `json:"countries"`
// The types of current // The types of current
CurrentTypes *CurrentType `json:"current_types"` CurrentTypes *CurrentType `json:"currentTypes"`
// The providers of the charger data // The providers of the charger data
DataProviders *DataProvider `json:"data_providers"` DataProviders *DataProvider `json:"dataProviders"`
// The companies operating the chargers // The companies operating the chargers
Operators []Operator `json:"operators"` Operators []Operator `json:"operators"`
// The status of the charger // The status of the charger
StatusTypes *StatusType `json:"status_types"` StatusTypes *StatusType `json:"statusTypes"`
// The status of a submission // The status of a submission
SubmissionStatusTypes *SubmissionStatusType `json:"submission_status_types"` SubmissionStatusTypes *SubmissionStatusType `json:"submissionStatusTypes"`
// The different types of usage // The different types of usage
UsageTypes *UsageType `json:"usage_types"` UsageTypes *UsageType `json:"usageTypes"`
// The types of user comment // The types of user comment
UserCommentTypes *UserCommentType `json:"user_comment_types"` UserCommentTypes *UserCommentType `json:"userCommentTypes"`
} }
type SearchRequest struct { type SearchRequest struct {
// Bounding box to search within (top left and bottom right coordinates) // Bounding box to search within (top left and bottom right coordinates)
Box *BoundingBox `json:"box"` Box *BoundingBox `json:"box"`
// IDs of the connection type // IDs of the connection type
ConnectionTypes string `json:"connection_types"` ConnectionTypes string `json:"connectionTypes"`
// Country ID // Country ID
CountryId string `json:"country_id"` CountryId string `json:"countryId"`
// Search distance from point in metres, defaults to 5000m // Search distance from point in metres, defaults to 5000m
Distance int64 `json:"distance,string"` Distance int64 `json:"distance,string"`
// Supported charging levels // Supported charging levels
@@ -205,13 +201,13 @@ type SearchRequest struct {
// Coordinates from which to begin search // Coordinates from which to begin search
Location *Coordinates `json:"location"` Location *Coordinates `json:"location"`
// Maximum number of results to return, defaults to 100 // Maximum number of results to return, defaults to 100
MaxResults int64 `json:"max_results,string"` MaxResults int64 `json:"maxResults,string"`
// Minimum power in KW. Note: data not available for many chargers // Minimum power in KW. Note: data not available for many chargers
MinPower int64 `json:"min_power,string"` MinPower int64 `json:"minPower,string"`
// IDs of the the EV charger operator // IDs of the the EV charger operator
Operators []string `json:"operators"` Operators []string `json:"operators"`
// Usage of the charge point (is it public, membership required, etc) // Usage of the charge point (is it public, membership required, etc)
UsageTypes string `json:"usage_types"` UsageTypes string `json:"usageTypes"`
} }
type SearchResponse struct { type SearchResponse struct {
@@ -220,21 +216,21 @@ type SearchResponse struct {
type StatusType struct { type StatusType struct {
Id string `json:"id"` Id string `json:"id"`
IsOperational bool `json:"is_operational"` IsOperational bool `json:"isOperational"`
Title string `json:"title"` Title string `json:"title"`
} }
type SubmissionStatusType struct { type SubmissionStatusType struct {
Id string `json:"id"` Id string `json:"id"`
IsLive bool `json:"is_live"` IsLive bool `json:"isLive"`
Title string `json:"title"` Title string `json:"title"`
} }
type UsageType struct { type UsageType struct {
Id string `json:"id"` Id string `json:"id"`
IsAccessKeyRequired bool `json:"is_access_key_required"` IsAccessKeyRequired bool `json:"isAccessKeyRequired"`
IsMembershipRequired bool `json:"is_membership_required"` IsMembershipRequired bool `json:"isMembershipRequired"`
IsPayAtLocation bool `json:"is_pay_at_location"` IsPayAtLocation bool `json:"isPayAtLocation"`
Title string `json:"title"` Title string `json:"title"`
} }

110
event/event.go
View File

@@ -1,110 +0,0 @@
package event
import (
"go.m3o.com/client"
)
func NewEventService(token string) *EventService {
return &EventService{
client: client.NewClient(&client.Options{
Token: token,
}),
}
}
type EventService struct {
client *client.Client
}
// Consume events from a given topic.
func (t *EventService) Consume(request *ConsumeRequest) (*ConsumeResponseStream, error) {
stream, err := t.client.Stream("event", "Consume", request)
if err != nil {
return nil, err
}
return &ConsumeResponseStream{
stream: stream,
}, nil
}
type ConsumeResponseStream struct {
stream *client.Stream
}
func (t *ConsumeResponseStream) Recv() (*ConsumeResponse, error) {
var rsp ConsumeResponse
if err := t.stream.Recv(&rsp); err != nil {
return nil, err
}
return &rsp, nil
}
// Publish a event to the event stream.
func (t *EventService) Publish(request *PublishRequest) (*PublishResponse, error) {
rsp := &PublishResponse{}
return rsp, t.client.Call("event", "Publish", request, rsp)
}
// Read stored events
func (t *EventService) Read(request *ReadRequest) (*ReadResponse, error) {
rsp := &ReadResponse{}
return rsp, t.client.Call("event", "Read", request, rsp)
}
type ConsumeRequest struct {
// Optional group for the subscription
Group string `json:"group"`
// Optional offset to read from e.g "2006-01-02T15:04:05.999Z07:00"
Offset string `json:"offset"`
// The topic to subscribe to
Topic string `json:"topic"`
}
type ConsumeResponse struct {
// Unique message id
Id string `json:"id"`
// The next json message on the topic
Message map[string]interface{} `json:"message"`
// Timestamp of publishing
Timestamp string `json:"timestamp"`
// The topic subscribed to
Topic string `json:"topic"`
}
type Ev struct {
// event id
Id string `json:"id"`
// event message
Message map[string]interface{} `json:"message"`
// event timestamp
Timestamp string `json:"timestamp"`
}
type PublishRequest struct {
// The json message to publish
Message map[string]interface{} `json:"message"`
// The topic to publish to
Topic string `json:"topic"`
}
type PublishResponse struct {
}
type ReadRequest struct {
// number of events to read; default 25
Limit int32 `json:"limit"`
// offset for the events; default 0
Offset int32 `json:"offset"`
// topic to read from
Topic string `json:"topic"`
}
type ReadResponse struct {
// the events
Events []Ev `json:"events"`
}

1
examples/address/README.md
View File

@@ -29,6 +29,5 @@ func LookupPostcode() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

17
examples/address/lookupPostcode/lookupPostcode/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/address"
)
// Lookup a list of UK addresses by postcode
func main() {
addressService := address.NewAddressService(os.Getenv("M3O_API_TOKEN"))
rsp, err := addressService.LookupPostcode(&address.LookupPostcodeRequest{
Postcode: "SW1A 2AA",
})
fmt.Println(rsp, err)
}

1
examples/answer/README.md
View File

@@ -29,6 +29,5 @@ func AskAquestion() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

0
examples/answer/question/askAQuestion/.run
View File

17
examples/answer/question/askAQuestion/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/answer"
)
// Ask a question and receive an instant answer
func main() {
answerService := answer.NewAnswerService(os.Getenv("M3O_API_TOKEN"))
rsp, err := answerService.Question(&answer.QuestionRequest{
Query: "microsoft",
})
fmt.Println(rsp, err)
}

232
examples/app/README.md
View File

@@ -1,232 +0,0 @@
# App
An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/App/api](https://m3o.com/App/api).
Endpoints:
## Update
Update the app. The latest source code will be downloaded, built and deployed.
[https://m3o.com/app/api#Update](https://m3o.com/app/api#Update)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/app"
)
// Update the app. The latest source code will be downloaded, built and deployed.
func UpdateAnApp() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Update(&app.UpdateRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}
```
## Delete
Delete an app
[https://m3o.com/app/api#Delete](https://m3o.com/app/api#Delete)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/app"
)
// Delete an app
func DeleteAnApp() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Delete(&app.DeleteRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}
```
## Reserve
Reserve apps beyond the free quota. Call Run after.
[https://m3o.com/app/api#Reserve](https://m3o.com/app/api#Reserve)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/app"
)
// Reserve apps beyond the free quota. Call Run after.
func ReserveAppName() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Reserve(&app.ReserveRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}
```
## List
List all the apps
[https://m3o.com/app/api#List](https://m3o.com/app/api#List)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/app"
)
// List all the apps
func ListTheApps() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.List(&app.ListRequest{
})
fmt.Println(rsp, err)
}
```
## Run
Run an app from a source repo. Specify region etc.
[https://m3o.com/app/api#Run](https://m3o.com/app/api#Run)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/app"
)
// Run an app from a source repo. Specify region etc.
func RunAnApp() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Run(&app.RunRequest{
Branch: "master",
Name: "helloworld",
Port: 8080,
Region: "europe-west1",
Repo: "github.com/asim/helloworld",
})
fmt.Println(rsp, err)
}
```
## Regions
Return the support regions
[https://m3o.com/app/api#Regions](https://m3o.com/app/api#Regions)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/app"
)
// Return the support regions
func ListRegions() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Regions(&app.RegionsRequest{
})
fmt.Println(rsp, err)
}
```
## Status
Get the status of an app
[https://m3o.com/app/api#Status](https://m3o.com/app/api#Status)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/app"
)
// Get the status of an app
func GetTheStatusOfAnApp() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Status(&app.StatusRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}
```
## Resolve
Resolve an app by id to its raw backend endpoint
[https://m3o.com/app/api#Resolve](https://m3o.com/app/api#Resolve)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/app"
)
// Resolve an app by id to its raw backend endpoint
func ResolveAppById() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Resolve(&app.ResolveRequest{
Id: "helloworld",
})
fmt.Println(rsp, err)
}
```

17
examples/app/delete/deleteAnApp/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/app"
)
// Delete an app
func main() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Delete(&app.DeleteRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}

15
examples/app/list/listTheApps/main.go
View File

@@ -1,15 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/app"
)
// List all the apps
func main() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.List(&app.ListRequest{})
fmt.Println(rsp, err)
}

15
examples/app/regions/listRegions/main.go
View File

@@ -1,15 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/app"
)
// Return the support regions
func main() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Regions(&app.RegionsRequest{})
fmt.Println(rsp, err)
}

17
examples/app/reserve/reserveAppName/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/app"
)
// Reserve apps beyond the free quota. Call Run after.
func main() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Reserve(&app.ReserveRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}

17
examples/app/resolve/resolveAppById/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/app"
)
// Resolve an app by id to its raw backend endpoint
func main() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Resolve(&app.ResolveRequest{
Id: "helloworld",
})
fmt.Println(rsp, err)
}

21
examples/app/run/runAnApp/main.go
View File

@@ -1,21 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/app"
)
// Run an app from a source repo. Specify region etc.
func main() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Run(&app.RunRequest{
Branch: "master",
Name: "helloworld",
Port: 8080,
Region: "europe-west1",
Repo: "github.com/asim/helloworld",
})
fmt.Println(rsp, err)
}

17
examples/app/status/getTheStatusOfAnApp/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/app"
)
// Get the status of an app
func main() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Status(&app.StatusRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}

17
examples/app/update/updateAnApp/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/app"
)
// Update the app. The latest source code will be downloaded, built and deployed.
func main() {
appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
rsp, err := appService.Update(&app.UpdateRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}

68
examples/avatar/README.md
View File

@@ -1,68 +0,0 @@
# Avatar
An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Avatar/api](https://m3o.com/Avatar/api).
Endpoints:
## Generate
[https://m3o.com/avatar/api#Generate](https://m3o.com/avatar/api#Generate)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/avatar"
)
//
func GenerateAvatarAndReturnBase64stringOfTheAvatar() {
avatarService := avatar.NewAvatarService(os.Getenv("M3O_API_TOKEN"))
rsp, err := avatarService.Generate(&avatar.GenerateRequest{
Format: "png",
Gender: "female",
Upload: true,
Username: "",
})
fmt.Println(rsp, err)
}
```
## Generate
[https://m3o.com/avatar/api#Generate](https://m3o.com/avatar/api#Generate)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/avatar"
)
//
func GenerateAnAvatarAndUploadTheAvatarToMicrosCdn() {
avatarService := avatar.NewAvatarService(os.Getenv("M3O_API_TOKEN"))
rsp, err := avatarService.Generate(&avatar.GenerateRequest{
Format: "jpeg",
Gender: "female",
Upload: false,
Username: "",
})
fmt.Println(rsp, err)
}
```

20
examples/avatar/generate/generateAnAvatarAndUploadTheAvatarToMicrosCdn/main.go
View File

@@ -1,20 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/avatar"
)
//
func main() {
avatarService := avatar.NewAvatarService(os.Getenv("M3O_API_TOKEN"))
rsp, err := avatarService.Generate(&avatar.GenerateRequest{
Format: "jpeg",
Gender: "female",
Upload: false,
Username: "",
})
fmt.Println(rsp, err)
}

20
examples/avatar/generate/generateAvatarAndReturnBase64stringOfTheAvatar/main.go
View File

@@ -1,20 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/avatar"
)
//
func main() {
avatarService := avatar.NewAvatarService(os.Getenv("M3O_API_TOKEN"))
rsp, err := avatarService.Generate(&avatar.GenerateRequest{
Format: "png",
Gender: "female",
Upload: true,
Username: "",
})
fmt.Println(rsp, err)
}

21
examples/cache/README.md vendored
View File

@@ -30,12 +30,11 @@ Value: "bar",
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Get ## Get
Get an item from the cache by key. If key is not found, an empty response is returned. Get an item from the cache by key
[https://m3o.com/cache/api#Get](https://m3o.com/cache/api#Get) [https://m3o.com/cache/api#Get](https://m3o.com/cache/api#Get)
@@ -50,7 +49,7 @@ import(
"go.m3o.com/cache" "go.m3o.com/cache"
) )
// Get an item from the cache by key. If key is not found, an empty response is returned. // Get an item from the cache by key
func GetAvalue() { func GetAvalue() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN")) cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Get(&cache.GetRequest{ rsp, err := cacheService.Get(&cache.GetRequest{
@@ -58,12 +57,11 @@ func GetAvalue() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Delete ## Delete
Delete a value from the cache. If key not found a success response is returned. Delete a value from the cache
[https://m3o.com/cache/api#Delete](https://m3o.com/cache/api#Delete) [https://m3o.com/cache/api#Delete](https://m3o.com/cache/api#Delete)
@@ -78,7 +76,7 @@ import(
"go.m3o.com/cache" "go.m3o.com/cache"
) )
// Delete a value from the cache. If key not found a success response is returned. // Delete a value from the cache
func DeleteAvalue() { func DeleteAvalue() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN")) cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Delete(&cache.DeleteRequest{ rsp, err := cacheService.Delete(&cache.DeleteRequest{
@@ -86,12 +84,11 @@ func DeleteAvalue() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Increment ## Increment
Increment a value (if it's a number). If key not found it is equivalent to set. Increment a value (if it's a number)
[https://m3o.com/cache/api#Increment](https://m3o.com/cache/api#Increment) [https://m3o.com/cache/api#Increment](https://m3o.com/cache/api#Increment)
@@ -106,7 +103,7 @@ import(
"go.m3o.com/cache" "go.m3o.com/cache"
) )
// Increment a value (if it's a number). If key not found it is equivalent to set. // Increment a value (if it's a number)
func IncrementAvalue() { func IncrementAvalue() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN")) cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Increment(&cache.IncrementRequest{ rsp, err := cacheService.Increment(&cache.IncrementRequest{
@@ -115,12 +112,11 @@ Value: 2,
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Decrement ## Decrement
Decrement a value (if it's a number). If key not found it is equivalent to set. Decrement a value (if it's a number)
[https://m3o.com/cache/api#Decrement](https://m3o.com/cache/api#Decrement) [https://m3o.com/cache/api#Decrement](https://m3o.com/cache/api#Decrement)
@@ -135,7 +131,7 @@ import(
"go.m3o.com/cache" "go.m3o.com/cache"
) )
// Decrement a value (if it's a number). If key not found it is equivalent to set. // Decrement a value (if it's a number)
func DecrementAvalue() { func DecrementAvalue() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN")) cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Decrement(&cache.DecrementRequest{ rsp, err := cacheService.Decrement(&cache.DecrementRequest{
@@ -144,6 +140,5 @@ Value: 2,
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

2
examples/cache/decrement/decrementAValue.go vendored
View File

@@ -7,7 +7,7 @@ import (
"go.m3o.com/cache" "go.m3o.com/cache"
) )
// Decrement a value (if it's a number). If key not found it is equivalent to set. // Decrement a value (if it's a number)
func DecrementAvalue() { func DecrementAvalue() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN")) cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Decrement(&cache.DecrementRequest{ rsp, err := cacheService.Decrement(&cache.DecrementRequest{

18
examples/cache/decrement/decrementAValue/main.go vendored
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/cache"
)
// Decrement a value (if it's a number). If key not found it is equivalent to set.
func main() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Decrement(&cache.DecrementRequest{
Key: "counter",
Value: 2,
})
fmt.Println(rsp, err)
}

2
examples/cache/delete/deleteAValue.go vendored
View File

@@ -7,7 +7,7 @@ import (
"go.m3o.com/cache" "go.m3o.com/cache"
) )
// Delete a value from the cache. If key not found a success response is returned. // Delete a value from the cache
func DeleteAvalue() { func DeleteAvalue() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN")) cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Delete(&cache.DeleteRequest{ rsp, err := cacheService.Delete(&cache.DeleteRequest{

17
examples/cache/delete/deleteAValue/main.go vendored
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/cache"
)
// Delete a value from the cache. If key not found a success response is returned.
func main() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Delete(&cache.DeleteRequest{
Key: "foo",
})
fmt.Println(rsp, err)
}

2
examples/cache/get/getAValue.go vendored
View File

@@ -7,7 +7,7 @@ import (
"go.m3o.com/cache" "go.m3o.com/cache"
) )
// Get an item from the cache by key. If key is not found, an empty response is returned. // Get an item from the cache by key
func GetAvalue() { func GetAvalue() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN")) cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Get(&cache.GetRequest{ rsp, err := cacheService.Get(&cache.GetRequest{

17
examples/cache/get/getAValue/main.go vendored
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/cache"
)
// Get an item from the cache by key. If key is not found, an empty response is returned.
func main() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Get(&cache.GetRequest{
Key: "foo",
})
fmt.Println(rsp, err)
}

2
examples/cache/increment/incrementAValue.go vendored
View File

@@ -7,7 +7,7 @@ import (
"go.m3o.com/cache" "go.m3o.com/cache"
) )
// Increment a value (if it's a number). If key not found it is equivalent to set. // Increment a value (if it's a number)
func IncrementAvalue() { func IncrementAvalue() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN")) cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Increment(&cache.IncrementRequest{ rsp, err := cacheService.Increment(&cache.IncrementRequest{

18
examples/cache/increment/incrementAValue/main.go vendored
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/cache"
)
// Increment a value (if it's a number). If key not found it is equivalent to set.
func main() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Increment(&cache.IncrementRequest{
Key: "counter",
Value: 2,
})
fmt.Println(rsp, err)
}

0
examples/cache/set/setAValue/.run vendored
View File

18
examples/cache/set/setAValue/main.go vendored
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/cache"
)
// Set an item in the cache. Overwrites any existing value already set.
func main() {
cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cacheService.Set(&cache.SetRequest{
Key: "foo",
Value: "bar",
})
fmt.Println(rsp, err)
}

4
examples/crypto/README.md
View File

@@ -29,7 +29,6 @@ func GetCryptocurrencyNews() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Price ## Price
@@ -57,7 +56,6 @@ func GetCryptocurrencyPrice() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Quote ## Quote
@@ -85,7 +83,6 @@ func GetAcryptocurrencyQuote() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## History ## History
@@ -113,6 +110,5 @@ func GetPreviousClose() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

17
examples/crypto/history/getPreviousClose/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/crypto"
)
// Returns the history for the previous close
func main() {
cryptoService := crypto.NewCryptoService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cryptoService.History(&crypto.HistoryRequest{
Symbol: "BTCUSD",
})
fmt.Println(rsp, err)
}

17
examples/crypto/news/getCryptocurrencyNews/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/crypto"
)
// Get news related to a currency
func main() {
cryptoService := crypto.NewCryptoService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cryptoService.News(&crypto.NewsRequest{
Symbol: "BTCUSD",
})
fmt.Println(rsp, err)
}

17
examples/crypto/price/getCryptocurrencyPrice/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/crypto"
)
// Get the last price for a given crypto ticker
func main() {
cryptoService := crypto.NewCryptoService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cryptoService.Price(&crypto.PriceRequest{
Symbol: "BTCUSD",
})
fmt.Println(rsp, err)
}

17
examples/crypto/quote/getACryptocurrencyQuote/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/crypto"
)
// Get the last quote for a given crypto ticker
func main() {
cryptoService := crypto.NewCryptoService(os.Getenv("M3O_API_TOKEN"))
rsp, err := cryptoService.Quote(&crypto.QuoteRequest{
Symbol: "BTCUSD",
})
fmt.Println(rsp, err)
}

61
examples/currency/README.md
View File

@@ -4,35 +4,6 @@ An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Currency/api](
Endpoints: Endpoints:
## History
Returns the historic rates for a currency on a given date
[https://m3o.com/currency/api#History](https://m3o.com/currency/api#History)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/currency"
)
// Returns the historic rates for a currency on a given date
func HistoricRatesForAcurrency() {
currencyService := currency.NewCurrencyService(os.Getenv("M3O_API_TOKEN"))
rsp, err := currencyService.History(&currency.HistoryRequest{
Code: "USD",
Date: "2021-05-30",
})
fmt.Println(rsp, err)
}
```
## Codes ## Codes
Codes returns the supported currency codes for the API Codes returns the supported currency codes for the API
@@ -57,7 +28,6 @@ func GetSupportedCodes() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Rates ## Rates
@@ -85,7 +55,6 @@ func GetRatesForUsd() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Convert ## Convert
@@ -114,7 +83,6 @@ To: "GBP",
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Convert ## Convert
@@ -144,6 +112,33 @@ To: "GBP",
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
}
```
## History
Returns the historic rates for a currency on a given date
[https://m3o.com/currency/api#History](https://m3o.com/currency/api#History)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/currency"
)
// Returns the historic rates for a currency on a given date
func HistoricRatesForAcurrency() {
currencyService := currency.NewCurrencyService(os.Getenv("M3O_API_TOKEN"))
rsp, err := currencyService.History(&currency.HistoryRequest{
Code: "USD",
Date: "2021-05-30",
})
fmt.Println(rsp, err)
} }
``` ```

15
examples/currency/codes/getSupportedCodes/main.go
View File

@@ -1,15 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/currency"
)
// Codes returns the supported currency codes for the API
func main() {
currencyService := currency.NewCurrencyService(os.Getenv("M3O_API_TOKEN"))
rsp, err := currencyService.Codes(&currency.CodesRequest{})
fmt.Println(rsp, err)
}

19
examples/currency/convert/convert10UsdToGbp/main.go
View File

@@ -1,19 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/currency"
)
// Convert returns the currency conversion rate between two pairs e.g USD/GBP
func main() {
currencyService := currency.NewCurrencyService(os.Getenv("M3O_API_TOKEN"))
rsp, err := currencyService.Convert(&currency.ConvertRequest{
Amount: 10,
From: "USD",
To: "GBP",
})
fmt.Println(rsp, err)
}

18
examples/currency/convert/convertUsdToGbp/main.go
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/currency"
)
// Convert returns the currency conversion rate between two pairs e.g USD/GBP
func main() {
currencyService := currency.NewCurrencyService(os.Getenv("M3O_API_TOKEN"))
rsp, err := currencyService.Convert(&currency.ConvertRequest{
From: "USD",
To: "GBP",
})
fmt.Println(rsp, err)
}

18
examples/currency/history/historicRatesForACurrency/main.go
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/currency"
)
// Returns the historic rates for a currency on a given date
func main() {
currencyService := currency.NewCurrencyService(os.Getenv("M3O_API_TOKEN"))
rsp, err := currencyService.History(&currency.HistoryRequest{
Code: "USD",
Date: "2021-05-30",
})
fmt.Println(rsp, err)
}

17
examples/currency/rates/getRatesForUsd/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/currency"
)
// Rates returns the currency rates for a given code e.g USD
func main() {
currencyService := currency.NewCurrencyService(os.Getenv("M3O_API_TOKEN"))
rsp, err := currencyService.Rates(&currency.RatesRequest{
Code: "USD",
})
fmt.Println(rsp, err)
}

264
examples/db/README.md
View File

@@ -4,175 +4,6 @@ An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Db/api](https:
Endpoints: Endpoints:
## Read
Read data from a table. Lookup can be by ID or via querying any field in the record.
[https://m3o.com/db/api#Read](https://m3o.com/db/api#Read)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/db"
)
// Read data from a table. Lookup can be by ID or via querying any field in the record.
func ReadRecords() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Read(&db.ReadRequest{
Query: "age == 43",
Table: "example",
})
fmt.Println(rsp, err)
}
```
## DropTable
Drop a table in the DB
[https://m3o.com/db/api#DropTable](https://m3o.com/db/api#DropTable)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/db"
)
// Drop a table in the DB
func DropTable() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.DropTable(&db.DropTableRequest{
Table: "example",
})
fmt.Println(rsp, err)
}
```
## RenameTable
Rename a table
[https://m3o.com/db/api#RenameTable](https://m3o.com/db/api#RenameTable)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/db"
)
// Rename a table
func RenameTable() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.RenameTable(&db.RenameTableRequest{
From: "examples2",
To: "examples3",
})
fmt.Println(rsp, err)
}
```
## Truncate
Truncate the records in a table
[https://m3o.com/db/api#Truncate](https://m3o.com/db/api#Truncate)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/db"
)
// Truncate the records in a table
func TruncateTable() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Truncate(&db.TruncateRequest{
Table: "example",
})
fmt.Println(rsp, err)
}
```
## Count
Count records in a table
[https://m3o.com/db/api#Count](https://m3o.com/db/api#Count)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/db"
)
// Count records in a table
func CountEntriesInAtable() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Count(&db.CountRequest{
Table: "example",
})
fmt.Println(rsp, err)
}
```
## ListTables
List tables in the DB
[https://m3o.com/db/api#ListTables](https://m3o.com/db/api#ListTables)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/db"
)
// List tables in the DB
func ListTables() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.ListTables(&db.ListTablesRequest{
})
fmt.Println(rsp, err)
}
```
## Create ## Create
Create a record in the database. Optionally include an "id" field otherwise it's set automatically. Create a record in the database. Optionally include an "id" field otherwise it's set automatically.
@@ -195,16 +26,15 @@ func CreateArecord() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN")) dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Create(&db.CreateRequest{ rsp, err := dbService.Create(&db.CreateRequest{
Record: map[string]interface{}{ Record: map[string]interface{}{
"isActive": true,
"id": "1", "id": "1",
"name": "Jane", "name": "Jane",
"age": 42, "age": 42,
"isActive": true,
}, },
Table: "example", Table: "users",
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Update ## Update
@@ -229,14 +59,41 @@ func UpdateArecord() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN")) dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Update(&db.UpdateRequest{ rsp, err := dbService.Update(&db.UpdateRequest{
Record: map[string]interface{}{ Record: map[string]interface{}{
"id": "1",
"age": 43, "age": 43,
"id": "1",
}, },
Table: "example", Table: "users",
})
fmt.Println(rsp, err)
}
```
## Read
Read data from a table. Lookup can be by ID or via querying any field in the record.
[https://m3o.com/db/api#Read](https://m3o.com/db/api#Read)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/db"
)
// Read data from a table. Lookup can be by ID or via querying any field in the record.
func ReadRecords() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Read(&db.ReadRequest{
Query: "age == 43",
Table: "users",
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Delete ## Delete
@@ -261,10 +118,63 @@ func DeleteArecord() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN")) dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Delete(&db.DeleteRequest{ rsp, err := dbService.Delete(&db.DeleteRequest{
Id: "1", Id: "1",
Table: "example", Table: "users",
})
fmt.Println(rsp, err)
}
```
## Truncate
Truncate the records in a table
[https://m3o.com/db/api#Truncate](https://m3o.com/db/api#Truncate)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/db"
)
// Truncate the records in a table
func TruncateTable() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Truncate(&db.TruncateRequest{
Table: "users",
})
fmt.Println(rsp, err)
}
```
## Count
Count records in a table
[https://m3o.com/db/api#Count](https://m3o.com/db/api#Count)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/db"
)
// Count records in a table
func CountEntriesInAtable() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Count(&db.CountRequest{
Table: "users",
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

17
examples/db/count/countEntriesInATable/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/db"
)
// Count records in a table
func main() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Count(&db.CountRequest{
Table: "example",
})
fmt.Println(rsp, err)
}

23
examples/db/create/createARecord/main.go
View File

@@ -1,23 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/db"
)
// Create a record in the database. Optionally include an "id" field otherwise it's set automatically.
func main() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Create(&db.CreateRequest{
Record: map[string]interface{}{
"id": "1",
"name": "Jane",
"age": 42,
"isActive": true,
},
Table: "example",
})
fmt.Println(rsp, err)
}

18
examples/db/delete/deleteARecord/main.go
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/db"
)
// Delete a record in the database by id.
func main() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Delete(&db.DeleteRequest{
Id: "1",
Table: "example",
})
fmt.Println(rsp, err)
}

17
examples/db/dropTable/dropTable/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/db"
)
// Drop a table in the DB
func main() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.DropTable(&db.DropTableRequest{
Table: "example",
})
fmt.Println(rsp, err)
}

15
examples/db/listTables/listTables/main.go
View File

@@ -1,15 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/db"
)
// List tables in the DB
func main() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.ListTables(&db.ListTablesRequest{})
fmt.Println(rsp, err)
}

0
examples/db/read/readRecords/.run
View File

18
examples/db/read/readRecords/main.go
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/db"
)
// Read data from a table. Lookup can be by ID or via querying any field in the record.
func main() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Read(&db.ReadRequest{
Query: "age == 43",
Table: "example",
})
fmt.Println(rsp, err)
}

18
examples/db/renameTable/renameTable/main.go
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/db"
)
// Rename a table
func main() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.RenameTable(&db.RenameTableRequest{
From: "examples2",
To: "examples3",
})
fmt.Println(rsp, err)
}

17
examples/db/truncate/truncateTable/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/db"
)
// Truncate the records in a table
func main() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Truncate(&db.TruncateRequest{
Table: "example",
})
fmt.Println(rsp, err)
}

21
examples/db/update/updateARecord/main.go
View File

@@ -1,21 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/db"
)
// Update a record in the database. Include an "id" in the record to update.
func main() {
dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
rsp, err := dbService.Update(&db.UpdateRequest{
Record: map[string]interface{}{
"id": "1",
"age": 43,
},
Table: "example",
})
fmt.Println(rsp, err)
}

1
examples/email/README.md
View File

@@ -33,6 +33,5 @@ Please verify your email by clicking this link: $micro_verification_link`,
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

21
examples/email/send/sendEmail/main.go
View File

@@ -1,21 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/email"
)
// Send an email by passing in from, to, subject, and a text or html body
func main() {
emailService := email.NewEmailService(os.Getenv("M3O_API_TOKEN"))
rsp, err := emailService.Send(&email.SendRequest{
From: "Awesome Dot Com",
Subject: "Email verification",
TextBody: `Hi there,
Please verify your email by clicking this link: $micro_verification_link`,
})
fmt.Println(rsp, err)
}

4
examples/emoji/README.md
View File

@@ -29,7 +29,6 @@ func FindEmoji() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Flag ## Flag
@@ -56,7 +55,6 @@ func GetFlagByCountryCode() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Print ## Print
@@ -86,7 +84,6 @@ func PrintTextIncludingEmoji() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Send ## Send
@@ -116,6 +113,5 @@ To: "+44782669123",
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

17
examples/emoji/find/findEmoji/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/emoji"
)
// Find an emoji by its alias e.g :beer:
func main() {
emojiService := emoji.NewEmojiService(os.Getenv("M3O_API_TOKEN"))
rsp, err := emojiService.Find(&emoji.FindRequest{
Alias: ":beer:",
})
fmt.Println(rsp, err)
}

15
examples/emoji/flag/getFlagByCountryCode/main.go
View File

@@ -1,15 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/emoji"
)
// Get the flag for a country. Requires country code e.g GB for great britain
func main() {
emojiService := emoji.NewEmojiService(os.Getenv("M3O_API_TOKEN"))
rsp, err := emojiService.Flag(&emoji.FlagRequest{})
fmt.Println(rsp, err)
}

18
examples/emoji/print/printTextIncludingEmoji/main.go
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/emoji"
)
// Print text and renders the emojis with aliases e.g
// let's grab a :beer: becomes let's grab a 🍺
func main() {
emojiService := emoji.NewEmojiService(os.Getenv("M3O_API_TOKEN"))
rsp, err := emojiService.Print(&emoji.PrintRequest{
Text: "let's grab a :beer:",
})
fmt.Println(rsp, err)
}

19
examples/emoji/send/sendATextContainingAnEmojiToAnyoneViaSms/main.go
View File

@@ -1,19 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/emoji"
)
// Send an emoji to anyone via SMS. Messages are sent in the form '<message> Sent from <from>'
func main() {
emojiService := emoji.NewEmojiService(os.Getenv("M3O_API_TOKEN"))
rsp, err := emojiService.Send(&emoji.SendRequest{
From: "Alice",
Message: "let's grab a :beer:",
To: "+44782669123",
})
fmt.Println(rsp, err)
}

4
examples/evchargers/README.md
View File

@@ -33,7 +33,6 @@ Location: &evchargers.Coordinates{
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Search ## Search
@@ -62,7 +61,6 @@ func SearchByBoundingBox() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Search ## Search
@@ -95,7 +93,6 @@ Location: &evchargers.Coordinates{
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## ReferenceData ## ReferenceData
@@ -122,6 +119,5 @@ func GetReferenceData() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

15
examples/evchargers/referenceData/getReferenceData/main.go
View File

@@ -1,15 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/evchargers"
)
// Retrieve reference data as used by this API and in conjunction with the Search endpoint
func main() {
evchargersService := evchargers.NewEvchargersService(os.Getenv("M3O_API_TOKEN"))
rsp, err := evchargersService.ReferenceData(&evchargers.ReferenceDataRequest{})
fmt.Println(rsp, err)
}

17
examples/evchargers/search/searchByBoundingBox/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/evchargers"
)
// Search by giving a coordinate and a max distance, or bounding box and optional filters
func main() {
evchargersService := evchargers.NewEvchargersService(os.Getenv("M3O_API_TOKEN"))
rsp, err := evchargersService.Search(&evchargers.SearchRequest{
Box: &evchargers.BoundingBox{},
})
fmt.Println(rsp, err)
}

21
examples/evchargers/search/searchByLocation/main.go
View File

@@ -1,21 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/evchargers"
)
// Search by giving a coordinate and a max distance, or bounding box and optional filters
func main() {
evchargersService := evchargers.NewEvchargersService(os.Getenv("M3O_API_TOKEN"))
rsp, err := evchargersService.Search(&evchargers.SearchRequest{
Distance: 2000,
Location: &evchargers.Coordinates{
Latitude: 51.53336351319885,
Longitude: -0.0252,
},
})
fmt.Println(rsp, err)
}

22
examples/evchargers/search/searchWithFiltersFastChargersOnly/main.go
View File

@@ -1,22 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/evchargers"
)
// Search by giving a coordinate and a max distance, or bounding box and optional filters
func main() {
evchargersService := evchargers.NewEvchargersService(os.Getenv("M3O_API_TOKEN"))
rsp, err := evchargersService.Search(&evchargers.SearchRequest{
Distance: 2000,
Levels: []string{"3"},
Location: &evchargers.Coordinates{
Latitude: 51.53336351319885,
Longitude: -0.0252,
},
})
fmt.Println(rsp, err)
}

108
examples/event/README.md
View File

@@ -1,108 +0,0 @@
# Event
An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Event/api](https://m3o.com/Event/api).
Endpoints:
## Publish
Publish a event to the event stream.
[https://m3o.com/event/api#Publish](https://m3o.com/event/api#Publish)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/event"
)
// Publish a event to the event stream.
func PublishAnEvent() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
rsp, err := eventService.Publish(&event.PublishRequest{
Message: map[string]interface{}{
"id": "1",
"type": "signup",
"user": "john",
},
Topic: "user",
})
fmt.Println(rsp, err)
}
```
## Consume
Consume events from a given topic.
[https://m3o.com/event/api#Consume](https://m3o.com/event/api#Consume)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/event"
)
// Consume events from a given topic.
func ConsumeFromAtopic() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
stream, err := eventService.Consume(&event.ConsumeRequest{
Topic: "user",
})
if err != nil {
fmt.Println(err)
return
}
for {
rsp, err := stream.Recv()
if err != nil {
fmt.Println(err)
return
}
fmt.Println(rsp)
}
}
```
## Read
Read stored events
[https://m3o.com/event/api#Read](https://m3o.com/event/api#Read)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/event"
)
// Read stored events
func ReadEventsOnAtopic() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
rsp, err := eventService.Read(&event.ReadRequest{
Topic: "user",
})
fmt.Println(rsp, err)
}
```

17
examples/event/consume/consumeFromATopic.go
View File

@@ -1,17 +0,0 @@
package example
import (
"fmt"
"os"
"go.m3o.com/event"
)
// Consume events from a given topic.
func ConsumeFromAtopic() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
rsp, err := eventService.Consume(&event.ConsumeRequest{
Topic: "user",
})
fmt.Println(rsp, err)
}

30
examples/event/consume/consumeFromATopic/main.go
View File

@@ -1,30 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/event"
)
// Consume events from a given topic.
func main() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
stream, err := eventService.Consume(&event.ConsumeRequest{
Topic: "user",
})
if err != nil {
fmt.Println(err)
return
}
for {
rsp, err := stream.Recv()
if err != nil {
fmt.Println(err)
return
}
fmt.Println(rsp)
}
}

22
examples/event/publish/publishAMessage.go
View File

@@ -1,22 +0,0 @@
package example
import (
"fmt"
"os"
"go.m3o.com/event"
)
// Publish a message to the event stream.
func PublishAmessage() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
rsp, err := eventService.Publish(&event.PublishRequest{
Message: map[string]interface{}{
"id": "1",
"type": "signup",
"user": "john",
},
Topic: "user",
})
fmt.Println(rsp, err)
}

22
examples/event/publish/publishAnEvent.go
View File

@@ -1,22 +0,0 @@
package example
import (
"fmt"
"os"
"go.m3o.com/event"
)
// Publish a event to the event stream.
func PublishAnEvent() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
rsp, err := eventService.Publish(&event.PublishRequest{
Message: map[string]interface{}{
"id": "1",
"type": "signup",
"user": "john",
},
Topic: "user",
})
fmt.Println(rsp, err)
}

22
examples/event/publish/publishAnEvent/main.go
View File

@@ -1,22 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/event"
)
// Publish a event to the event stream.
func main() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
rsp, err := eventService.Publish(&event.PublishRequest{
Message: map[string]interface{}{
"user": "john",
"id": "1",
"type": "signup",
},
Topic: "user",
})
fmt.Println(rsp, err)
}

17
examples/event/read/readEventsOnATopic.go
View File

@@ -1,17 +0,0 @@
package example
import (
"fmt"
"os"
"go.m3o.com/event"
)
// Read stored events
func ReadEventsOnAtopic() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
rsp, err := eventService.Read(&event.ReadRequest{
Topic: "user",
})
fmt.Println(rsp, err)
}

17
examples/event/read/readEventsOnATopic/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/event"
)
// Read stored events
func main() {
eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
rsp, err := eventService.Read(&event.ReadRequest{
Topic: "user",
})
fmt.Println(rsp, err)
}

60
examples/file/README.md
View File

@@ -4,35 +4,6 @@ An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/File/api](http
Endpoints: Endpoints:
## Read
Read a file by path
[https://m3o.com/file/api#Read](https://m3o.com/file/api#Read)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/file"
)
// Read a file by path
func ReadFile() {
fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
rsp, err := fileService.Read(&file.ReadRequest{
Path: "/document/text-files/file.txt",
Project: "examples",
})
fmt.Println(rsp, err)
}
```
## Delete ## Delete
Delete a file by project name/path Delete a file by project name/path
@@ -59,7 +30,34 @@ Project: "examples",
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
}
```
## Read
Read a file by path
[https://m3o.com/file/api#Read](https://m3o.com/file/api#Read)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/file"
)
// Read a file by path
func ReadFile() {
fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
rsp, err := fileService.Read(&file.ReadRequest{
Path: "/document/text-files/file.txt",
Project: "examples",
})
fmt.Println(rsp, err)
} }
``` ```
## Save ## Save
@@ -91,7 +89,6 @@ func SaveFile() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## List ## List
@@ -119,6 +116,5 @@ func ListFiles() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

18
examples/file/delete/deleteFile/main.go
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/file"
)
// Delete a file by project name/path
func main() {
fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
rsp, err := fileService.Delete(&file.DeleteRequest{
Path: "/document/text-files/file.txt",
Project: "examples",
})
fmt.Println(rsp, err)
}

0
examples/file/list/listFiles/.run
View File

17
examples/file/list/listFiles/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/file"
)
// List files by their project and optionally a path.
func main() {
fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
rsp, err := fileService.List(&file.ListRequest{
Project: "examples",
})
fmt.Println(rsp, err)
}

18
examples/file/read/readFile/main.go
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/file"
)
// Read a file by path
func main() {
fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
rsp, err := fileService.Read(&file.ReadRequest{
Path: "/document/text-files/file.txt",
Project: "examples",
})
fmt.Println(rsp, err)
}

21
examples/file/save/saveFile/main.go
View File

@@ -1,21 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/file"
)
// Save a file
func main() {
fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
rsp, err := fileService.Save(&file.SaveRequest{
File: &file.Record{
Content: "file content example",
Path: "/document/text-files/file.txt",
Project: "examples",
},
})
fmt.Println(rsp, err)
}

3
examples/forex/README.md
View File

@@ -29,7 +29,6 @@ func GetAnFxPrice() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Quote ## Quote
@@ -57,7 +56,6 @@ func GetAfxQuote() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## History ## History
@@ -85,6 +83,5 @@ func GetPreviousClose() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

17
examples/forex/history/getPreviousClose/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/forex"
)
// Returns the data for the previous close
func main() {
forexService := forex.NewForexService(os.Getenv("M3O_API_TOKEN"))
rsp, err := forexService.History(&forex.HistoryRequest{
Symbol: "GBPUSD",
})
fmt.Println(rsp, err)
}

17
examples/forex/price/getAnFxPrice/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/forex"
)
// Get the latest price for a given forex ticker
func main() {
forexService := forex.NewForexService(os.Getenv("M3O_API_TOKEN"))
rsp, err := forexService.Price(&forex.PriceRequest{
Symbol: "GBPUSD",
})
fmt.Println(rsp, err)
}

17
examples/forex/quote/getAFxQuote/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/forex"
)
// Get the latest quote for the forex
func main() {
forexService := forex.NewForexService(os.Getenv("M3O_API_TOKEN"))
rsp, err := forexService.Quote(&forex.QuoteRequest{
Symbol: "GBPUSD",
})
fmt.Println(rsp, err)
}

161
examples/function/README.md
View File

@@ -4,98 +4,6 @@ An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Function/api](
Endpoints: Endpoints:
## Deploy
Deploy a group of functions
[https://m3o.com/function/api#Deploy](https://m3o.com/function/api#Deploy)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/function"
)
// Deploy a group of functions
func DeployAfunction() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Deploy(&function.DeployRequest{
Entrypoint: "helloworld",
Name: "helloworld",
Repo: "github.com/m3o/nodejs-function-example",
Runtime: "nodejs14",
})
fmt.Println(rsp, err)
}
```
## Update
Update a function
[https://m3o.com/function/api#Update](https://m3o.com/function/api#Update)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/function"
)
// Update a function
func UpdateAfunction() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Update(&function.UpdateRequest{
Entrypoint: "helloworld",
Name: "helloworld",
Repo: "github.com/m3o/nodejs-function-example",
Runtime: "nodejs14",
})
fmt.Println(rsp, err)
}
```
## Call
Call a function by name
[https://m3o.com/function/api#Call](https://m3o.com/function/api#Call)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/function"
)
// Call a function by name
func CallAfunction() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Call(&function.CallRequest{
Name: "helloworld",
Request: map[string]interface{}{
},
})
fmt.Println(rsp, err)
}
```
## List ## List
List all the deployed functions List all the deployed functions
@@ -120,7 +28,6 @@ func ListFunctions() {
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Delete ## Delete
@@ -144,11 +51,11 @@ import(
func DeleteAfunction() { func DeleteAfunction() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN")) functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Delete(&function.DeleteRequest{ rsp, err := functionService.Delete(&function.DeleteRequest{
Name: "helloworld", Name: "my-first-func",
Project: "tests",
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```
## Describe ## Describe
@@ -172,10 +79,70 @@ import(
func DescribeFunctionStatus() { func DescribeFunctionStatus() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN")) functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Describe(&function.DescribeRequest{ rsp, err := functionService.Describe(&function.DescribeRequest{
Name: "helloworld", Name: "my-first-func",
Project: "tests",
})
fmt.Println(rsp, err)
}
```
## Deploy
Deploy a group of functions
[https://m3o.com/function/api#Deploy](https://m3o.com/function/api#Deploy)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/function"
)
// Deploy a group of functions
func DeployAfunction() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Deploy(&function.DeployRequest{
Entrypoint: "helloworld",
Name: "my-first-func",
Project: "tests",
Repo: "github.com/m3o/nodejs-function-example",
Runtime: "nodejs14",
})
fmt.Println(rsp, err)
}
```
## Call
Call a function by name
[https://m3o.com/function/api#Call](https://m3o.com/function/api#Call)
```go
package example
import(
"fmt"
"os"
"go.m3o.com/function"
)
// Call a function by name
func CallAfunction() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Call(&function.CallRequest{
Name: "my-first-func",
Request: map[string]interface{}{
},
}) })
fmt.Println(rsp, err) fmt.Println(rsp, err)
} }
``` ```

18
examples/function/call/callAFunction/main.go
View File

@@ -1,18 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/function"
)
// Call a function by name
func main() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Call(&function.CallRequest{
Name: "helloworld",
Request: map[string]interface{}{},
})
fmt.Println(rsp, err)
}

17
examples/function/delete/deleteAFunction/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/function"
)
// Delete a function by name
func main() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Delete(&function.DeleteRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}

20
examples/function/deploy/deployAFunction/main.go
View File

@@ -1,20 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/function"
)
// Deploy a group of functions
func main() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Deploy(&function.DeployRequest{
Entrypoint: "helloworld",
Name: "helloworld",
Repo: "github.com/m3o/nodejs-function-example",
Runtime: "nodejs14",
})
fmt.Println(rsp, err)
}

17
examples/function/describe/describeFunctionStatus/main.go
View File

@@ -1,17 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/function"
)
// Get the info for a deployed function
func main() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.Describe(&function.DescribeRequest{
Name: "helloworld",
})
fmt.Println(rsp, err)
}

15
examples/function/list/listFunctions/main.go
View File

@@ -1,15 +0,0 @@
package main
import (
"fmt"
"os"
"go.m3o.com/function"
)
// List all the deployed functions
func main() {
functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
rsp, err := functionService.List(&function.ListRequest{})
fmt.Println(rsp, err)
}

Some files were not shown because too many files have changed in this diff Show More