List of func on Conn struct for go-zookeeper

conn.go

func (c *Conn) Close() {
func (c *Conn) State() State {
func (c *Conn) SessionID() int64 {
func (c *Conn) SetLogger(l Logger) {
func (c *Conn) setTimeouts(sessionTimeoutMs int32) {
func (c *Conn) setState(state State) {
func (c *Conn) connect() error {
func (c *Conn) loop() {
func (c *Conn) flushUnsentRequests(err error) {
func (c *Conn) flushRequests(err error) {
func (c *Conn) invalidateWatches(err error) {
func (c *Conn) sendSetWatches() {
func (c *Conn) authenticate() error {
func (c *Conn) sendLoop(conn net.Conn, closeChan <-chan struct{}) error {
func (c *Conn) recvLoop(conn net.Conn) error {
func (c *Conn) nextXid() int32 {
func (c *Conn) addWatcher(path string, watchType WatchType) <-chan Event {
func (c *Conn) queueRequest(opcode int32, req interface{}, res interface{}, recvFunc func(*request, *responseHeader, error)) <-chan response {
func (c *Conn) request(opcode int32, req interface{}, res interface{}, recvFunc func(*request, *responseHeader, error)) (int64, error) {
func (c *Conn) AddAuth(scheme string, auth []byte) error {
func (c *Conn) Children(path string) ([]string, *Stat, error) {
func (c *Conn) ChildrenW(path string) ([]string, *Stat, <-chan Event, error) {
func (c *Conn) Get(path string) ([]byte, *Stat, error) {
func (c *Conn) GetW(path string) ([]byte, *Stat, <-chan Event, error) {
func (c *Conn) Set(path string, data []byte, version int32) (*Stat, error) {
func (c *Conn) Create(path string, data []byte, flags int32, acl []ACL) (string, error) {
func (c *Conn) CreateProtectedEphemeralSequential(path string, data []byte, acl []ACL) (string, error) {
func (c *Conn) Delete(path string, version int32) error {
func (c *Conn) Exists(path string) (bool, *Stat, error) {
func (c *Conn) ExistsW(path string) (bool, *Stat, <-chan Event, error) {
func (c *Conn) GetACL(path string) ([]ACL, *Stat, error) {
func (c *Conn) SetACL(path string, acl []ACL, version int32) (*Stat, error) {
func (c *Conn) Sync(path string) (string, error) {
func (c *Conn) Multi(ops ...interface{}) ([]MultiResponse, error) {
func (c *Conn) Server() string {