internal/

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
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
broker
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
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/server/mock_balancer
streamingnode/client/handler/mock_assignment
streamingnode/client/handler/mock_consumer
streamingnode/client/handler/mock_producer
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/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
optimizers
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/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/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
dependency
dependency/kv
exprutil
flowgraph
funcutil
grpcclient
hookutil
importutilv2
importutilv2/binlog
importutilv2/common
importutilv2/json
importutilv2/numpy
importutilv2/parquet
indexcgowrapper
initcore
metrics
mock
pipeline
proxyutil
quota
ratelimitutil
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
tsoutil
typeutil
wrappers

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