zk

type ACL struct {
	Perms  int32
	Scheme string
	ID     string
}

type AddAuthResponse struct {
	Zxid int64
}

type CheckVersionRequest PathVersionRequest

type ChildrenOption func(opts *childrenOpts)

type ChildrenResponse struct {
	Zxid     int64
	Children []string
}

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

type CreateContainerRequest CreateRequest

type CreateRequest struct {
	Path  string
	Data  []byte
	Acl   []ACL
	Flags int32
}

type CreateResponse struct {
	Zxid int64
	Path string
}

type CreateTTLRequest struct {
	Path  string
	Data  []byte
	Acl   []ACL
	Flags int32
	Ttl   int64 // ms
}

type DeleteRequest PathVersionRequest

type DeleteResponse struct {
	Zxid int64
}

type ErrCode int32

type Event struct {
	Type  EventType
	State State
	Path  string // For non-session events, the path of the watched node.
}

type EventType int32

type ExistsOption func(opts *existsOpts)

type ExistsResponse struct {
	Zxid int64
	Stat Stat
}

type GetACLResponse struct {
	Zxid int64
	ACL  []ACL
	Stat Stat
}

type GetOption func(opts *getOpts)

type GetResponse struct {
	Zxid int64
	Data []byte
	Stat Stat
}

type Logger interface {
	Infof(format string, args ...any)
	Warnf(format string, args ...any)
	Errorf(format string, args ...any)
}

type Mode uint8

type NetworkConn interface {
	io.Reader
	io.Writer
	io.Closer

	// SetReadDeadline sets the deadline for future Read calls
	// and any currently-blocked Read call.
	// A zero value for t means Read will not time out.
	SetReadDeadline(d time.Duration) error

	// SetWriteDeadline sets the deadline for future Write calls
	// and any currently-blocked Write call.
	// Even if write times out, it may return n > 0, indicating that
	// some of the data was successfully written.
	// A zero value for t means Write will not time out.
	SetWriteDeadline(d time.Duration) error
}

type Option func(c *Client)

type PathVersionRequest struct {
	Path    string
	Version int32
}

type SelectNextOutput struct {
	Server     string
	RetryStart bool
}

type ServerClient struct {
	Queued        int64
	Received      int64
	Sent          int64
	SessionID     int64
	Lcxid         int64
	Lzxid         int64
	Timeout       int32
	LastLatency   int32
	MinLatency    int32
	AvgLatency    int32
	MaxLatency    int32
	Established   time.Time
	LastResponse  time.Time
	Addr          string
	LastOperation string // maybe?
	Error         error
}

type ServerClients struct {
	Clients []*ServerClient
	Error   error
}

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

type ServerSelector interface {
	Init(servers []string)
	Next() SelectNextOutput
	NotifyConnected()
}

type ServerStats struct {
	Server      string
	Sent        int64
	Received    int64
	NodeCount   int64
	MinLatency  int64
	AvgLatency  float64
	MaxLatency  int64
	Connections int64
	Outstanding int64
	Epoch       int32
	Counter     int32
	BuildTime   time.Time
	Mode        Mode
	Version     string
	Error       error
}

type SetACLResponse struct {
	Zxid int64
	Stat Stat
}

type SetDataRequest struct {
	Path    string
	Data    []byte
	Version int32
}

type SetResponse struct {
	Zxid int64
	Stat Stat
}

type Stat struct {
	Czxid          int64 // The zxid of the change that caused this znode to be created.
	Mzxid          int64 // The zxid of the change that last modified this znode.
	Ctime          int64 // The time in milliseconds from epoch when this znode was created.
	Mtime          int64 // The time in milliseconds from epoch when this znode was last modified.
	Version        int32 // The number of changes to the data of this znode.
	Cversion       int32 // The number of changes to the children of this znode.
	Aversion       int32 // The number of changes to the ACL of this znode.
	EphemeralOwner int64 // The session id of the owner of this znode if the znode is an ephemeral node. If it is not an ephemeral node, it will be zero.
	DataLength     int32 // The length of the data field of this znode.
	NumChildren    int32 // The number of children of this znode.
	Pzxid          int64 // last modified children
}

type State int32