Documentation ¶
Index ¶
Constants ¶
View Source
const FastpathBatchMaxSize = 100
View Source
const FastpathMaxConcurrency = 500
View Source
const FastpathMaxTxnConcurrency = 100
View Source
const LoginVersion = "v0.1.4-alpha.2"
View Source
const MaxMuxWidth = 64
View Source
const MaxPreAuthWebSocketIncomingMessageSize = 1024 * 100 // 100KiB
View Source
const MaxWebSocketIncomingMessageSize = 1024 * 1024 * 20 // 20MiB
View Source
const PingInterval = 500 * time.Millisecond
Variables ¶
View Source
var RetryableFastpathError = errors.New("retryable fastpath error")
Functions ¶
Types ¶
type Fastpath ¶
type Fastpath struct {
// contains filtered or unexported fields
}
func NewFastpath ¶
func NewFastpath(logger *zap.Logger, cluster *MdsCluster, ss subspace.Subspace, perm StorePermission) *Fastpath
type Mds ¶
type Mds struct {
// contains filtered or unexported fields
}
func (*Mds) ReplicaReadTransactor ¶
func (m *Mds) ReplicaReadTransactor() fdb.ReadTransactor
type MdsCluster ¶
type MdsCluster struct { RawConfig []byte // contains filtered or unexported fields }
func NewMdsCluster ¶
func (*MdsCluster) PrimaryTransactor ¶
func (s *MdsCluster) PrimaryTransactor() fdb.Transactor
func (*MdsCluster) ReplicaReadTransactor ¶
func (s *MdsCluster) ReplicaReadTransactor() fdb.ReadTransactor
type MdsConfig ¶
type MdsConfig struct { RootStore RootStoreConfig `yaml:"rootStore"` Region string }
type MdsSession ¶
type MdsSession struct {
// contains filtered or unexported fields
}
func NewMdsSession ¶
func NewMdsSession(logger *zap.Logger, cluster *MdsCluster, ss subspace.Subspace, perm StorePermission) *MdsSession
type RootStoreConfig ¶
type StorePermission ¶
type StorePermission int
const ( StorePermissionDenied StorePermission = iota StorePermissionReadOnly StorePermissionReadWrite )
func (StorePermission) String ¶
func (p StorePermission) String() string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.