document

Documentation

Index

• Constants
• func ExportDocumentHandler(httpServer *netutil.Server, client *client.Client, monitor monitoring.Monitor)
• func ExportRpcHandler(rpcServer *grpc.Server, client *client.Client, monitor monitoring.Monitor)
• type DocumentHandler
  • func (handler *DocumentHandler) ExportToServer() error
• type RawReqArgs
• type RawReqBody
• type RpcHandler
  • func (handler *RpcHandler) Search(ctx context.Context, req *pspb.RpcSearchRequest) (def *pspb.RpcSearchResponse, err error)

Constants

const (
	UrlQueryFrom            = "from"
	UrlQuerySize            = "size"
	UrlQueryRouting         = "routing"
	UrlQueryTypedKey        = "typed_keys"
	UrlQueryVersion         = "version"
	UrlQueryRetryOnConflict = "retry_on_conflict"
	UrlQueryOpType          = "op_type"
	UrlQueryRefresh         = "refresh"
	UrlQueryURISort         = "sort"
	UrlQueryTimeout         = "timeout"
)

const (
	UrlParamDbName    = "db_name"
	UrlParamSpaceName = "space_name"
	UrlParamDocID     = "doc_id"
)

Functions

func ExportDocumentHandler

func ExportDocumentHandler(httpServer *netutil.Server, client *client.Client, monitor monitoring.Monitor)

func ExportRpcHandler

func ExportRpcHandler(rpcServer *grpc.Server, client *client.Client, monitor monitoring.Monitor)

Types

type DocumentHandler

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

func (*DocumentHandler) ExportToServer

func (handler *DocumentHandler) ExportToServer() error

type RawReqArgs

type RawReqArgs map[string]string

type RawReqBody

type RawReqBody []byte

type RpcHandler

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

func (*RpcHandler) Search

func (handler *RpcHandler) Search(ctx context.Context, req *pspb.RpcSearchRequest) (def *pspb.RpcSearchResponse, err error)