eventdispatch

Documentation

Index

• Variables
• type CloseShardRequest
• type CloseTableOnShardRequest
• type CreateTableOnShardRequest
• type Dispatch
• type DispatchImpl
  • func NewDispatchImpl() *DispatchImpl
  • func (d *DispatchImpl) CloseShard(ctx context.Context, addr string, request CloseShardRequest) error
  • func (d *DispatchImpl) CloseTableOnShard(ctx context.Context, addr string, request CloseTableOnShardRequest) error
  • func (d *DispatchImpl) CreateTableOnShard(ctx context.Context, addr string, request CreateTableOnShardRequest) error
  • func (d *DispatchImpl) DropTableOnShard(ctx context.Context, addr string, request DropTableOnShardRequest) error
  • func (d *DispatchImpl) OpenShard(ctx context.Context, addr string, request OpenShardRequest) error
  • func (d *DispatchImpl) OpenTableOnShard(ctx context.Context, addr string, request OpenTableOnShardRequest) error
• type DropTableOnShardRequest
• type OpenShardRequest
• type OpenTableOnShardRequest
• type UpdateShardInfo

Variables

var ErrDispatch = coderr.NewCodeError(coderr.Internal, "event dispatch failed")

Types

type CloseShardRequest

type CloseShardRequest struct {
	ShardID uint32
}

type CloseTableOnShardRequest

type CloseTableOnShardRequest struct {
	UpdateShardInfo UpdateShardInfo
	TableInfo       cluster.TableInfo
}

type CreateTableOnShardRequest

type CreateTableOnShardRequest struct {
	UpdateShardInfo  UpdateShardInfo
	TableInfo        cluster.TableInfo
	EncodedSchema    []byte
	Engine           string
	CreateIfNotExist bool
	Options          map[string]string
}

type Dispatch

type Dispatch interface {
	OpenShard(context context.Context, address string, request OpenShardRequest) error
	CloseShard(context context.Context, address string, request CloseShardRequest) error
	CreateTableOnShard(context context.Context, address string, request CreateTableOnShardRequest) error
	DropTableOnShard(context context.Context, address string, request DropTableOnShardRequest) error
	OpenTableOnShard(ctx context.Context, address string, request OpenTableOnShardRequest) error
	CloseTableOnShard(context context.Context, address string, request CloseTableOnShardRequest) error
}

type DispatchImpl

type DispatchImpl struct {
	// contains filtered or unexported fields
}

func NewDispatchImpl

func NewDispatchImpl() *DispatchImpl

func (*DispatchImpl) CloseShard

func (d *DispatchImpl) CloseShard(ctx context.Context, addr string, request CloseShardRequest) error

func (*DispatchImpl) CloseTableOnShard

func (d *DispatchImpl) CloseTableOnShard(ctx context.Context, addr string, request CloseTableOnShardRequest) error

func (*DispatchImpl) CreateTableOnShard

func (d *DispatchImpl) CreateTableOnShard(ctx context.Context, addr string, request CreateTableOnShardRequest) error

func (*DispatchImpl) DropTableOnShard

func (d *DispatchImpl) DropTableOnShard(ctx context.Context, addr string, request DropTableOnShardRequest) error

func (*DispatchImpl) OpenShard

func (d *DispatchImpl) OpenShard(ctx context.Context, addr string, request OpenShardRequest) error

func (*DispatchImpl) OpenTableOnShard

func (d *DispatchImpl) OpenTableOnShard(ctx context.Context, addr string, request OpenTableOnShardRequest) error

type DropTableOnShardRequest

type DropTableOnShardRequest struct {
	UpdateShardInfo UpdateShardInfo
	TableInfo       cluster.TableInfo
}

type OpenShardRequest

type OpenShardRequest struct {
	Shard cluster.ShardInfo
}

type OpenTableOnShardRequest

type OpenTableOnShardRequest struct {
	UpdateShardInfo UpdateShardInfo
	TableInfo       cluster.TableInfo
}

type UpdateShardInfo

type UpdateShardInfo struct {
	CurrShardInfo cluster.ShardInfo
	PrevVersion   uint64
}