internal/

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

Links

Open Source Insights

Directories ¶

Path	Synopsis
allocator
datacoord Package datacoord contains core functions in datacoord	Package datacoord contains core functions in datacoord
allocator
broker
session
datanode Package datanode implements data persistence logic.	Package datanode implements data persistence logic.
allocator
channel
compaction
importv2
iterators
util
distributed
datacoord Package grpcdatacoord implements grpc server for datacoord	Package grpcdatacoord implements grpc server for datacoord
datacoord/client
datanode
datanode/client
indexnode
indexnode/client
proxy
proxy/client
proxy/httpserver
querycoord
querycoord/client
querynode
querynode/client
rootcoord
rootcoord/client
streaming
streaming/internal/consumer
streaming/internal/errs
streaming/internal/producer
streamingnode
utils
flushcommon
broker
io
metacache
metacache/pkoracle
pipeline
syncmgr
util
writebuffer
http
healthz
indexnode
json
kv
etcd
mem
mocks
tikv
metastore
kv/binlog
kv/datacoord
kv/querycoord
kv/rootcoord
kv/streamingcoord
kv/streamingnode
mocks
model
mocks
distributed/mock_streaming
google.golang.org/grpc/mock_balancer
google.golang.org/grpc/mock_resolver
google.golang.org/mock_grpc
mock_metastore
streamingcoord/mock_client
streamingcoord/server/mock_balancer
streamingnode/client/handler/mock_assignment
streamingnode/client/handler/mock_consumer
streamingnode/client/handler/mock_producer
streamingnode/client/mock_handler
streamingnode/client/mock_manager
streamingnode/server/mock_flusher
streamingnode/server/mock_wal
streamingnode/server/mock_walmanager
streamingnode/server/wal/interceptors/segment/mock_inspector
streamingnode/server/wal/interceptors/timetick/mock_inspector
streamingnode/server/wal/mock_interceptors
util/streamingutil/service/mock_discoverer
util/streamingutil/service/mock_lazygrpc
util/streamingutil/service/mock_resolver
parser
planparserv2
planparserv2/generated
proxy Licensed to the LF AI & Data foundation under one or more contributor license agreements.	Licensed to the LF AI & Data foundation under one or more contributor license agreements.
accesslog
accesslog/info
connection
querycoordv2
balance
checkers
dist
job
meta
mocks
observers
params
session
task
utils
querynodev2
cluster delegator package contains the logic of shard delegator.	delegator package contains the logic of shard delegator.
collector
delegator delegator package contains the logic of shard delegator.	delegator package contains the logic of shard delegator.
delegator/deletebuffer
pipeline
pkoracle pkoracle package contains pk - segment mapping logic.	pkoracle package contains pk - segment mapping logic.
segments
segments/metricsutil
segments/state
tasks
tsafe
registry
rootcoord
mocks
storage
aliyun
aliyun/mocks
gcp
tencent
streamingcoord
client
client/assignment
server
server/balancer
server/balancer/channel
server/balancer/policy
server/resource
server/service
server/service/discover
streamingnode
client/handler
client/handler/assignment
client/handler/consumer
client/handler/producer
client/manager
server
server/flusher
server/flusher/flusherimpl
server/resource
server/resource/idalloc
server/service
server/service/handler/consumer
server/service/handler/producer
server/wal
server/wal/adaptor
server/wal/interceptors
server/wal/interceptors/ddl
server/wal/interceptors/redo
server/wal/interceptors/segment
server/wal/interceptors/segment/inspector
server/wal/interceptors/segment/manager
server/wal/interceptors/segment/policy
server/wal/interceptors/segment/stats
server/wal/interceptors/timetick
server/wal/interceptors/timetick/ack
server/wal/interceptors/timetick/inspector
server/wal/interceptors/txn
server/wal/metricsutil
server/wal/registry
server/wal/utility
server/walmanager
tso
mocks
types
util
analyzecgowrapper
bloomfilter Licensed to the LF AI & Data foundation under one or more contributor license agreements.	Licensed to the LF AI & Data foundation under one or more contributor license agreements.
cgo
cgoconverter
clustering
componentutil
ctokenizer
dependency
dependency/kv
exprutil
flowgraph
function
funcutil
grpcclient
hookutil
importutilv2
importutilv2/binlog
importutilv2/common
importutilv2/csv
importutilv2/json
importutilv2/numpy
importutilv2/parquet
indexcgowrapper
indexparamcheck
initcore
metrics
mock
nullutil
pipeline
proxyutil
quota
ratelimitutil
reduce
searchutil/optimizers
searchutil/scheduler
segmentutil
sessionutil Licensed to the LF AI & Data foundation under one or more contributor license agreements.	Licensed to the LF AI & Data foundation under one or more contributor license agreements.
streamingutil
streamingutil/service/attributes
streamingutil/service/balancer
streamingutil/service/balancer/picker
streamingutil/service/contextutil
streamingutil/service/discoverer
streamingutil/service/interceptor
streamingutil/service/lazygrpc
streamingutil/service/resolver
streamingutil/status
streamingutil/util
streamrpc
testutil
tokenizerapi
tokenizerapi/mocks
tsoutil
typeutil
vecindexmgr
wrappers

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL