client

package

v0.3.0 Latest Latest Go to latest Published: Apr 21, 2020 License: Apache-2.0, MIT Imports: 39 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/jd-opensource/vearch

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Execute(addr, servicePath string, request request.Request) (interface{}, int64, error)
func Slot(routingValue string) uint32
type Client
- func NewClient(conf *config.Config) (client *Client, err error)
type ClientType
type MasterServer

Constants ¶

View Source

const (
	//doc handler
	SearchHandler        = "SearchHandler"
	DeleteByQueryHandler = "DeleteByQueryHandler"
	MSearchHandler       = "MSearchHandler"
	MSearchIDsHandler    = "MSearchIDsHandler"

	StreamSearchHandler = "StreamSearchHandler"
	GetDocHandler       = "GetDocHandler"
	GetDocsHandler      = "GetDocsHandler"
	WriteHandler        = "WriteHandler"
	BatchHandler        = "BatchHandler"
	FlushHandler        = "FlushHandler"
	ForceMergeHandler   = "ForceMergeHandler"

	//admin handler
	CreatePartitionHandler = "CreatePartitionHandler"
	DeletePartitionHandler = "DeletePartitionHandler"
	DeleteReplicaHandler   = "DeleteReplicaHandler"
	UpdatePartitionHandler = "UpdatePartitionHandler"
	StatsHandler           = "StatsHandler"
	IsLiveHandler          = "IsLiveHandler"
	PartitionInfoHandler   = "PartitionInfoHandler"
	ChangeMemberHandler    = "ChangeMemberHandler"
)

View Source

const Authorization = "Authorization"

View Source

const Root = "root"

Variables ¶

This section is empty.

Functions ¶

func Execute ¶

func Execute(addr, servicePath string, request request.Request) (interface{}, int64, error)

ExecuteErrorChangeRetry add retry to handle no leader and not leader situation

func Slot ¶

func Slot(routingValue string) uint32

Types ¶

type Client ¶

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

func NewClient ¶

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

func (*Client) Master ¶

func (client *Client) Master() *masterClient

func (*Client) PS ¶

func (client *Client) PS() *psClient

func (*Client) Stop ¶

func (client *Client) Stop()

type ClientType ¶

type ClientType int

const (
	LEADER ClientType = iota
	NOT_LEADER
	RANDOM
	ALL
)

type MasterServer ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL