client

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)
  • func (client *Client) Master() *masterClient
  • func (client *Client) PS() *psClient
  • func (client *Client) Stop()
• type ClientType
• type MasterServer

Constants

const (
	//doc handler
	SearchHandler        = "SearchHandler"
	DeleteByQueryHandler = "DeleteByQueryHandler"
	MSearchHandler       = "MSearchHandler"
	StreamSearchHandler  = "StreamSearchHandler"
	GetDocHandler        = "GetDocHandler"
	GetDocsHandler       = "GetDocsHandler"
	WriteHandler         = "WriteHandler"
	BatchHandler         = "BatchHandler"
	FlushHandler         = "FlushHandler"
	ForceMergeHandler    = "ForceMergeHandler"

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

const Authorization = "Authorization"

const Root = "root"

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
	RANDOM
	ALL
)

type MasterServer

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