Functions — github.com/mediachain/concat

hub / github.com/mediachain/concat / functions

Functions779 in github.com/mediachain/concat

⨍ Functions 779◇ Types & classes 159

↓ 136 callersFunctioncheckContains

(t *testing.T, where string, res []interface{}, val interface{})

mc/query/query_test.go:148

↓ 135 callersFunctioncheckErrorNow

(t *testing.T, where string, err error)

mc/query/query_test.go:130

↓ 97 callersFunctioncheckResultLen

(t *testing.T, where string, res []interface{}, xlen int)

mc/query/query_test.go:138

↓ 63 callersFunctionapiError

(w http.ResponseWriter, status int, err error)

mcnode/api.go:26

↓ 63 callersFunctionparseCompileEval

(db *sql.DB, qs string)

mc/query/query_test.go:1260

↓ 60 callersMethodError

()

mcnode/node.go:142

↓ 40 callersMethodClose

()

mcnode/node.go:84

↓ 37 callersFunctionParseQuery

query parsing

mc/query/parse.go:8

↓ 33 callersFunctionEvalQuery

query evaluation: very primitive eval with only simple statements will have to do until we have an index and we can compile to sql.

mc/query/eval.go:11

↓ 32 callersMethodPretty

()

mc/identity.go:29

↓ 23 callersMethodpush

(val interface{})

mc/query/parse.go:158

↓ 20 callersMethodpop

()

mc/query/parse.go:163

↓ 17 callersMethodScan

(res ...interface{})

mc/query/compile.go:18

↓ 13 callersMethodString

()

mc/nat.go:33

↓ 11 callersFunctionapiNetError

(w http.ResponseWriter, err error)

mcnode/api.go:31

↓ 10 callersMethodGet

↓ 6 callersMethodOpen

(home string)

mcnode/node.go:67

↓ 6 callersMethodQuery

(*mcq.Query)

mcnode/node.go:55

↓ 6 callersFunctiondisambigSelector

when we are JOINing, id is ambiguous because it is a column in both tables; this funciton disambiguates

mc/query/compile.go:122

↓ 6 callersMethoddoConnect

Connectivity

mcnode/net.go:458

↓ 6 callersFunctionentityKeyNotFound

(what string)

mc/entity.go:36

↓ 5 callersFunctionapiConfigMethod

config api

mcnode/api.go:1002

↓ 5 callersMethoddoDirConnect

(ctx context.Context, dir p2p_pstore.PeerInfo, proto p2p_proto.ID)

mcnode/net.go:813

↓ 5 callersFunctionisAddrSubnet

multiaddr juggling

mc/util.go:138

↓ 5 callersMethodisParentOf

(u token32)

mc/query/query.peg.go:236

↓ 5 callersFunctionmakeSubnetSpec

(subnets []string)

mc/util.go:174

↓ 5 callersMethodsaveConfig

()

mcnode/node.go:334

↓ 5 callersFunctionsendStreamError

(ctx context.Context, ch chan interface{}, what string)

mcnode/node.go:154

↓ 4 callersMethodDelete

(Key)

mcnode/node.go:72

↓ 4 callersMethodExpand

(index int)

mc/query/query.peg.go:474

↓ 4 callersMethodGetBody

()

proto/stmt.pb.go:73

↓ 4 callersMethodGetValue

()

proto/node.pb.go:416

↓ 4 callersMethodQueryStream

(context.Context, *mcq.Query)

mcnode/node.go:56

↓ 4 callersFunctionmarshalJSON

(m pb.Message)

proto/json.go:8

↓ 4 callersFunctionselectorColumn

(sel SimpleSelector, rename map[string]string)

mc/query/compile.go:133

↓ 4 callersFunctionunmarshalJSON

(data []byte, m pb.Message)

proto/json.go:14

↓ 3 callersMethodGetResult

()

proto/node.pb.go:138

↓ 3 callersMethodGetResult

()

proto/node.pb.go:628

↓ 3 callersMethodMergeBatch

([]*pb.Statement)

mcnode/node.go:59

↓ 3 callersMethodString

()

mc/query/query.peg.go:244

↓ 3 callersMethoddoConnectPeer

(ctx context.Context, pid p2p_peer.ID)

mcnode/net.go:467

↓ 3 callersMethoddoDirCollect

(ctx context.Context, proc func(ctx context.Context, dir p2p_pstore.PeerInfo) ([]string, error))

mcnode/net.go:659

↓ 3 callersMethodlistPeersFilter

(filter func(PeerRecord) bool)

mcdir/dir.go:100

↓ 3 callersMethodlookupManifest

(filter func(*pb.Manifest) bool)

mcdir/mfs.go:125

↓ 3 callersMethodmakePublicAddr

(addr, port string)

mc/nat.go:80

↓ 3 callersMethodmergeObjectKey

(key58 string, keys map[string]Key)

mcnode/proto.go:791

↓ 2 callersMethodBootstrap

()

mcnode/node.go:80

↓ 2 callersMethodCompact

()

mcnode/node.go:75

↓ 2 callersFunctionCompileQuery

