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
↓ 3 callers
Function
NewToken
NewToken creates new JWT token for the gien username. It embedds the given public key as kontrolKey and signs the token with the private one.
testutil/testutil.go:36
↓ 3 callers
Method
Port
Port returns the TCP port number that the kite listens. Port must be called after the listener is initialized. You can use ServerReadyNotify function
server.go:118
↓ 3 callers
Method
ReadByte
()
sockjsclient/xhr.go:361
↓ 3 callers
Method
RemoveCallback
RemoveCallback removes the callback with id from callbacks. Can be used to remove unused callbacks to free memory.
dnode/scrubber.go:24
↓ 3 callers
Method
Reset
()
client.go:1046
↓ 3 callers
Method
Run
()
reverseproxy/reverseproxy.go:245
↓ 3 callers
Method
Scrub
Scrub creates an object that represents "callbacks" field in dnode message. The obj argument which will be scrubbed must be of array, slice, struct, o
dnode/scrub.go:15
↓ 3 callers
Method
SendWebRTCRequest
SendWebRTCRequest sends requests to kontrol for signalling purposes.
client.go:715
↓ 3 callers
Method
Shuffle
Shuffle shuffles the order of the kites. This is useful if you want send back a randomized list of kites.
kontrol/kites.go:24
↓ 3 callers
Method
SliceOfLength
SliceOfLength is a helper method to unmarshal a JSON Array with specified length.
dnode/partial.go:70
↓ 3 callers
Method
String
()
kitectl/command/list.go:129
↓ 3 callers
Method
Upsert
Upsert inserts or updates the value for the given kite
kontrol/storage.go:24
↓ 3 callers
Method
Values
Values returns the values of each field in order
protocol/protocol.go:69
↓ 3 callers
Method
collect
(rv reflect.Value, path Path, callbacks map[string]Path)
dnode/scrub.go:30
↓ 3 callers
Function
convertLevel
convertLevel converts a kite level into logging level
logger.go:62
↓ 3 callers
Function
createError
createError creates a new kite.Error for the given r variable
errors.go:41
↓ 3 callers
Function
isValid
(k *protocol.Kite, c version.Constraints, keyRest string)
kontrol/kites.go:45
↓ 3 callers
Function
pause
(args ...interface{})
kontrol/helper_test.go:316
↓ 3 callers
Method
registerUser
(username, publicKey, privateKey string)
kontrol/kontrol.go:363
↓ 3 callers
Function
s
(str string)
protocol/webrtc_test.go:149
↓ 3 callers
Method
setState
(state sockjs.SessionState)
sockjsclient/xhr.go:157
↓ 2 callers
Method
Add
(k *protocol.Kite, v *kontrolprotocol.RegisterValue)
kontrol/etcd.go:102
↓ 2 callers
Function
Callback
Callback is the wrapper for function when sending.
dnode/callback.go:43
↓ 2 callers
Method
Close
()
tunnelproxy/proxy.go:114
↓ 2 callers
Method
CloseNotify
()
tunnelproxy/proxy.go:106
↓ 2 callers
Method
DeleteKeyPair
DeleteKeyPair deletes the key with the given id or public key. (One of them can be empty)
kontrol/kontrol.go:220
↓ 2 callers
Method
Function
Function is a helper to unmarshal a callback function.
dnode/partial.go:108
↓ 2 callers
Method
GetKey
GetKey is used to get a new public key from kontrol if the current one is invalidated. The key is also replaced in memory and every request is going t
kontrolclient.go:254
↓ 2 callers
Method
HandleHTTPFunc
HandleHTTPFunc registers the HTTP handler for the given pattern into the underlying HTTP muxer.
kite.go:270
↓ 2 callers
Method
KiteFromKey
KiteFromKey returns a *protocol.Kite from an etcd key. etcd key is like: "/kites/devrim/env/mathworker/1/localhost/tardis.local/id"
kontrol/node.go:69
↓ 2 callers
Method
ListenAndServe
ListenAndServe listens on the TCP network address addr and then calls Serve with handler to handle requests on incoming connections.
reverseproxy/reverseproxy.go:195
↓ 2 callers
Function
NewMemKeyPairStorage
()
kontrol/keypair.go:66
↓ 2 callers
Function
NewScrubber
New returns a pointer to a new Scrubber.
dnode/scrubber.go:16
↓ 2 callers
Method
OnDisconnect
OnDisconnect adds a callback which is called when client disconnects from a remote kite.
client.go:619
↓ 2 callers
Method
OnFirstRequest
OnFirstRequest registers a function to run when we receive first request from other Kite.
kite.go:312
↓ 2 callers
Method
OnTokenExpire
OnTokenExpire adds a callback which is called when client receives token-is-expired error from a remote kite.
client.go:627
↓ 2 callers
Method
ReadToken
ReadToken reads Kite Claims from JWT token and uses them to initialize Config.
config/config.go:254
↓ 2 callers
Method
Recv
()
sockjsclient/xhr.go:102
↓ 2 callers
Method
Register
Register registers current Kite to Kontrol. After registration other Kites can find it via GetKites() or WatchKites() method. This method does not ha
kontrolclient.go:356
↓ 2 callers
Method
RegisterHTTP
RegisterHTTP registers current Kite to Kontrol. After registration other Kites can find it via GetKites() or WatchKites() method. It registers again i
heartbeat.go:130
↓ 2 callers
Method
RegisterHTTPForever
RegisterHTTPForever is just like RegisterHTTP however it first tries to register forever until a response from kontrol is received. It's useful to use
heartbeat.go:90
↓ 2 callers
Method
Send
(frame string)
sockjsclient/xhr.go:263
↓ 2 callers
Method
Slice
------------------------------------------- Helper methods for unmarshaling JSON types ------------------------------------------- Slice is a helper m
dnode/partial.go:64
↓ 2 callers
Method
Start
()
tunnelproxy/proxy.go:124
↓ 2 callers
Method
String
()
protocol/protocol.go:45
↓ 2 callers
Method
String
String is a helper to unmarshal a JSON String.
dnode/partial.go:90
↓ 2 callers
Method
String
()
examples/math/config.go:50
↓ 2 callers
Method
Validate
()
protocol/protocol.go:81
↓ 2 callers
Method
addHandle
addHandle is an internal method to add a handler
method.go:78
↓ 2 callers
Method
callOnConnectHandlers
callOnConnectHandlers runs the registered connect handlers.
client.go:642
↓ 2 callers
Method
callOnDisconnectHandlers
callOnDisconnectHandlers runs the registered disconnect handlers.
client.go:655
↓ 2 callers
Method
callOnRegisterHandlers
(r *protocol.RegisterResult)
kite.go:369
↓ 2 callers
Function
createTestKite
createTestKite creates a test kite, caller of this func should close the kite
kontrol/handlers_test.go:14
↓ 2 callers
Method
dial
(timeout time.Duration)
client.go:306
↓ 2 callers
Method
dialForever
(connectNotifyChan chan bool)
client.go:347
↓ 2 callers
Method
fields
fields walks over a structure and scrubs its fields.
dnode/scrub.go:71
↓ 2 callers
Method
generateToken
generateToken returns a JWT token string. Please see the URL for details: http://tools.ietf.org/html/draft-ietf-oauth-json-web-token-13#section-4.1
kontrol/kontrol.go:560
↓ 2 callers
Function
getAudience
(q *protocol.KontrolQuery)
kontrol/etcd.go:374
↓ 2 callers
Function
getBundlePath
getBundlePath returns the bundle path of a given kite. Example: "adsf-1.2.3" -> "~/.kd/kites/asdf-1.2.3.kite"
kitectl/command/uninstall.go:74
↓ 2 callers
Function
getInstalledKites
getIntalledKites returns installed kites in .kd/kites folder. an empty argument returns all kites.
kitectl/command/list.go:53
↓ 2 callers
Method
getKey
(preds ...interface{})
kontrol/postgres.go:432
↓ 2 callers
Method
getKontrolPath
(path string)
heartbeat.go:118
↓ 2 callers
Function
getLogLevel
getLogLevel returns the logging level defined via the KITE_LOG_LEVEL environment. It returns Info by default if no environment variable is set.
logger.go:46
↓ 2 callers
Method
getOrUpdateKeyID
(id string, r *kite.Request)
kontrol/handlers.go:391
↓ 2 callers
Method
getOrUpdateKeyPub
(pub string, t *jwt.Token, r *kite.Request)
kontrol/handlers.go:371
↓ 2 callers
Function
insertKiteQuery
inseryKiteQuery inserts the given kite, url and key to the kite.kite table
kontrol/postgres.go:364
↓ 2 callers
Method
isClosed
()
sockjsclient/xhr.go:306
↓ 2 callers
Function
isInstalled
isInstalled returns true if the kite is installed.
kitectl/command/uninstall.go:83
↓ 2 callers
Function
kiteKeyPath
()
kitekey/kitekey.go:43
↓ 2 callers
Method
marshalAndSend
marshalAndSend takes a method and arguments, scrubs the arguments to create a dnode message, marshals the message to JSON and sends it over the wire.
client.go:838
↓ 2 callers
Method
methods
methods walks over a structure and scrubs its exported methods.
dnode/scrub.go:106
↓ 2 callers
Function
newFrameReader
(r io.Reader, timeout time.Duration)
sockjsclient/xhr.go:336
↓ 2 callers
Method
parse
parse the token string and set
tokenrenewer.go:41
↓ 2 callers
Method
readLoop
readLoop reads a message from websocket and processes it.
client.go:425
↓ 2 callers
Method
reconnect
()
client.go:417
↓ 2 callers
Method
register
register is called when a function/method is found in arguments array. It assigns an unique ID to the passed callback and stores it internally.
dnode/scrub.go:123
↓ 2 callers
Method
renewDuration
The duration from now to the time token needs to be renewed. Needs to be calculated after renewing the token.
tokenrenewer.go:111
↓ 2 callers
Method
run
run consumes incoming dnode messages. Reconnects if necessary.
client.go:388
↓ 2 callers
Method
runCallback
runCallback is called when a callback method call is received from remote Kite.
request.go:122
↓ 2 callers
Method
runMethod
runMethod is called when a method is received from remote Kite.
request.go:62
↓ 2 callers
Function
selectQuery
selectQuery returns a SQL query for the given query
kontrol/postgres.go:334
↓ 2 callers
Method
sendHub
sendhub sends the msg received from the send channel to the remote client
client.go:572
↓ 2 callers
Function
setCallback
(value reflect.Value, path Path, cb functionReceived)
dnode/unscrub.go:31
↓ 2 callers
Method
setSession
(session sockjs.Session)
client.go:895
↓ 2 callers
Method
setState
(state sockjs.SessionState)
sockjsclient/sockjsclient.go:283
↓ 2 callers
Function
sockjsHandlerWithRequest
sockjsHandlerWithRequest is a wrapper around the sockjs.Handler that includes a *http.Request context.
tunnelproxy/proxy.go:94
↓ 2 callers
Function
threeDigits
threeDigits is used to generate a server_id.
sockjsclient/sockjsclient.go:303
↓ 2 callers
Method
tokenTTL
()
kontrol/kontrol.go:504
↓ 2 callers
Function
transportFromEnv
()
kite_test.go:39
↓ 2 callers
Method
updateKeyWithKeyPair
(t *jwt.Token, keyPair *KeyPair)
kontrol/handlers.go:347
↓ 2 callers
Function
validateKiteKey
validateKiteKey returns a string representing the kite uniquely that is suitable to use as a key for etcd.
kontrol/etcd.go:300
↓ 1 callers
Method
AuthenticateSimpleKiteKey
AuthenticateSimpleKiteKey authenticates user from the given kite key and returns the authenticated username. It's the same as AuthenticateFromKiteKey
request.go:299
↓ 1 callers
Method
BinPath
BinPath returns the path of the executable binary file.
kitectl/command/list.go:134
↓ 1 callers
Method
CancelRequest
(*http.Request)
sockjsclient/xhr.go:104
↓ 1 callers
Method
CleanExpiredRows
CleanExpiredRows deletes rows that are at least "expire" duration old. So if say an expire duration of 10 second is given, it will delete all rows tha
kontrol/postgres.go:111
↓ 1 callers
Method
CloseNotify
()
tunnelproxy/tunnel.go:32
↓ 1 callers
Function
Closer
Closer returns a io.Closer that can be used to close all the kites given by the generic argument. The kites is expected to be one of: - *kite.Kite -
kite.go:495
↓ 1 callers
Function
DialWebsocket
DialWebsocket establishes a SockJS session over a websocket connection. Requires cfg.Websocket to be a valid client.
sockjsclient/sockjsclient.go:136
↓ 1 callers
Function
DialXHR
DialXHR establishes a SockJS session over a XHR connection. Requires cfg.XHR to be a valid client.
sockjsclient/xhr.go:49
↓ 1 callers
Method
Extract
Extract is a keyFunc argument for jwt.Parse function.
kitekey/kitekey.go:110
← previous
next →
101–200 of 619, ranked by callers