Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/koding/kite
/ functions
Functions
619 in github.com/koding/kite
⨍
Functions
619
◇
Types & classes
124
↓ 192 callers
Method
Error
Error logs to the ERROR, WARNING, INFO and DEBUG level.
logger.go:31
↓ 90 callers
Method
Fatal
Fatal logs to the FATAL, ERROR, WARNING, INFO and DEBUG levels, including a stack trace of all running goroutines, then calls os.Exit(1).
logger.go:28
↓ 60 callers
Method
String
()
kontrol/kontrol.go:533
↓ 42 callers
Method
HandleFunc
HandleFunc registers a handler to run when a method call is received from a Kite. It returns a *Method option to further modify certain options on a m
method.go:168
↓ 37 callers
Method
Info
Info logs to the INFO and DEBUG level.
logger.go:37
↓ 37 callers
Method
TellWithTimeout
TellWithTimeout does the same thing with Tell() method except it takes an extra argument that is the timeout for waiting reply from the remote Kite. I
client.go:727
↓ 36 callers
Method
Unmarshal
Unmarshal unmarshals the raw data (p.Raw) into v and prepares callbacks. v must be a struct that is the type of expected arguments.
dnode/partial.go:34
↓ 30 callers
Method
Debug
Debug logs to the DEBUG level.
logger.go:40
↓ 30 callers
Method
Kite
Kite returns a single kite gathered from the key and the value for the current node.
kontrol/node.go:49
↓ 29 callers
Method
Copy
Copy returns a new copy of the config object.
config/config.go:272
↓ 25 callers
Method
Get
Get retrieves the Kites with the given query
kontrol/storage.go:12
↓ 25 callers
Method
One
()
dnode/partial.go:135
↓ 23 callers
Method
Dial
Dial connects to the remote Kite. Returns error if it can't.
client.go:234
↓ 23 callers
Method
MustString
()
dnode/partial.go:145
↓ 23 callers
Method
NewClient
NewClient returns a pointer to a new Client. The returned instance is not connected. You have to call Dial() or DialForever() before calling Tell() an
client.go:203
↓ 22 callers
Method
Close
Close stops kontrol and closes all connections
kontrol/kontrol.go:345
↓ 21 callers
Method
Add
Add inserts the given kite with the given value
kontrol/storage.go:15
↓ 20 callers
Method
Close
Close stops the server and the kontrol client instance.
server.go:41
↓ 19 callers
Method
ServerReadyNotify
()
server.go:157
↓ 18 callers
Method
SetStorage
SetStorage sets the backend storage that kontrol is going to use to store kites
kontrol/kontrol.go:334
↓ 16 callers
Method
Run
Run is a blocking method. It runs the kite server and then accepts requests asynchronously. It supports graceful restart via SIGUSR2.
server.go:18
↓ 15 callers
Function
New
New creates, initializes and then returns a new Kite instance. Version must be in 3-digit semantic form. Name is important that it's also used to be
kite.go:163
↓ 14 callers
Method
GetKites
GetKites returns the list of Kites matching the query. The returned list contains Ready to connect Client instances. The caller must connect with Clie
kontrolclient.go:124
↓ 12 callers
Method
Call
(args ...interface{})
dnode/callback.go:14
↓ 12 callers
Method
Do
Do calls the function f if and only if Do hits the given periodic interval. In other words Do can be called multiple times during the interval but it
kontrol/onceevery/onceevery.go:28
↓ 12 callers
Method
Kite
Kite returns the definition of the kite.
kite.go:232
↓ 10 callers
Method
GetToken
GetToken is used to get a token for a single Kite. In case of calling GetToken multiple times, it usually returns the same token until it expires on
kontrolclient.go:187
↓ 10 callers
Method
MustFloat64
()
dnode/partial.go:151
↓ 10 callers
Method
PostHandleFunc
PostHandleFunc is the same as PostHandle. It accepts a HandlerFunc.
method.go:194
↓ 10 callers
Method
PreHandleFunc
PreHandleFunc is the same as PreHandle. It accepts a HandlerFunc.
method.go:181
↓ 10 callers
Method
RegisterForever
RegisterForever is equivalent to Register(), but it tries to re-register if there is a disconnection. The returned error is for the first register att
kontrolclient.go:306
↓ 9 callers
Method
Warning
Warning logs to the WARNING, INFO and DEBUG level.
logger.go:34
↓ 9 callers
Function
jsonError
jsonError returns a JSON string of form {"err" : "error content"}
kontrol/http.go:235
↓ 8 callers
Method
Addr
()
server.go:64
↓ 8 callers
Method
OnDisconnect
OnDisconnect registers a function to run when a connected Kite is disconnected.
kite.go:319
↓ 8 callers
Method
Query
Query() returns a pointer to KontrolQuery struct.
protocol/protocol.go:56
↓ 8 callers
Method
Set
(ctx context.Context, key, value string, opts *etcd.SetOptions)
kontrol/etcd_keysapi_logger.go:27
↓ 8 callers
Method
SetupKontrolClient
SetupKontrolClient setups and prepares a the kontrol instance. It connects to kontrol and reconnects again if there is any disconnections. This method
kontrolclient.go:53
↓ 8 callers
Function
checkError
---------------------------------------------------------------- Helper methods for unmarshaling JSON types that panic on errors ---------------------
dnode/partial.go:117
↓ 8 callers
Function
nopRecover
()
kite.go:548
↓ 7 callers
Method
AddKeyPair
AddKeyPair add the given key pair so it can be used to validate and sign/generate tokens. If id is empty, a unique ID will be generated. The last adde
kontrol/kontrol.go:279
↓ 7 callers
Method
Close
()
client.go:543
↓ 7 callers
Method
Close
()
kontrol/helper_test.go:243
↓ 7 callers
Method
Delete
Delete deletes the given kite from the storage
kontrol/storage.go:21
↓ 7 callers
Method
ReadEnvironmentVariables
()
config/config.go:188
↓ 7 callers
Method
Set
(s string)
examples/math/config.go:42
↓ 7 callers
Method
Value
Value returns the value associated with the current node.
kontrol/node.go:88
↓ 7 callers
Function
newXhrKite
(name, version string)
kite_test.go:540
↓ 6 callers
Method
AddKey
AddKey adds the given key pair to the storage
kontrol/keypair.go:42
↓ 6 callers
Method
Close
()
kite.go:533
↓ 6 callers
Function
NewHelloKite
(name string, conf *Config)
kontrol/helper_test.go:99
↓ 6 callers
Method
Register
(hk *HelloKite)
kontrol/helper_test.go:28
↓ 6 callers
Method
Seed
(seed int64)
utils/utils.go:30
↓ 6 callers
Function
klose
(clients []*kite.Client)
kontrol/helper_test.go:82
↓ 5 callers
Function
Call
(kitePairs HelloKites)
kontrol/helper_test.go:255
↓ 5 callers
Method
Fields
()
protocol/protocol.go:207
↓ 5 callers
Method
GetKeyFromPublic
GetKeyFromPublic retrieves the KeyPairs from the given public key. If the key is no longer valid and the storage is able to deterime that it was dele
kontrol/keypair.go:55
↓ 5 callers
Function
GetQueryKey
getQueryKey returns the etcd key for the query.
kontrol/etcd.go:339
↓ 5 callers
Method
IsValid
Is valid checks if the given publicKey is valid or not. It's up to the implementer how to implement it. A valid public key returns a nil error. If th
kontrol/keypair.go:63
↓ 5 callers
Method
KeyPair
KeyPair looks up a key pair that was used to sign Kontrol's kite key. The value is cached on first call of the function.
kontrol/kontrol.go:456
↓ 5 callers
Method
KiteKey
KiteKey gives a kite key used to authenticate to kontrol and other kites.
kite.go:245
↓ 5 callers
Method
KontrolReadyNotify
KontrolReadyNotify returns a channel that is closed when a successful registration to kontrol is done.
kontrolclient.go:292
↓ 5 callers
Function
NewNode
New returns a new initialized node with the given etcd node.
kontrol/node.go:20
↓ 5 callers
Method
OnRegister
OnRegister registers a callback which is called when a Kite registers to a Kontrol.
kite.go:327
↓ 5 callers
Method
Run
()
kontrol/kontrol.go:314
↓ 5 callers
Method
Run
()
tunnelproxy/proxy.go:129
↓ 5 callers
Method
SetKeyPairStorage
SetKeyPairStorage sets the backend storage that kontrol is going to use to store keypairs
kontrol/kontrol.go:340
↓ 5 callers
Method
Update
Update updates the value for the given kite
kontrol/storage.go:18
↓ 5 callers
Method
WaitRegister
(timeout time.Duration)
kontrol/helper_test.go:141
↓ 5 callers
Method
Write
(b []byte)
tunnelproxy/tunnel.go:75
↓ 5 callers
Method
config
()
client.go:914
↓ 5 callers
Method
getSession
()
client.go:888
↓ 5 callers
Method
tokenLeeway
()
kontrol/kontrol.go:512
↓ 4 callers
Method
Close
(status uint32, reason string)
sockjsclient/xhr.go:295
↓ 4 callers
Method
Close
()
tunnelproxy/tunnel.go:19
↓ 4 callers
Method
DialTimeout
DialTimeout acts like Dial but takes a timeout.
client.go:240
↓ 4 callers
Method
GetKeyFromID
GetKeyFromID retrieves the KeyPair from the given ID
kontrol/keypair.go:48
↓ 4 callers
Method
Handle
Handle registers the handler for the given method. The handler is called when a method call is received from a Kite.
method.go:161
↓ 4 callers
Method
ID
()
sockjsclient/xhr.go:98
↓ 4 callers
Function
NewEtcd
(machines []string, log kite.Logger)
kontrol/etcd.go:35
↓ 4 callers
Method
OnConnect
OnConnect registers a callbacks which is called when a Kite connects to the k Kite.
kite.go:304
↓ 4 callers
Method
Read
(p []byte)
sockjsclient/xhr.go:343
↓ 4 callers
Method
ServeKite
(*Request)
method.go:30
↓ 4 callers
Method
Tell
Tell makes a blocking method call to the server. Waits until the callback function is called by the other side and returns the result and the error.
client.go:710
↓ 4 callers
Method
Validate
()
kontrol/keypair.go:23
↓ 4 callers
Method
final
(r *Request, resp interface{}, err error)
method.go:279
↓ 4 callers
Method
pickKey
(r *kite.Request)
kontrol/handlers.go:319
↓ 4 callers
Function
startKontrol
(pem, pub string, port int)
kontrol/helper_test.go:46
↓ 3 callers
Method
Bool
Bool is a helper to unmarshal a JSON Boolean.
dnode/partial.go:102
↓ 3 callers
Method
DeleteKey
DeleteKey deletes the given key pairs from the storage
kontrol/keypair.go:45
↓ 3 callers
Method
DialForever
Dial connects to the remote Kite. If it can't connect, it retries indefinitely. It returns a channel to check if it's connected or not.
client.go:256
↓ 3 callers
Method
DisableAuthentication
DisableAuthentication disables authentication check for this method.
method.go:96
↓ 3 callers
Method
Filter
Filter filters out kites with the given constraints
kontrol/kites.go:34
↓ 3 callers
Method
Float64
Float64 is a helper to unmarshal a JSON Number.
dnode/partial.go:96
↓ 3 callers
Method
Go
Go makes an unblocking method call to the server. It returns a channel that the caller can wait on it to get the response.
client.go:734
↓ 3 callers
Method
GoWithTimeout
GoWithTimeout does the same thing with Go() method except it takes an extra argument that is the timeout for waiting reply from the remote Kite. If ti
client.go:741
↓ 3 callers
Method
Handle
(rec *logging.Record)
testutil/testutil.go:113
↓ 3 callers
Method
MustSliceOfLength
(length int)
dnode/partial.go:129
↓ 3 callers
Method
MustUnmarshal
(v interface{})
dnode/partial.go:54
↓ 3 callers
Function
NewPostgres
(conf *PostgresConfig, log kite.Logger)
kontrol/postgres.go:46
next →
1–100 of 619, ranked by callers