CompileQuery compiles a query to sql. Returns the compiled sql query and a selector for extracting values from an sql result set Note: The row selecto

mc/query/compile.go:31

↓ 2 callersMethodGetBody

()

proto/node.pb.go:795

↓ 2 callersFunctionGetPublicIP

()

mc/nat.go:128

↓ 2 callersMethodGetValue

()

proto/node.pb.go:285

↓ 2 callersMethodGetValue

↓ 2 callersMethodIsSimpleSelect

(sel string)

mc/query/query.go:23

↓ 2 callersMethodIterKeys

(ctx context.Context)

mcnode/node.go:73

↓ 2 callersMethodOrder

()

mc/query/query.peg.go:263

↓ 2 callersMethodPreOrder

()

mc/query/query.peg.go:322

↓ 2 callersMethodProvide

(ctx context.Context, key string)

mcnode/node.go:82

↓ 2 callersFunctionPublisherID58

(pubk p2p_crypto.PubKey)

mc/identity.go:142

↓ 2 callersFunctionSimpleValueOf

(sv *pb.SimpleValue)

mc/message.go:101

↓ 2 callersFunctionStatementRefs

(stmt *pb.Statement)

mc/query/stmt.go:7

↓ 2 callersMethodTokens

()

mc/query/query.peg.go:450

↓ 2 callersMethodVacuum

(full bool)

mcnode/node.go:61

↓ 2 callersMethod_goOnline

↓ 2 callersMethodaddSimpleKeys

(s *pb.SimpleStatement, keys map[string]bool)

mcnode/gc.go:148

↓ 2 callersMethodbegin

(hint int)

mc/query/eval.go:36

↓ 2 callersMethodbootstrapConnect

(ctx context.Context, count int)

mcnode/dht.go:76

↓ 2 callersFunctioncheckBool

(t *testing.T, where string, e bool)

mc/query/query_test.go:158

↓ 2 callersFunctioncheckError

(t *testing.T, where string, err error)

mc/query/query_test.go:123

↓ 2 callersFunctioncheckFunctionSelector

(sel *FunctionSelector)

mc/query/eval.go:370

↓ 2 callersMethodcheckStatement

(stmt *pb.Statement)

mcnode/node.go:267

↓ 2 callersMethoddoImport

(stmts []*pb.Statement, pkcache map[string]p2p_crypto.PubKey)

mcnode/node.go:199

↓ 2 callersMethoddoLookup

(ctx context.Context, pid p2p_peer.ID)

mcnode/net.go:489

↓ 2 callersMethoddoMergeDataImpl

(s p2p_net.Stream, keys map[string]Key)

mcnode/proto.go:655

↓ 2 callersMethoddoMergeStream

(ctx context.Context, pid p2p_peer.ID, ch <-chan interface{})

mcnode/proto.go:503

↓ 2 callersMethoddoPublishBatch

(ns string, lst []interface{})

mcnode/node.go:179

↓ 2 callersMethoddoRemoteQuery

(ctx context.Context, pid p2p_peer.ID, q string)

↓ 2 callersFunctiongetIdentity

identity

mcid/main.go:175

↓ 2 callersMethodgetToken32

()

mc/query/query.peg.go:240

↓ 2 callersMethodhttpDirListImpl

(w http.ResponseWriter, r *http.Request, inclSelf bool)

mcnode/api.go:241

↓ 2 callersFunctionloadKey

Key management

mc/identity.go:158

↓ 2 callersFunctionmakeSimpleResultSet

(getf StatementSelector, limit int)

mc/query/eval.go:441

↓ 2 callersMethodmakeStatement

(ns string, body interface{})

mcnode/node.go:218

↓ 2 callersMethodmergeKeys

(keys map[string]bool)

mcnode/gc.go:155

↓ 2 callersMethodmergeSimple

(stmt *pb.SimpleStatement)

mc/query/stmt.go:32

↓ 2 callersMethodmergeStatement

(stmt *pb.Statement)

mc/query/stmt.go:19

↓ 2 callersMethodnatAddr

()

mcnode/net.go:314

↓ 2 callersFunctionparseEval

(qs string, stmts []*pb.Statement)

mc/query/query_test.go:595

↓ 2 callersMethodresult

()

mc/query/eval.go:39

↓ 2 callersFunctionsaveKey

(privk p2p_crypto.PrivKey, kpath string)

mc/identity.go:167

↓ 2 callersFunctionselectorp

(sel QuerySelector, tbl map[string]bool, funp bool)

mc/query/compile.go:508

↓ 2 callersMethodsklen

()

mc/query/parse.go:173

↓ 2 callersMethodtoJSON

()

mcnode/node.go:454

↓ 2 callersFunctionunmarshalEntityKeyBytes

(key []byte, khash multihash.Multihash)

mc/entity.go:194

↓ 2 callersMethodvalue

()

mc/query/compile.go:285

↓ 2 callersMethodverifyStatementCacheKeys

(stmt *pb.Statement, pkcache map[string]p2p_crypto.PubKey)

mcnode/node.go:285

next →1–100 of 779, ranked by callers