zetcd

package module

Go to main page

Versions in this module

v0

v0.0.5

May 22, 2018

v0.0.4

Aug 8, 2017

v0.0.3

Jul 5, 2017

Changes in this version

+ type WatchHandler func(ZXid, EventType)

v0.0.2

Jun 1, 2017

Changes in this version

+ var ErrBadArguments = errors.New("zk: bad arguments")

type MultiResponse

+ func (r *MultiResponse) Encode(buf []byte) (int, error)

v0.0.1

May 9, 2017

Changes in this version

+ const DefaultPort

+ const FlagEphemeral

+ const FlagSequence

+ const StateAuthFailed

+ const StateConnected

+ const StateConnectedReadOnly

+ const StateConnecting

+ const StateDisconnected

+ const StateExpired

+ const StateHasSession

+ const StateSaslAuthenticated

+ const StateSyncConnected

+ const StateUnknown

+ var ErrAPIError = errors.New("zk: api error")

+ var ErrAuthFailed = errors.New("zk: client authentication failed")

+ var ErrBadVersion = errors.New("zk: version conflict")

+ var ErrClosing = errors.New("zk: zookeeper is closing")

+ var ErrConnectionClosed = errors.New("zk: connection closed")

+ var ErrInvalidACL = errors.New("zk: invalid ACL specified")

+ var ErrNoAuth = errors.New("zk: not authenticated")

+ var ErrNoChildrenForEphemerals = errors.New("zk: ephemeral nodes may not have children")

+ var ErrNoNode = errors.New("zk: node does not exist")

+ var ErrNodeExists = errors.New("zk: node already exists")

+ var ErrNotEmpty = errors.New("zk: node has children")

+ var ErrNothing = errors.New("zk: no server responsees to process")

+ var ErrPtrExpected = errors.New("ptr expected")

+ var ErrSessionExpired = errors.New("zk: session has been expired by the server")

+ var ErrSessionMoved = errors.New("zk: session moved to another server, so operation is ignored")

+ var ErrShortBuffer = errors.New("short buffer")

+ var ErrUnhandledFieldType = errors.New("unhandled field type")

+ var ErrUnknown = errors.New("zk: unknown error")

+ var PerfectZXidMode bool = true

+ func ReadPacket(zk net.Conn, r interface{}) (string, error)

+ func Serve(ctx context.Context, ln net.Listener, auth AuthFunc, zk ZKFunc)

+ func ServeSerial(ctx context.Context, ln net.Listener, auth AuthFunc, zk ZKFunc)

+ func WritePacket(zk net.Conn, r interface{}) error

+ type ACL struct

+ ID string

+ Perms int32

+ Scheme string

+ type AuthConn interface

+ Close func()

+ Read func() (*AuthRequest, error)

+ Write func(AuthResponse) (Conn, error)

+ func NewAuthConn(c net.Conn) AuthConn

+ type AuthFunc func(AuthConn) (Session, error)

+ func NewAuth(c *etcd.Client) AuthFunc

+ type AuthRequest struct

+ FourLetterWord string

+ Req *ConnectRequest

+ type AuthResponse struct

+ FourLetterWord string

+ Resp *ConnectResponse

+ type CheckVersionRequest pathVersionRequest

+ type Client interface

+ Close func()

+ Read func() <-chan ZKResponse

+ Send func(xid Xid, req interface{}) error

+ StopNotify func() <-chan struct{}

+ func NewClient(ctx context.Context, zk net.Conn) Client

+ type CloseRequest struct

+ type CloseResponse struct

+ type Conn interface

+ Close func()

+ Read func() <-chan ZKRequest

+ Send func(xid Xid, zxid ZXid, resp interface{}) error

+ StopNotify func() <-chan struct{}

+ func NewConn(zk net.Conn) Conn

+ type ConnectRequest struct

+ LastZxidSeen ZXid

+ Passwd []byte

+ ProtocolVersion int32

+ SessionID Sid

+ TimeOut int32

+ type ConnectResponse struct

+ Passwd []byte

+ ProtocolVersion int32

+ SessionID Sid

+ TimeOut int32

+ type CreateRequest struct

+ Acl []ACL

+ Data []byte

+ Flags int32

+ Path string

+ type CreateResponse pathResponse

+ type DeleteRequest pathVersionRequest

+ type DeleteResponse struct

+ type ErrCode int32

+ type EventType int32

+ const EventNodeChildrenChanged

+ const EventNodeCreated

+ const EventNodeDataChanged

+ const EventNodeDeleted

+ const EventNotWatching

+ const EventSession

+ type ExistsRequest pathWatchRequest

+ type ExistsResponse statResponse

