connector

Documentation

Index

• Constants
• type Conn
  • func Connect(connString string, opts Opts) (*Conn, error)
  • func (conn *Conn) Close() error
  • func (conn *Conn) Exec(req *Request) ([]interface{}, error)
  • func (conn *Conn) ExecTyped(req *Request, resData interface{}) error
• type ConnOpts
• type EvalPlainTextOpts
• type ExecOpts
• type Opts
• type PlainTextEvalRes
• type Protocol
• type Request
  • func CallReq(funcName string, args ...interface{}) *Request
  • func EvalReq(funcBody string, args ...interface{}) *Request
  • func (req *Request) SetPushCallback(pushCallback func(interface{})) *Request
  • func (req *Request) SetReadTimeout(readTimeout time.Duration) *Request

Constants

const (
	TCPNetwork  = "tcp"
	UnixNetwork = "unix"
)

Types

type Conn

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

func Connect

func Connect(connString string, opts Opts) (*Conn, error)

func (*Conn) Close

func (conn *Conn) Close() error

func (*Conn) Exec

func (conn *Conn) Exec(req *Request) ([]interface{}, error)

func (*Conn) ExecTyped

func (conn *Conn) ExecTyped(req *Request, resData interface{}) error

type ConnOpts

type ConnOpts struct {
	Network  string
	Address  string
	Username string
	Password string
}

type EvalPlainTextOpts

type EvalPlainTextOpts struct {
	ReadTimeout  time.Duration
	PushCallback func(interface{})
	ResData      interface{}
}

type ExecOpts

type ExecOpts struct {
	PushCallback func(interface{})
	ReadTimeout  time.Duration
	ResData      interface{}
}

type Opts

type Opts struct {
	Username string
	Password string
}

type PlainTextEvalRes

type PlainTextEvalRes struct {
	DataEncBase64 string `yaml:"data_enc"`
}

type Protocol

type Protocol string

const (
	PlainTextProtocol Protocol = "plain text"
	BinaryProtocol    Protocol = "binary"

	SimpleOperationTimeout = 3 * time.Second
)

type Request

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

func CallReq

func CallReq(funcName string, args ...interface{}) *Request

func EvalReq

func EvalReq(funcBody string, args ...interface{}) *Request

func (*Request) SetPushCallback

func (req *Request) SetPushCallback(pushCallback func(interface{})) *Request

func (*Request) SetReadTimeout

func (req *Request) SetReadTimeout(readTimeout time.Duration) *Request