MCPcopy Create free account

hub / github.com/koding/kite / functions

Functions619 in github.com/koding/kite

↓ 192 callersMethodError
Error logs to the ERROR, WARNING, INFO and DEBUG level.
logger.go:31
↓ 90 callersMethodFatal
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 callersMethodString
()
kontrol/kontrol.go:533
↓ 42 callersMethodHandleFunc
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 callersMethodInfo
Info logs to the INFO and DEBUG level.
logger.go:37
↓ 37 callersMethodTellWithTimeout
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 callersMethodUnmarshal
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 callersMethodDebug
Debug logs to the DEBUG level.
logger.go:40
↓ 30 callersMethodKite
Kite returns a single kite gathered from the key and the value for the current node.
kontrol/node.go:49
↓ 29 callersMethodCopy
Copy returns a new copy of the config object.
config/config.go:272
↓ 25 callersMethodGet
Get retrieves the Kites with the given query
kontrol/storage.go:12
↓ 25 callersMethodOne
()
dnode/partial.go:135
↓ 23 callersMethodDial
Dial connects to the remote Kite. Returns error if it can't.
client.go:234
↓ 23 callersMethodMustString
()
dnode/partial.go:145
↓ 23 callersMethodNewClient
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 callersMethodClose
Close stops kontrol and closes all connections
kontrol/kontrol.go:345
↓ 21 callersMethodAdd
Add inserts the given kite with the given value
kontrol/storage.go:15
↓ 20 callersMethodClose
Close stops the server and the kontrol client instance.
server.go:41
↓ 19 callersMethodServerReadyNotify
()
server.go:157
↓ 18 callersMethodSetStorage
SetStorage sets the backend storage that kontrol is going to use to store kites
kontrol/kontrol.go:334
↓ 16 callersMethodRun
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 callersFunctionNew
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 callersMethodGetKites
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 callersMethodCall
(args ...interface{})
dnode/callback.go:14
↓ 12 callersMethodDo
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 callersMethodKite
Kite returns the definition of the kite.
kite.go:232
↓ 10 callersMethodGetToken
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 callersMethodMustFloat64
()
dnode/partial.go:151
↓ 10 callersMethodPostHandleFunc
PostHandleFunc is the same as PostHandle. It accepts a HandlerFunc.
method.go:194
↓ 10 callersMethodPreHandleFunc
PreHandleFunc is the same as PreHandle. It accepts a HandlerFunc.
method.go:181
↓ 10 callersMethodRegisterForever
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 callersMethodWarning
Warning logs to the WARNING, INFO and DEBUG level.
logger.go:34
↓ 9 callersFunctionjsonError
jsonError returns a JSON string of form {"err" : "error content"}
kontrol/http.go:235
↓ 8 callersMethodAddr
()
server.go:64
↓ 8 callersMethodOnDisconnect
OnDisconnect registers a function to run when a connected Kite is disconnected.
kite.go:319
↓ 8 callersMethodQuery
Query() returns a pointer to KontrolQuery struct.
protocol/protocol.go:56
↓ 8 callersMethodSet
(ctx context.Context, key, value string, opts *etcd.SetOptions)
kontrol/etcd_keysapi_logger.go:27
↓ 8 callersMethodSetupKontrolClient
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 callersFunctioncheckError
---------------------------------------------------------------- Helper methods for unmarshaling JSON types that panic on errors ---------------------
dnode/partial.go:117
↓ 8 callersFunctionnopRecover
()
kite.go:548
↓ 7 callersMethodAddKeyPair
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 callersMethodClose
()
client.go:543
↓ 7 callersMethodClose
()
kontrol/helper_test.go:243
↓ 7 callersMethodDelete
Delete deletes the given kite from the storage
kontrol/storage.go:21
↓ 7 callersMethodReadEnvironmentVariables
()
config/config.go:188
↓ 7 callersMethodSet
(s string)
examples/math/config.go:42
↓ 7 callersMethodValue
Value returns the value associated with the current node.
kontrol/node.go:88
↓ 7 callersFunctionnewXhrKite
(name, version string)
kite_test.go:540
↓ 6 callersMethodAddKey
AddKey adds the given key pair to the storage
kontrol/keypair.go:42
↓ 6 callersMethodClose
()
kite.go:533
↓ 6 callersFunctionNewHelloKite
(name string, conf *Config)
kontrol/helper_test.go:99
↓ 6 callersMethodRegister
(hk *HelloKite)
kontrol/helper_test.go:28
↓ 6 callersMethodSeed
(seed int64)
utils/utils.go:30
↓ 6 callersFunctionklose
(clients []*kite.Client)
kontrol/helper_test.go:82
↓ 5 callersFunctionCall
(kitePairs HelloKites)
kontrol/helper_test.go:255
↓ 5 callersMethodFields
()
protocol/protocol.go:207
↓ 5 callersMethodGetKeyFromPublic
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 callersFunctionGetQueryKey
getQueryKey returns the etcd key for the query.
kontrol/etcd.go:339
↓ 5 callersMethodIsValid
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 callersMethodKeyPair
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 callersMethodKiteKey
KiteKey gives a kite key used to authenticate to kontrol and other kites.
kite.go:245
↓ 5 callersMethodKontrolReadyNotify
KontrolReadyNotify returns a channel that is closed when a successful registration to kontrol is done.
kontrolclient.go:292
↓ 5 callersFunctionNewNode
New returns a new initialized node with the given etcd node.
kontrol/node.go:20
↓ 5 callersMethodOnRegister
OnRegister registers a callback which is called when a Kite registers to a Kontrol.
kite.go:327
↓ 5 callersMethodRun
()
kontrol/kontrol.go:314
↓ 5 callersMethodRun
()
tunnelproxy/proxy.go:129
↓ 5 callersMethodSetKeyPairStorage
SetKeyPairStorage sets the backend storage that kontrol is going to use to store keypairs
kontrol/kontrol.go:340
↓ 5 callersMethodUpdate
Update updates the value for the given kite
kontrol/storage.go:18
↓ 5 callersMethodWaitRegister
(timeout time.Duration)
kontrol/helper_test.go:141
↓ 5 callersMethodWrite
(b []byte)
tunnelproxy/tunnel.go:75
↓ 5 callersMethodconfig
()
client.go:914
↓ 5 callersMethodgetSession
()
client.go:888
↓ 5 callersMethodtokenLeeway
()
kontrol/kontrol.go:512
↓ 4 callersMethodClose
(status uint32, reason string)
sockjsclient/xhr.go:295
↓ 4 callersMethodClose
()
tunnelproxy/tunnel.go:19
↓ 4 callersMethodDialTimeout
DialTimeout acts like Dial but takes a timeout.
client.go:240
↓ 4 callersMethodGetKeyFromID
GetKeyFromID retrieves the KeyPair from the given ID
kontrol/keypair.go:48
↓ 4 callersMethodHandle
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 callersMethodID
()
sockjsclient/xhr.go:98
↓ 4 callersFunctionNewEtcd
(machines []string, log kite.Logger)
kontrol/etcd.go:35
↓ 4 callersMethodOnConnect
OnConnect registers a callbacks which is called when a Kite connects to the k Kite.
kite.go:304
↓ 4 callersMethodRead
(p []byte)
sockjsclient/xhr.go:343
↓ 4 callersMethodServeKite
(*Request)
method.go:30
↓ 4 callersMethodTell
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 callersMethodValidate
()
kontrol/keypair.go:23
↓ 4 callersMethodfinal
(r *Request, resp interface{}, err error)
method.go:279
↓ 4 callersMethodpickKey
(r *kite.Request)
kontrol/handlers.go:319
↓ 4 callersFunctionstartKontrol
(pem, pub string, port int)
kontrol/helper_test.go:46
↓ 3 callersMethodBool
Bool is a helper to unmarshal a JSON Boolean.
dnode/partial.go:102
↓ 3 callersMethodDeleteKey
DeleteKey deletes the given key pairs from the storage
kontrol/keypair.go:45
↓ 3 callersMethodDialForever
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 callersMethodDisableAuthentication
DisableAuthentication disables authentication check for this method.
method.go:96
↓ 3 callersMethodFilter
Filter filters out kites with the given constraints
kontrol/kites.go:34
↓ 3 callersMethodFloat64
Float64 is a helper to unmarshal a JSON Number.
dnode/partial.go:96
↓ 3 callersMethodGo
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 callersMethodGoWithTimeout
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 callersMethodHandle
(rec *logging.Record)
testutil/testutil.go:113
↓ 3 callersMethodMustSliceOfLength
(length int)
dnode/partial.go:129
↓ 3 callersMethodMustUnmarshal
(v interface{})
dnode/partial.go:54
↓ 3 callersFunctionNewPostgres
(conf *PostgresConfig, log kite.Logger)
kontrol/postgres.go:46
next →1–100 of 619, ranked by callers