MCPcopy Create free account

hub / github.com/koding/kite / functions

Functions619 in github.com/koding/kite

↓ 3 callersFunctionNewToken
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 callersMethodPort
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 callersMethodReadByte
()
sockjsclient/xhr.go:361
↓ 3 callersMethodRemoveCallback
RemoveCallback removes the callback with id from callbacks. Can be used to remove unused callbacks to free memory.
dnode/scrubber.go:24
↓ 3 callersMethodReset
()
client.go:1046
↓ 3 callersMethodRun
()
reverseproxy/reverseproxy.go:245
↓ 3 callersMethodScrub
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 callersMethodSendWebRTCRequest
SendWebRTCRequest sends requests to kontrol for signalling purposes.
client.go:715
↓ 3 callersMethodShuffle
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 callersMethodSliceOfLength
SliceOfLength is a helper method to unmarshal a JSON Array with specified length.
dnode/partial.go:70
↓ 3 callersMethodString
()
kitectl/command/list.go:129
↓ 3 callersMethodUpsert
Upsert inserts or updates the value for the given kite
kontrol/storage.go:24
↓ 3 callersMethodValues
Values returns the values of each field in order
protocol/protocol.go:69
↓ 3 callersMethodcollect
(rv reflect.Value, path Path, callbacks map[string]Path)
dnode/scrub.go:30
↓ 3 callersFunctionconvertLevel
convertLevel converts a kite level into logging level
logger.go:62
↓ 3 callersFunctioncreateError
createError creates a new kite.Error for the given r variable
errors.go:41
↓ 3 callersFunctionisValid
(k *protocol.Kite, c version.Constraints, keyRest string)
kontrol/kites.go:45
↓ 3 callersFunctionpause
(args ...interface{})
kontrol/helper_test.go:316
↓ 3 callersMethodregisterUser
(username, publicKey, privateKey string)
kontrol/kontrol.go:363
↓ 3 callersFunctions
(str string)
protocol/webrtc_test.go:149
↓ 3 callersMethodsetState
(state sockjs.SessionState)
sockjsclient/xhr.go:157
↓ 2 callersMethodAdd
(k *protocol.Kite, v *kontrolprotocol.RegisterValue)
kontrol/etcd.go:102
↓ 2 callersFunctionCallback
Callback is the wrapper for function when sending.
dnode/callback.go:43
↓ 2 callersMethodClose
()
tunnelproxy/proxy.go:114
↓ 2 callersMethodCloseNotify
()
tunnelproxy/proxy.go:106
↓ 2 callersMethodDeleteKeyPair
DeleteKeyPair deletes the key with the given id or public key. (One of them can be empty)
kontrol/kontrol.go:220
↓ 2 callersMethodFunction
Function is a helper to unmarshal a callback function.
dnode/partial.go:108
↓ 2 callersMethodGetKey
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 callersMethodHandleHTTPFunc
HandleHTTPFunc registers the HTTP handler for the given pattern into the underlying HTTP muxer.
kite.go:270
↓ 2 callersMethodKiteFromKey
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 callersMethodListenAndServe
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 callersFunctionNewMemKeyPairStorage
()
kontrol/keypair.go:66
↓ 2 callersFunctionNewScrubber
New returns a pointer to a new Scrubber.
dnode/scrubber.go:16
↓ 2 callersMethodOnDisconnect
OnDisconnect adds a callback which is called when client disconnects from a remote kite.
client.go:619
↓ 2 callersMethodOnFirstRequest
OnFirstRequest registers a function to run when we receive first request from other Kite.
kite.go:312
↓ 2 callersMethodOnTokenExpire
OnTokenExpire adds a callback which is called when client receives token-is-expired error from a remote kite.
client.go:627
↓ 2 callersMethodReadToken
ReadToken reads Kite Claims from JWT token and uses them to initialize Config.
config/config.go:254
↓ 2 callersMethodRecv
()
sockjsclient/xhr.go:102
↓ 2 callersMethodRegister
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 callersMethodRegisterHTTP
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 callersMethodRegisterHTTPForever
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 callersMethodSend
(frame string)
sockjsclient/xhr.go:263
↓ 2 callersMethodSlice
------------------------------------------- Helper methods for unmarshaling JSON types ------------------------------------------- Slice is a helper m
dnode/partial.go:64
↓ 2 callersMethodStart
()
tunnelproxy/proxy.go:124
↓ 2 callersMethodString
()
protocol/protocol.go:45
↓ 2 callersMethodString
String is a helper to unmarshal a JSON String.
dnode/partial.go:90
↓ 2 callersMethodString
()
examples/math/config.go:50
↓ 2 callersMethodValidate
()
protocol/protocol.go:81
↓ 2 callersMethodaddHandle
addHandle is an internal method to add a handler
method.go:78
↓ 2 callersMethodcallOnConnectHandlers
callOnConnectHandlers runs the registered connect handlers.
client.go:642
↓ 2 callersMethodcallOnDisconnectHandlers
callOnDisconnectHandlers runs the registered disconnect handlers.
client.go:655
↓ 2 callersMethodcallOnRegisterHandlers
(r *protocol.RegisterResult)
kite.go:369
↓ 2 callersFunctioncreateTestKite
createTestKite creates a test kite, caller of this func should close the kite
kontrol/handlers_test.go:14
↓ 2 callersMethoddial
(timeout time.Duration)
client.go:306
↓ 2 callersMethoddialForever
(connectNotifyChan chan bool)
client.go:347
↓ 2 callersMethodfields
fields walks over a structure and scrubs its fields.
dnode/scrub.go:71
↓ 2 callersMethodgenerateToken
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 callersFunctiongetAudience
(q *protocol.KontrolQuery)
kontrol/etcd.go:374
↓ 2 callersFunctiongetBundlePath
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 callersFunctiongetInstalledKites
getIntalledKites returns installed kites in .kd/kites folder. an empty argument returns all kites.
kitectl/command/list.go:53
↓ 2 callersMethodgetKey
(preds ...interface{})
kontrol/postgres.go:432
↓ 2 callersMethodgetKontrolPath
(path string)
heartbeat.go:118
↓ 2 callersFunctiongetLogLevel
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 callersMethodgetOrUpdateKeyID
(id string, r *kite.Request)
kontrol/handlers.go:391
↓ 2 callersMethodgetOrUpdateKeyPub
(pub string, t *jwt.Token, r *kite.Request)
kontrol/handlers.go:371
↓ 2 callersFunctioninsertKiteQuery
inseryKiteQuery inserts the given kite, url and key to the kite.kite table
kontrol/postgres.go:364
↓ 2 callersMethodisClosed
()
sockjsclient/xhr.go:306
↓ 2 callersFunctionisInstalled
isInstalled returns true if the kite is installed.
kitectl/command/uninstall.go:83
↓ 2 callersFunctionkiteKeyPath
()
kitekey/kitekey.go:43
↓ 2 callersMethodmarshalAndSend
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 callersMethodmethods
methods walks over a structure and scrubs its exported methods.
dnode/scrub.go:106
↓ 2 callersFunctionnewFrameReader
(r io.Reader, timeout time.Duration)
sockjsclient/xhr.go:336
↓ 2 callersMethodparse
parse the token string and set
tokenrenewer.go:41
↓ 2 callersMethodreadLoop
readLoop reads a message from websocket and processes it.
client.go:425
↓ 2 callersMethodreconnect
()
client.go:417
↓ 2 callersMethodregister
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 callersMethodrenewDuration
The duration from now to the time token needs to be renewed. Needs to be calculated after renewing the token.
tokenrenewer.go:111
↓ 2 callersMethodrun
run consumes incoming dnode messages. Reconnects if necessary.
client.go:388
↓ 2 callersMethodrunCallback
runCallback is called when a callback method call is received from remote Kite.
request.go:122
↓ 2 callersMethodrunMethod
runMethod is called when a method is received from remote Kite.
request.go:62
↓ 2 callersFunctionselectQuery
selectQuery returns a SQL query for the given query
kontrol/postgres.go:334
↓ 2 callersMethodsendHub
sendhub sends the msg received from the send channel to the remote client
client.go:572
↓ 2 callersFunctionsetCallback
(value reflect.Value, path Path, cb functionReceived)
dnode/unscrub.go:31
↓ 2 callersMethodsetSession
(session sockjs.Session)
client.go:895
↓ 2 callersMethodsetState
(state sockjs.SessionState)
sockjsclient/sockjsclient.go:283
↓ 2 callersFunctionsockjsHandlerWithRequest
sockjsHandlerWithRequest is a wrapper around the sockjs.Handler that includes a *http.Request context.
tunnelproxy/proxy.go:94
↓ 2 callersFunctionthreeDigits
threeDigits is used to generate a server_id.
sockjsclient/sockjsclient.go:303
↓ 2 callersMethodtokenTTL
()
kontrol/kontrol.go:504
↓ 2 callersFunctiontransportFromEnv
()
kite_test.go:39
↓ 2 callersMethodupdateKeyWithKeyPair
(t *jwt.Token, keyPair *KeyPair)
kontrol/handlers.go:347
↓ 2 callersFunctionvalidateKiteKey
validateKiteKey returns a string representing the kite uniquely that is suitable to use as a key for etcd.
kontrol/etcd.go:300
↓ 1 callersMethodAuthenticateSimpleKiteKey
AuthenticateSimpleKiteKey authenticates user from the given kite key and returns the authenticated username. It's the same as AuthenticateFromKiteKey
request.go:299
↓ 1 callersMethodBinPath
BinPath returns the path of the executable binary file.
kitectl/command/list.go:134
↓ 1 callersMethodCancelRequest
(*http.Request)
sockjsclient/xhr.go:104
↓ 1 callersMethodCleanExpiredRows
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 callersMethodCloseNotify
()
tunnelproxy/tunnel.go:32
↓ 1 callersFunctionCloser
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 callersFunctionDialWebsocket
DialWebsocket establishes a SockJS session over a websocket connection. Requires cfg.Websocket to be a valid client.
sockjsclient/sockjsclient.go:136
↓ 1 callersFunctionDialXHR
DialXHR establishes a SockJS session over a XHR connection. Requires cfg.XHR to be a valid client.
sockjsclient/xhr.go:49
↓ 1 callersMethodExtract
Extract is a keyFunc argument for jwt.Parse function.
kitekey/kitekey.go:110
← previousnext →101–200 of 619, ranked by callers