handler

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AbortProcessor 

type AbortProcessor struct {
}

func NewAbortProcessor 

func NewAbortProcessor() *AbortProcessor

func (*AbortProcessor) Handle 

func (p *AbortProcessor) Handle(w spdy.Responser, data interface{}) error

type BaseHandler 

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

func (*BaseHandler) Abort 

func (h *BaseHandler) Abort()

func (*BaseHandler) SetMessage 

func (h *BaseHandler) SetMessage(msg codec.BinaryCodec) error

func (*BaseHandler) SetStore 

func (h *BaseHandler) SetStore(store *storage.Storage)

type ContextKey 

type ContextKey string
const (
	QueryDurationKey ContextKey = "QueryDuration"
)

type CreateDataBase 

type CreateDataBase struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*CreateDataBase) Process 

func (h *CreateDataBase) Process() (codec.BinaryCodec, error)

func (*CreateDataBase) SetMessage 

func (h *CreateDataBase) SetMessage(msg codec.BinaryCodec) error

type DDLProcessor 

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

func NewDDLProcessor 

func NewDDLProcessor(store *storage.Storage) *DDLProcessor

func (*DDLProcessor) Handle 

func (p *DDLProcessor) Handle(w spdy.Responser, data interface{}) error

type Delete 

type Delete struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*Delete) Process 

func (h *Delete) Process() (codec.BinaryCodec, error)

func (*Delete) SetMessage 

func (h *Delete) SetMessage(msg codec.BinaryCodec) error

type GetShardSplitPoints 

type GetShardSplitPoints struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*GetShardSplitPoints) Process 

func (h *GetShardSplitPoints) Process() (codec.BinaryCodec, error)

func (*GetShardSplitPoints) SetMessage 

func (h *GetShardSplitPoints) SetMessage(msg codec.BinaryCodec) error

type KillQuery added in v1.1.0 

type KillQuery struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*KillQuery) Process added in v1.1.0 

func (h *KillQuery) Process() (codec.BinaryCodec, error)

func (*KillQuery) SetMessage added in v1.1.0 

func (h *KillQuery) SetMessage(msg codec.BinaryCodec) error

type MigrationProcessor added in v1.0.0 

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

func NewPtProcessor added in v1.0.0 

func NewPtProcessor(store *storage.Storage) *MigrationProcessor

func (*MigrationProcessor) Handle added in v1.0.0 

func (mp *MigrationProcessor) Handle(w spdy.Responser, data interface{}) error

type RPCHandler 

type RPCHandler interface {
	SetMessage(binaryCodec codec.BinaryCodec) error
	SetStore(*storage.Storage)
	Process() (codec.BinaryCodec, error)
}

type SegregateProcessor added in v1.1.1 

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

func NewSegregateNodeProcessor added in v1.1.1 

func NewSegregateNodeProcessor(store *storage.Storage) *SegregateProcessor

func (*SegregateProcessor) Handle added in v1.1.1 

func (mp *SegregateProcessor) Handle(w spdy.Responser, data interface{}) error

type Select 

type Select struct {
	BaseHandler
	// contains filtered or unexported fields
}

func NewSelect 

func NewSelect(store *storage.Storage, w spdy.Responser, req *executor.RemoteQuery) *Select

func (*Select) Abort 

func (s *Select) Abort()

func (*Select) Crash added in v1.2.0 

func (s *Select) Crash()

func (*Select) GetQueryExeInfo added in v1.1.0 

func (s *Select) GetQueryExeInfo() *netstorage.QueryExeInfo

GetQueryExeInfo return the unchanging information in a query

func (*Select) NewExecutorBuilder added in v1.2.0 

func (s *Select) NewExecutorBuilder(w spdy.Responser, req *executor.RemoteQuery, ctx context.Context, parallelism int) *executor.ExecutorBuilder

func (*Select) NewPtQuerysTraits added in v1.2.0 

func (s *Select) NewPtQuerysTraits(req *executor.RemoteQuery, w spdy.Responser) *executor.CsStoreExchangeTraits

func (*Select) NewShardTraits 

func (s *Select) NewShardTraits(req *executor.RemoteQuery, w spdy.Responser) *executor.StoreExchangeTraits

func (*Select) Process 

func (s *Select) Process() error

func (*Select) SetAbortHook added in v1.1.0 

func (s *Select) SetAbortHook(hook func()) bool

func (*Select) SetCrashHook added in v1.2.0 

func (s *Select) SetCrashHook(hook func()) bool

type SelectProcessor 

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

func NewSelectProcessor 

func NewSelectProcessor(store *storage.Storage) *SelectProcessor

func (*SelectProcessor) Handle 

func (p *SelectProcessor) Handle(w spdy.Responser, data interface{}) error

func (*SelectProcessor) HandleIncQuery added in v1.2.0 

func (p *SelectProcessor) HandleIncQuery(w spdy.Responser, req *executor.RemoteQuery, getFailed bool, iterMaxNum int32, rowCount int64) error

type SeriesCardinality 

type SeriesCardinality struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*SeriesCardinality) Process 

func (h *SeriesCardinality) Process() (codec.BinaryCodec, error)

func (*SeriesCardinality) SetMessage 

func (h *SeriesCardinality) SetMessage(msg codec.BinaryCodec) error

type SeriesExactCardinality 

type SeriesExactCardinality struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*SeriesExactCardinality) Process 

func (h *SeriesExactCardinality) Process() (codec.BinaryCodec, error)

func (*SeriesExactCardinality) SetMessage 

func (h *SeriesExactCardinality) SetMessage(msg codec.BinaryCodec) error

type SeriesKeys 

type SeriesKeys struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*SeriesKeys) Process 

func (h *SeriesKeys) Process() (codec.BinaryCodec, error)

func (*SeriesKeys) SetMessage 

func (h *SeriesKeys) SetMessage(msg codec.BinaryCodec) error

type ShowQueries added in v1.1.0 

type ShowQueries struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*ShowQueries) Process added in v1.1.0 

func (h *ShowQueries) Process() (codec.BinaryCodec, error)

func (*ShowQueries) SetMessage added in v1.1.0 

func (h *ShowQueries) SetMessage(msg codec.BinaryCodec) error

type ShowTagKeys added in v1.2.0 

type ShowTagKeys struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*ShowTagKeys) Process added in v1.2.0 

func (h *ShowTagKeys) Process() (codec.BinaryCodec, error)

func (*ShowTagKeys) SetMessage added in v1.2.0 

func (h *ShowTagKeys) SetMessage(msg codec.BinaryCodec) error

type ShowTagValues 

type ShowTagValues struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*ShowTagValues) Process 

func (h *ShowTagValues) Process() (codec.BinaryCodec, error)

func (*ShowTagValues) SetMessage 

func (h *ShowTagValues) SetMessage(msg codec.BinaryCodec) error

type ShowTagValuesCardinality 

type ShowTagValuesCardinality struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*ShowTagValuesCardinality) Process 

func (h *ShowTagValuesCardinality) Process() (codec.BinaryCodec, error)

func (*ShowTagValuesCardinality) SetMessage 

func (h *ShowTagValuesCardinality) SetMessage(msg codec.BinaryCodec) error

type SysCtrlCmd 

type SysCtrlCmd struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*SysCtrlCmd) Process 

func (h *SysCtrlCmd) Process() error

type SysProcessor 

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

func NewSysProcessor 

func NewSysProcessor(store *storage.Storage) *SysProcessor

func (*SysProcessor) Handle 

func (p *SysProcessor) Handle(w spdy.Responser, data interface{}) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.