Categorygithub.com/koding/kite
modulepackage
0.0.0-20180710021347-baa1a54919e3
Repository: https://github.com/koding/kite.git
Documentation: pkg.go.dev

# README

Kite Micro-Service Framework

Kite is a framework for developing micro-services in Go.

GoDoc Build Status

Kite

Kite is both the name of the framework and the micro-service that is written by using this framework. Basically, Kite is a RPC server as well as a client. It connects to other kites and peers to communicate with each other. They can discover other kites using a service called Kontrol, and communicate with them bidirectionaly. The communication protocol uses a WebSocket (or XHR) as transport in order to allow web applications to connect directly to kites.

Kites can talk with each other by sending dnode messages over a socket session. If the client knows the URL of the server kite it can connect to it directly. If the URL is not known, client can ask for it from Kontrol (Service Discovery).

For more info checkout the blog post at GopherAcademy which explains Kite in more detail: http://blog.gopheracademy.com/birthday-bash-2014/kite-microservice-library/

Install and Usage

Install the package with:

go get github.com/koding/kite

Import it with:

import "github.com/koding/kite"

and use kite as the package name inside the code.

What is Kontrol?

Kontrol is the service registry and authentication service used by Kites. It is itself a kite too.

When a kite starts to run, it can registers itself to Kontrol with the Register() method if wished. That enables others to find it by querying Kontrol. There is also a Proxy Kite for giving public URLs to registered kites.

Query has 7 fields:

/<username>/<environment>/<name>/<version>/<region>/<hostname>/<id>
  • You must at least give the username.
  • The order of the fields is from general to specific.
  • Query cannot contains empty parts between fields.

Installing Kontrol

Install Kontrol:

go get github.com/koding/kite/kontrol/kontrol

Generate keys for the Kite key:

openssl genrsa -out key.pem 2048
openssl rsa -in key.pem -pubout > key_pub.pem

Set environment variables:

KONTROL_PORT=6000
KONTROL_USERNAME="kontrol"
KONTROL_STORAGE="etcd"
KONTROL_KONTROLURL="http://127.0.0.1:6000/kite"
KONTROL_PUBLICKEYFILE="certs/key_pub.pem"
KONTROL_PRIVATEKEYFILE="certs/key.pem"

Generate initial Kite key:

./bin/kontrol -initial

How can I use kites from a browser?

A browser can also be a Kite. It has it's own methods ("log" for logging a message to the console, "alert" for displaying alert to the user, etc.). A connected kite can call methods defined on the webpage.

See kite.js library for more information.

How can I write a new kite?

  • Import kite package.
  • Create a new instance with kite.New().
  • Add your method handlers with k.HandleFunc() or k.Handle().
  • Call k.Run()

Below you can find an example, a math kite which calculates the square of a received number:

package main

import "github.com/koding/kite"

func main() {
	// Create a kite
	k := kite.New("math", "1.0.0")

	// Add our handler method with the name "square"
	k.HandleFunc("square", func(r *kite.Request) (interface{}, error) {
		a := r.Args.One().MustFloat64()
		result := a * a    // calculate the square
		return result, nil // send back the result
	}).DisableAuthentication()

	// Attach to a server with port 3636 and run it
	k.Config.Port = 3636
	k.Run()
}

Now let's connect to it and send a 4 as an argument.

package main

import (
	"fmt"

	"github.com/koding/kite"
)

func main() {
	k := kite.New("exp2", "1.0.0")

	// Connect to our math kite
	mathWorker := k.NewClient("http://localhost:3636/kite")
	mathWorker.Dial()

	response, _ := mathWorker.Tell("square", 4) // call "square" method with argument 4
	fmt.Println("result:", response.MustFloat64())
}

Check out the examples folder for more examples.

# Packages

Package config contains a Config struct for kites.
Package dnode implements a dnode scrubber.
No description provided by the author
Command line tool for using kite services.
Package kitekey provides method for reading and writing kite.key file.
No description provided by the author
Package kontrol provides an implementation for the name service kite.
Package protocol defines the communication between the components of the Kite infrastructure.
No description provided by the author
No description provided by the author
Package systeminfo provides a way of getting memory usage, disk usage and various information about the host.
No description provided by the author
Package testkeys contains RSA keys and TLS certificates for using in examples and tests.
Package testutil provides a default Kontrol kites for using in tests.
Package tunnelproxy implements a reverse-proxy for kites behind firewall or NAT.
No description provided by the author

# Functions

Close is a wrapper for Closer that calls a Close on it.
Closer returns a io.Closer that can be used to close all the kites given by the generic argument.
New creates, initializes and then returns a new Kite instance.
No description provided by the author
NewWebRCTHandler creates a new handler for web rtc signalling services.
NewWithConfig builds a new kite value for the given configuration.

# Constants

Logging levels.
Logging levels.
Logging levels.
Logging levels.
ReturnFirst returns the first non-nil response.
ReturnLatest returns the latest response (waterfall behaviour).
ReturnMethod returns main method's response.
Logging levels.
WebRTCHandlerName provides the naming scheme for the handler.

# Variables

ErrKeyNotTrusted is returned by verify functions when the key should not be trusted.
Returned from GetKites when query matches no kites.

# Structs

Authentication is used when connecting a Client.
Client is the client for communicating with another Kite.
ErrClose is returned by the Close function, when the argument passed to it was a slice of kites.
Error is the type of the kite related errors returned from kite package.
Kite defines a single process that enables distributed service messaging amongst the peers it is connected.
Method defines a method and the Handler it is bind to.
Request contains information about the incoming request.
Response is the type of the object that is returned from request handlers and the type of only argument that is passed to callback functions.
TokenRenewer renews the token of a Client just before it expires.

# Interfaces

Objects implementing the Handler interface can be registered to a method.
Logger is the interface used to log messages in different levels.

# Type aliases

FinalFunc represents a proxy function that is called last in the method call chain, regardless whether whole call chained succeeded with non-nil error or not.
HandlerFunc is a type adapter to allow the use of ordinary functions as Kite handlers.
No description provided by the author
MethodHandling defines how to handle chaining of kite.Handler middlewares.