Documentation
¶
Index ¶
- type EtcdMetadataBootstraper
- type InitSQLMetadataBootstraper
- type InstanceImpl
- func (r *InstanceImpl) Addr() string
- func (r *InstanceImpl) Config() *config.Router
- func (r *InstanceImpl) Console() console.Console
- func (r *InstanceImpl) ID() string
- func (r *InstanceImpl) Initialize() bool
- func (r *InstanceImpl) Initialized() bool
- func (r *InstanceImpl) Run(ctx context.Context, listener net.Listener, pt port.RouterPortType) error
- func (r *InstanceImpl) RunAdm(ctx context.Context, listener net.Listener) error
- type RouterInstance
- type RouterMetadataBootstraper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EtcdMetadataBootstraper ¶
type EtcdMetadataBootstraper struct {
QdbAddr string
}
func (*EtcdMetadataBootstraper) InitializeMetadata ¶
func (e *EtcdMetadataBootstraper) InitializeMetadata(ctx context.Context, r RouterInstance) error
InitializeMetadata implements RouterMetadataBootstraper.
type InitSQLMetadataBootstraper ¶
type InitSQLMetadataBootstraper struct {
InitSQLFIle string
}
func (*InitSQLMetadataBootstraper) InitializeMetadata ¶
func (i *InitSQLMetadataBootstraper) InitializeMetadata(ctx context.Context, r RouterInstance) error
InitializeMetadata implements RouterMetadataBootstraper.
type InstanceImpl ¶
type InstanceImpl struct { RuleRouter rulerouter.RuleRouter Qrouter qrouter.QueryRouter AdmConsole console.Console Mgr meta.EntityMgr Writer workloadlog.WorkloadLog // contains filtered or unexported fields }
func (*InstanceImpl) Addr ¶
func (r *InstanceImpl) Addr() string
func (*InstanceImpl) Config ¶
func (r *InstanceImpl) Config() *config.Router
func (*InstanceImpl) Console ¶
func (r *InstanceImpl) Console() console.Console
Console implements RouterInstance.
func (*InstanceImpl) ID ¶
func (r *InstanceImpl) ID() string
func (*InstanceImpl) Initialize ¶
func (r *InstanceImpl) Initialize() bool
func (*InstanceImpl) Initialized ¶
func (r *InstanceImpl) Initialized() bool
func (*InstanceImpl) Run ¶
func (r *InstanceImpl) Run(ctx context.Context, listener net.Listener, pt port.RouterPortType) error
type RouterInstance ¶
type RouterMetadataBootstraper ¶
type RouterMetadataBootstraper interface {
InitializeMetadata(ctx context.Context, r RouterInstance) error
}
func NewEtcdMetadataBootstraper ¶
func NewEtcdMetadataBootstraper(QdbAddr string) RouterMetadataBootstraper
func NewInitSQLMetadataBootstraper ¶
func NewInitSQLMetadataBootstraper(InitSQLFIle string) RouterMetadataBootstraper
Click to show internal directories.
Click to hide internal directories.