client

Documentation

Index

• Constants
• func AddMerge(sr *vearchpb.SearchResult, other *vearchpb.SearchResult) (err error)
• func AddMergeResultArr(dest []*vearchpb.SearchResult, src []*vearchpb.SearchResult) error
• func BulkMergeArrForField(dest []*vearchpb.SearchResult, src []*vearchpb.SearchResult, ...) error
• func ChangeMember(addr string, changeMember *entity.ChangeMember) error
• func Compare(old float64, new float64) int
• func CreatePartition(addr string, space *entity.Space, pid uint32) error
• func DeletePartition(addr string, pid uint32) error
• func DeleteReplica(addr string, partitionId uint32) error
• func Execute(addr, servicePath string, args *vearchpb.PartitionData, ...) (err error)
• func GetEngineCfg(addr string, pid entity.PartitionID) (cfg *entity.EngineCfg, err error)
• func GetMD5Encode(data string) string
• func GetNodeIdsByClientType(clientType string, partition *entity.Partition, servers *cache.Cache) entity.NodeID
• func GetSource(doc *vearchpb.ResultItem, space *entity.Space, idIsLong bool, ...) (json.RawMessage, []sortorder.SortValue, string, error)
• func HitsMergeForField(dh []*vearchpb.ResultItem, firstSortValue map[string][]sortorder.SortValue, ...) []*vearchpb.ResultItem
• func IsLive(addr string) bool
• func Merge(ss *vearchpb.SearchStatus, other *vearchpb.SearchStatus)
• func MergeArrForField(dest []*vearchpb.SearchResult, src []*vearchpb.SearchResult, ...) error
• func MergeForField(old *vearchpb.SearchResult, other *vearchpb.SearchResult, ...) (err error)
• func NewRouterRequest(ctx context.Context, client *Client) *routerRequest
• func NewWatchServerCache(serverCtx context.Context, cli *Client) error
• func PartitionInfo(addr string, pid entity.PartitionID) (value *entity.PartitionInfo, err error)
• func PartitionInfos(addr string) (value []*entity.PartitionInfo, err error)
• func SearchStatusMerge(old *vearchpb.SearchStatus, other *vearchpb.SearchStatus) *vearchpb.SearchStatus
• func ServerStats(addr string) *mserver.ServerStats
• func UpdateEngineCfg(addr string, cacheCfg *entity.EngineCfg, pid entity.PartitionID) error
• func UpdatePartition(addr string, space *entity.Space, pid entity.PartitionID) error
• type Client
  • func NewClient(conf *config.Config) (client *Client, err error)
  • func (client *Client) Master() *masterClient
  • func (client *Client) PS() *psClient
  • func (client *Client) Space(ctx context.Context, dbName, spaceName string) (*entity.Space, error)
  • func (client *Client) Stop()
• type ClientType
• type MasterServer

Constants

const (
	HandlerType  = "type"
	UnaryHandler = "UnaryHandler"

	SearchHandler        = "SearchHandler"
	BulkSearchHandler    = "BulkSearchHandler"
	DeleteByQueryHandler = "DeleteByQueryHandler"
	MSearchHandler       = "MSearchHandler"
	MSearchIDsHandler    = "MSearchIDsHandler"
	MSearchForIDsHandler = "MSearchForIDsHandler"
	MSearchNewHandler    = "MSearchNewHandler"
	StreamSearchHandler  = "StreamSearchHandler"

	GetDocHandler     = "GetDocHandler"
	GetDocsHandler    = "GetDocsHandler"
	CreateDocHandler  = "CreateDocHandler"
	DeleteDocsHandler = "DeleteDocsHandler"
	ReplaceDocHandler = "ReplaceDocHandler"
	BatchHandler      = "BatchHandler"
	ForceMergeHandler = "ForceMergeHandler"
	FlushHandler      = "FlushHandler"

	CreatePartitionHandler = "CreatePartitionHandler"
	DeletePartitionHandler = "DeletePartitionHandler"
	DeleteReplicaHandler   = "DeleteReplicaHandler"
	UpdatePartitionHandler = "UpdatePartitionHandler"
	StatsHandler           = "StatsHandler"
	IsLiveHandler          = "IsLiveHandler"
	PartitionInfoHandler   = "PartitionInfoHandler"
	ChangeMemberHandler    = "ChangeMemberHandler"
	EngineCfgHandler       = "EngineCfgHandler"
)

const Authorization = "Authorization"

Authorization default Authorization

const (
	DefaultPsTimeOut = 5
)

