client

Documentation

Index

• Constants
• func Print(out io.Writer, msg vtp.Message, group *sync.WaitGroup)
• func PrintEnv(out io.Writer, env *environment)
• type CmdClient
  • func NewCmdClient(bindTo string) *CmdClient
  • func (c *CmdClient) Repl(in io.Reader, out io.Writer)
• type Evaluator
• type Repl
• type Scanner
• type TCPClient
  • func NewTCPClient(config TCPClientConfig) *TCPClient
  • func (c *TCPClient) Alias(index, alias string, cb callback)
  • func (c *TCPClient) Drop(index string, cb callback)
  • func (c *TCPClient) Error(fn errorCallback)
  • func (c *TCPClient) Index(index, name, payload string, format entities.MimeType, cb callback)
  • func (c *TCPClient) Request(msg vtp.Message)
  • func (c *TCPClient) Responses() <-chan vtp.Message
  • func (c *TCPClient) Search(index, terms string, engine search.EngineType, cb callback)
  • func (c *TCPClient) ShowIndices(cb callback)
  • func (c *TCPClient) Start(ctx context.Context)
  • func (c *TCPClient) Stop()
  • func (c *TCPClient) UnAlias(index, alias string, cb callback)
• type TCPClientConfig

Constants

const (
	Version = 0
	Prompt  = "> "
)

Functions

func Print

func Print(out io.Writer, msg vtp.Message, group *sync.WaitGroup)

func PrintEnv

func PrintEnv(out io.Writer, env *environment)

Types

type CmdClient

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

func NewCmdClient

func NewCmdClient(bindTo string) *CmdClient

func (*CmdClient) Repl

func (c *CmdClient) Repl(in io.Reader, out io.Writer)

type Evaluator

type Evaluator interface {
	Eval(string) []vtp.Message
}

type Repl

type Repl interface {
	Repl(in io.Reader, out io.Writer)
}

type Scanner

type Scanner interface {
	Text() string
	Scan() bool
}

type TCPClient

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

func NewTCPClient

func NewTCPClient(config TCPClientConfig) *TCPClient

func (*TCPClient) Alias

func (c *TCPClient) Alias(index, alias string, cb callback)

func (*TCPClient) Drop

func (c *TCPClient) Drop(index string, cb callback)

func (*TCPClient) Error

func (c *TCPClient) Error(fn errorCallback)

func (*TCPClient) Index

func (c *TCPClient) Index(index, name, payload string, format entities.MimeType, cb callback)

func (*TCPClient) Request

func (c *TCPClient) Request(msg vtp.Message)

func (*TCPClient) Responses

func (c *TCPClient) Responses() <-chan vtp.Message

func (*TCPClient) Search

func (c *TCPClient) Search(index, terms string, engine search.EngineType, cb callback)

func (*TCPClient) ShowIndices

func (c *TCPClient) ShowIndices(cb callback)

func (*TCPClient) Start

func (c *TCPClient) Start(ctx context.Context)

func (*TCPClient) Stop

func (c *TCPClient) Stop()

func (*TCPClient) UnAlias

func (c *TCPClient) UnAlias(index, alias string, cb callback)

type TCPClientConfig

type TCPClientConfig struct {
	BindTo       string
	ReadPoolSize int
	ProxyStream  bool
}