client

Documentation

Index

• type DispatcherClient
  • func NewDispatcherClient(addr string) (*DispatcherClient, error)
  • func (c *DispatcherClient) Close()
  • func (c *DispatcherClient) NotifyTenantHasUpdate(ctx context.Context, req *pb.HasNewChangeReq) error
  • func (c *DispatcherClient) ScheduleNewTenant(ctx context.Context, req *pb.TenantTasksReq) error
• type MetaServerClient
  • func NewMetaServerClient(addrs []string) (*MetaServerClient, error)
  • func (c *MetaServerClient) Close()
  • func (c *MetaServerClient) FetchSchemaRegistryAddr(ctx context.Context, req *pb.FetchSchemaRegistryAddrReq) (string, error)
  • func (c *MetaServerClient) FetchSorterAddr(ctx context.Context, req *pb.FetchRangeSorterAddrReq) (string, error)
• type SchemaRegistryClient
  • func NewSchemaRegistryClient(addr string) (*SchemaRegistryClient, error)
  • 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
  • func NewSorterClient(addr string) (*SorterClient, error)
  • func (s *SorterClient) Close()
  • func (s *SorterClient) RefreshAddr(newAddr string) error
  • func (s *SorterClient) SendDataChanges(ctx context.Context, req *pb.RangeChangesReq) (*pb.RangeChangesResp, error)

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)