nebuladrv

Documentation

Index

• Variables
• func CheckResultSet(rs *nebula.ResultSet, err error) error
• func NebulaConnPoolCreator(addresses []nebula.HostAddress, conf nebula.PoolConfig) func(logger xlog.Logger) (*nebula.ConnectionPool, error)
• func NewNebulaConnection(opts ...ConnectionOpt) *nebulaConnection
• func NewNebulaResultSet(rs *nebula.ResultSet) *nebulaResultSet
• func NewNebulaSession(sess *nebula.Session) *nebulaSession
• type ConnectionOpt

Variables

var ConnOpts connOpts

Functions

func CheckResultSet

func CheckResultSet(rs *nebula.ResultSet, err error) error

func NebulaConnPoolCreator

func NebulaConnPoolCreator(addresses []nebula.HostAddress, conf nebula.PoolConfig) func(logger xlog.Logger) (*nebula.ConnectionPool, error)

func NewNebulaConnection

func NewNebulaConnection(opts ...ConnectionOpt) *nebulaConnection

func NewNebulaResultSet

func NewNebulaResultSet(rs *nebula.ResultSet) *nebulaResultSet

func NewNebulaSession

func NewNebulaSession(sess *nebula.Session) *nebulaSession

Types

type ConnectionOpt

type ConnectionOpt func(*nebulaConnection)