const (
	// MessageID the key of message
	MessageID = "message_id"
)

const Root = "root"

Root default root

Functions

func AddMerge

func AddMerge(sr *vearchpb.SearchResult, other *vearchpb.SearchResult) (err error)

func AddMergeResultArr

func AddMergeResultArr(dest []*vearchpb.SearchResult, src []*vearchpb.SearchResult) error

func BulkMergeArrForField

func BulkMergeArrForField(dest []*vearchpb.SearchResult, src []*vearchpb.SearchResult, firstSortValue map[string][]sortorder.SortValue, soArr []sortorder.SortOrder, sizes []int32) error

func ChangeMember

func ChangeMember(addr string, changeMember *entity.ChangeMember) error

func Compare

func Compare(old float64, new float64) int

func CreatePartition

func CreatePartition(addr string, space *entity.Space, pid uint32) error

func DeletePartition

func DeletePartition(addr string, pid uint32) error

func DeleteReplica

func DeleteReplica(addr string, partitionId uint32) error

func Execute

func Execute(addr, servicePath string, args *vearchpb.PartitionData, reply *vearchpb.PartitionData) (err error)

Execute add retry to handle no leader and not leader situation

func GetEngineCfg

func GetEngineCfg(addr string, pid entity.PartitionID) (cfg *entity.EngineCfg, err error)

func GetMD5Encode

func GetMD5Encode(data string) string

GetMD5Encode return md5 value of given data

func GetNodeIdsByClientType

func GetNodeIdsByClientType(clientType string, partition *entity.Partition, servers *cache.Cache) entity.NodeID

func GetSource

func GetSource(doc *vearchpb.ResultItem, space *entity.Space, idIsLong bool, sortFieldMap map[string]string, sortFields []*vearchpb.SortField) (json.RawMessage, []sortorder.SortValue, string, error)

func HitsMergeForField

func HitsMergeForField(dh []*vearchpb.ResultItem, firstSortValue map[string][]sortorder.SortValue, spid, fpid uint32, sh []*vearchpb.ResultItem, sortOrder sortorder.SortOrder, from, size int32) []*vearchpb.ResultItem

func IsLive

func IsLive(addr string) bool

func Merge

func Merge(ss *vearchpb.SearchStatus, other *vearchpb.SearchStatus)

func MergeArrForField

func MergeArrForField(dest []*vearchpb.SearchResult, src []*vearchpb.SearchResult, firstSortValue map[string][]sortorder.SortValue, so sortorder.SortOrder, size int32) error

func MergeForField

func MergeForField(old *vearchpb.SearchResult, other *vearchpb.SearchResult, firstSortValue map[string][]sortorder.SortValue, sortOrder sortorder.SortOrder, from, size int32) (err error)

func NewRouterRequest

func NewRouterRequest(ctx context.Context, client *Client) *routerRequest

NewRouterRequest create a new request for router

func NewWatchServerCache

func NewWatchServerCache(serverCtx context.Context, cli *Client) error

NewWatchServerCache watch ps server put and delete status

func PartitionInfo

func PartitionInfo(addr string, pid entity.PartitionID) (value *entity.PartitionInfo, err error)

PartitionInfo get partition info about partitionID

func PartitionInfos

func PartitionInfos(addr string) (value []*entity.PartitionInfo, err error)

PartitionInfos get all partition info from server

func SearchStatusMerge

func SearchStatusMerge(old *vearchpb.SearchStatus, other *vearchpb.SearchStatus) *vearchpb.SearchStatus

func ServerStats

func ServerStats(addr string) *mserver.ServerStats

func UpdateEngineCfg

func UpdateEngineCfg(addr string, cacheCfg *entity.EngineCfg, pid entity.PartitionID) error

func UpdatePartition

func UpdatePartition(addr string, space *entity.Space, pid entity.PartitionID) error

Types

type Client

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

Client include client of master and ps

func NewClient

func NewClient(conf *config.Config) (client *Client, err error)

NewClient create a new client by config

func (*Client) Master

func (client *Client) Master() *masterClient

Master return master client

func (*Client) PS

func (client *Client) PS() *psClient

PS return ps client

func (*Client) Space

func (client *Client) Space(ctx context.Context, dbName, spaceName string) (*entity.Space, error)

Space return space by dbname and space name

func (*Client) Stop

func (client *Client) Stop()

Stop stop client

type ClientType

type ClientType int

ClientType decide the method to choose raft

const (
	LEADER ClientType = iota
	NOTLEADER
	RANDOM
	ALL
)

type MasterServer

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

MasterServer the num of master