+ type GetAclRequest pathRequest

+ type GetAclResponse struct

+ Acl []ACL

+ Stat Stat

+ type GetChildren2Request pathWatchRequest

+ type GetChildren2Response struct

+ Children []string

+ Stat Stat

+ type GetChildrenRequest pathWatchRequest

+ type GetChildrenResponse struct

+ Children []string

+ type GetDataRequest pathWatchRequest

+ type GetDataResponse struct

+ Data []byte

+ Stat Stat

+ type MultiHeader struct

+ Done bool

+ Err ErrCode

+ Type Op

+ type MultiRequest struct

+ DoneHeader MultiHeader

+ Ops []MultiRequestOp

+ func (r *MultiRequest) Decode(buf []byte) (int, error)

+ func (r *MultiRequest) Encode(buf []byte) (int, error)

+ type MultiRequestOp struct

+ Header MultiHeader

+ Op interface{}

+ type MultiResponse struct

+ DoneHeader MultiHeader

+ Ops []MultiResponseOp

+ func (r *MultiResponse) Decode(buf []byte) (int, error)

+ type MultiResponseOp struct

+ Header MultiHeader

+ Stat *Stat

+ String string

+ type Op int32

+ type PingRequest struct

+ type PingResponse struct

+ type ResponseHeader struct

+ Err ErrCode

+ Xid Xid

+ Zxid ZXid

+ type Session interface

+ Backing func() interface{}

+ ConnReq func() ConnectRequest

+ Sid func() Sid

+ ZXid func() ZXid

+ type SessionPool struct

+ func NewSessionPool(client *etcd.Client) *SessionPool

+ func (sp *SessionPool) Auth(zka AuthConn) (Session, error)

+ type SetAclRequest struct

+ Acl []ACL

+ Path string

+ Version Ver

+ type SetAclResponse statResponse

+ type SetAuthRequest auth

+ type SetAuthResponse struct

+ type SetDataRequest struct

+ Data []byte

+ Path string

+ Version Ver

+ type SetDataResponse statResponse

+ type SetWatchesRequest struct

+ ChildWatches []string

+ DataWatches []string

+ ExistWatches []string

+ RelativeZxid ZXid

+ type SetWatchesResponse struct

+ type Sid int64

+ type Stat struct

+ Aversion Ver

+ Ctime int64

+ Cversion Ver

+ Czxid ZXid

+ DataLength int32

+ EphemeralOwner Sid

+ Mtime int64

+ Mzxid ZXid

+ NumChildren int32

+ Pzxid ZXid

+ Version Ver

+ type State int32

+ type SyncRequest pathRequest

+ type SyncResponse pathResponse

+ type Ver int32

+ type WatcherEvent struct

+ Path string

+ State State

+ Type EventType

+ type Watches interface

+ Wait func(rev ZXid, path string, evtype EventType)

+ Watch func(rev ZXid, xid Xid, path string, evtype EventType, cb func(ZXid))

+ type Xid int32

+ type ZK interface

+ Close func(xid Xid, op *CloseRequest) ZKResponse

+ Create func(xid Xid, op *CreateRequest) ZKResponse

+ Delete func(xid Xid, op *DeleteRequest) ZKResponse

+ Exists func(xid Xid, op *ExistsRequest) ZKResponse

+ GetAcl func(xid Xid, op *GetAclRequest) ZKResponse

+ GetChildren func(xid Xid, op *GetChildrenRequest) ZKResponse

+ GetChildren2 func(xid Xid, op *GetChildren2Request) ZKResponse

+ GetData func(xid Xid, op *GetDataRequest) ZKResponse

+ Multi func(xid Xid, op *MultiRequest) ZKResponse

+ Ping func(xid Xid, op *PingRequest) ZKResponse

+ SetAcl func(xid Xid, op *SetAclRequest) ZKResponse

+ SetAuth func(xid Xid, op *SetAuthRequest) ZKResponse

+ SetData func(xid Xid, op *SetDataRequest) ZKResponse

+ SetWatches func(xid Xid, op *SetWatchesRequest) ZKResponse

+ Sync func(xid Xid, op *SyncRequest) ZKResponse

+ func NewZKEtcd(c *etcd.Client, s Session) ZK

+ func NewZKLog(zk ZK) ZK

+ type ZKFunc func(Session) (ZK, error)

+ func NewZK(c *etcd.Client) ZKFunc

+ type ZKRequest struct

+ func (zk *ZKRequest) String() string

+ type ZKResponse struct

+ Err error

+ Hdr *ResponseHeader

+ Resp interface{}

+ func DispatchZK(zk ZK, xid Xid, op interface{}) ZKResponse

+ type ZXid int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL