Documentation
¶
Index ¶
- type HighlightRequest
- type ObjRequest
- func (req *ObjRequest) Clone(pid entity.PartitionID) Request
- func (req *ObjRequest) CloneValue(pid entity.PartitionID, value interface{}) (Request, error)
- func (req *ObjRequest) Context() *RequestContext
- func (req *ObjRequest) Decode(i interface{}) error
- func (req *ObjRequest) GetPartitionID() uint32
- func (req *ObjRequest) SetPartitionID(pid entity.PartitionID)
- type Request
- type RequestContext
- func (request *RequestContext) AddCannelFunc(cannel func())
- func (request *RequestContext) Cannel()
- func (request *RequestContext) GetContext() context.Context
- func (request *RequestContext) GetStore() interface{}
- func (request *RequestContext) SetContext(ctx context.Context)
- func (request *RequestContext) SetStore(store interface{})
- type SearchDocumentRequest
- type SearchRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HighlightRequest ¶
type HighlightRequest struct {
PreTags []string `json:"pre_tags,omitempty"`
PostTags []string `json:"post_tags,omitempty"`
Fields map[string]interface{} `json:"fields,omitempty"`
RequireFieldMatch bool `json:"require_field_match,omitempty"`
FragmentSize int `json:"fragment_size,omitempty"`
NumberOfFragments int `json:"number_of_fragments,omitempty"`
}
type ObjRequest ¶
type ObjRequest struct {
*RequestContext
PartitionID entity.PartitionID `json:"partition,omitempty"`
Value []byte `json:"value,omitempty"`
}
func NewObjRequest ¶
func NewObjRequest(reqCtx *RequestContext, pid entity.PartitionID, value interface{}) (*ObjRequest, error)
func (*ObjRequest) Clone ¶
func (req *ObjRequest) Clone(pid entity.PartitionID) Request
func (*ObjRequest) CloneValue ¶
func (req *ObjRequest) CloneValue(pid entity.PartitionID, value interface{}) (Request, error)
func (*ObjRequest) Context ¶
func (req *ObjRequest) Context() *RequestContext
func (*ObjRequest) Decode ¶
func (req *ObjRequest) Decode(i interface{}) error
this function will decoding or encoding value
func (*ObjRequest) GetPartitionID ¶
func (req *ObjRequest) GetPartitionID() uint32
func (*ObjRequest) SetPartitionID ¶
func (req *ObjRequest) SetPartitionID(pid entity.PartitionID)
type Request ¶
type Request interface {
Context() *RequestContext
SetContext(ctx context.Context)
GetPartitionID() entity.PartitionID
SetPartitionID(entity.PartitionID)
}
type RequestContext ¶
type RequestContext struct {
MessageId string `json:"message_id,omitempty"`
Timeout int64 `json:"timeout,omitempty"`
PartitionNum int `json:"partition_num,omitempty"`
RouterAddr string `json:"router_addr,omitempty"`
Leader bool `json:"leader,omitempty"`
// contains filtered or unexported fields
}
it use base struct must first field in structs
func (*RequestContext) AddCannelFunc ¶
func (request *RequestContext) AddCannelFunc(cannel func())
func (*RequestContext) Cannel ¶
func (request *RequestContext) Cannel()
func (*RequestContext) GetContext ¶
func (request *RequestContext) GetContext() context.Context
func (*RequestContext) GetStore ¶
func (request *RequestContext) GetStore() interface{}
func (*RequestContext) SetContext ¶
func (request *RequestContext) SetContext(ctx context.Context)
func (*RequestContext) SetStore ¶
func (request *RequestContext) SetStore(store interface{})
type SearchDocumentRequest ¶
type SearchDocumentRequest struct {
From int `json:"from,omitempty"`
Size *int `json:"size,omitempty"`
Fields []string `json:"fields,omitempty"`
Query json.RawMessage `json:"query,omitempty"`
MinScore float64 `json:"min_score,omitempty"`
Sort json.RawMessage `json:"sort,omitempty"`
Explain bool `json:"explain,omitempty"`
Quick bool `json:"quick,omitempty"`
VectorValue bool `json:"vector_value,omitempty"`
Parallel bool `json:"parallel,omitempty"`
// contains filtered or unexported fields
}
type SearchRequest ¶
type SearchRequest struct {
*RequestContext
*SearchDocumentRequest
PartitionID entity.PartitionID `json:"partition,omitempty"`
}
func NewSearchRequest ¶
func NewSearchRequest(ctx context.Context, msgId string) *SearchRequest
func (*SearchRequest) Clone ¶
func (req *SearchRequest) Clone(pid entity.PartitionID, db, space string) *SearchRequest
func (*SearchRequest) Context ¶
func (req *SearchRequest) Context() *RequestContext
func (*SearchRequest) GetPartitionID ¶
func (req *SearchRequest) GetPartitionID() uint32
func (*SearchRequest) SetPartitionID ¶
func (req *SearchRequest) SetPartitionID(pid entity.PartitionID)
Click to show internal directories.
Click to hide internal directories.