hiveconnect

README

go-hive

Documentation

Index

• Constants
• type Connection
  • func ConnectZookeeper(hosts, auth string, configuration *ConnectionConfiguration) (conn *Connection, err error)
• type ConnectionConfiguration
  • func NewConnectionConfiguration() *ConnectionConfiguration
• type DialContextFunc
• type HiveError

Constants

const DEFAULT_FETCH_SIZE int64 = 1000

const DEFAULT_MAX_LENGTH = 16384000

const ZOOKEEPER_DEFAULT_NAMESPACE = "hiveserver2"

Types

type Connection

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

func ConnectZookeeper

func ConnectZookeeper(hosts, auth string,
	configuration *ConnectionConfiguration) (conn *Connection, err error)

type ConnectionConfiguration

type ConnectionConfiguration struct {
	Username           string
	Principal          string
	Password           string
	Service            string
	HiveConfiguration  map[string]string
	PollIntervalInMS   int
	FetchSize          int64
	TransportMode      string
	HTTPPath           string
	TLSConfig          *tls.Config
	ZookeeperNamespace string
	Database           string
	ConnectTimeout     time.Duration
	SocketTimeout      time.Duration
	HttpTimeout        time.Duration
	DialContext        DialContextFunc
	DisableKeepAlives  bool
	MaxSize            uint32
}

func NewConnectionConfiguration

func NewConnectionConfiguration() *ConnectionConfiguration

type DialContextFunc

type DialContextFunc func(ctx context.Context, network, addr string) (net.Conn, error)

type HiveError

type HiveError struct {
	Message   string
	ErrorCode int
	// contains filtered or unexported fields
}