Documentation
¶
Index ¶
- type DispatcherClient
- type MetaServerClient
- type SchemaRegistryClient
- func (c *SchemaRegistryClient) Close()
- func (c *SchemaRegistryClient) RefreshAddr(newAddr string) error
- func (c *SchemaRegistryClient) SendDDLChange(ctx context.Context, req *pb.RegisterDDLReq) (*pb.RegisterDDLResp, error)
- func (c *SchemaRegistryClient) SendSchemaSnap(ctx context.Context, req *pb.RegisterSchemaSnapReq) (*pb.RegisterSchemaSnapResp, error)
- type SorterClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DispatcherClient ¶
type DispatcherClient struct {
// contains filtered or unexported fields
}
func NewDispatcherClient ¶
func NewDispatcherClient(addr string) (*DispatcherClient, error)
func (*DispatcherClient) Close ¶
func (c *DispatcherClient) Close()
func (*DispatcherClient) NotifyTenantHasUpdate ¶
func (c *DispatcherClient) NotifyTenantHasUpdate(ctx context.Context, req *pb.HasNewChangeReq) error
func (*DispatcherClient) ScheduleNewTenant ¶
func (c *DispatcherClient) ScheduleNewTenant(ctx context.Context, req *pb.TenantTasksReq) error
type MetaServerClient ¶
type MetaServerClient struct {
// contains filtered or unexported fields
}
Todo: handle meta-server scale-out and scale-in cases, dynamically add or remove meta-server addr.
func NewMetaServerClient ¶
func NewMetaServerClient(addrs []string) (*MetaServerClient, error)
func (*MetaServerClient) Close ¶
func (c *MetaServerClient) Close()
func (*MetaServerClient) FetchSchemaRegistryAddr ¶
func (c *MetaServerClient) FetchSchemaRegistryAddr(ctx context.Context, req *pb.FetchSchemaRegistryAddrReq) (string, error)
func (*MetaServerClient) FetchSorterAddr ¶
func (c *MetaServerClient) FetchSorterAddr(ctx context.Context, req *pb.FetchRangeSorterAddrReq) (string, error)
type SchemaRegistryClient ¶
type SchemaRegistryClient struct {
// contains filtered or unexported fields
}
func NewSchemaRegistryClient ¶
func NewSchemaRegistryClient(addr string) (*SchemaRegistryClient, error)
func (*SchemaRegistryClient) Close ¶
func (c *SchemaRegistryClient) Close()
func (*SchemaRegistryClient) RefreshAddr ¶
func (c *SchemaRegistryClient) RefreshAddr(newAddr string) error
func (*SchemaRegistryClient) SendDDLChange ¶
func (c *SchemaRegistryClient) SendDDLChange(ctx context.Context, req *pb.RegisterDDLReq) (*pb.RegisterDDLResp, error)
func (*SchemaRegistryClient) SendSchemaSnap ¶
func (c *SchemaRegistryClient) SendSchemaSnap(ctx context.Context, req *pb.RegisterSchemaSnapReq) (*pb.RegisterSchemaSnapResp, error)
type SorterClient ¶
type SorterClient struct {
// contains filtered or unexported fields
}
Current implementation is one tenant one sorter simple model. Todo: 1) support multiple sorters for one tenant. 2) update the sorter address when the tenant scheduled to another sorter.
func NewSorterClient ¶
func NewSorterClient(addr string) (*SorterClient, error)
func (*SorterClient) Close ¶
func (s *SorterClient) Close()
func (*SorterClient) RefreshAddr ¶
func (s *SorterClient) RefreshAddr(newAddr string) error
func (*SorterClient) SendDataChanges ¶
func (s *SorterClient) SendDataChanges(ctx context.Context, req *pb.RangeChangesReq) (*pb.RangeChangesResp, error)
Source Files
Click to show internal directories.
Click to hide internal directories.