proto

package
v0.0.0-...-cc177ea Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 7, 2021 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddWatchRequest 

type AddWatchRequest struct {
	Path string // path
	Mode int32  // mode
}

func (*AddWatchRequest) GetMode 

func (r *AddWatchRequest) GetMode() int32

func (*AddWatchRequest) GetPath 

func (r *AddWatchRequest) GetPath() string

func (*AddWatchRequest) Read 

func (r *AddWatchRequest) Read(dec jute.Decoder) (err error)

func (*AddWatchRequest) String 

func (r *AddWatchRequest) String() string

func (*AddWatchRequest) Write 

func (r *AddWatchRequest) Write(enc jute.Encoder) error

type AuthPacket 

type AuthPacket struct {
	Type   int32  // type
	Scheme string // scheme
	Auth   []byte // auth
}

func (*AuthPacket) GetAuth 

func (r *AuthPacket) GetAuth() []byte

func (*AuthPacket) GetScheme 

func (r *AuthPacket) GetScheme() string

func (*AuthPacket) GetType 

func (r *AuthPacket) GetType() int32

func (*AuthPacket) Read 

func (r *AuthPacket) Read(dec jute.Decoder) (err error)

func (*AuthPacket) String 

func (r *AuthPacket) String() string

func (*AuthPacket) Write 

func (r *AuthPacket) Write(enc jute.Encoder) error

type CheckVersionRequest 

type CheckVersionRequest struct {
	Path    string // path
	Version int32  // version
}

func (*CheckVersionRequest) GetPath 

func (r *CheckVersionRequest) GetPath() string

func (*CheckVersionRequest) GetVersion 

func (r *CheckVersionRequest) GetVersion() int32

func (*CheckVersionRequest) Read 

func (r *CheckVersionRequest) Read(dec jute.Decoder) (err error)

func (*CheckVersionRequest) String 

func (r *CheckVersionRequest) String() string

func (*CheckVersionRequest) Write 

func (r *CheckVersionRequest) Write(enc jute.Encoder) error

type CheckWatchesRequest 

type CheckWatchesRequest struct {
	Path string // path
	Type int32  // type
}

func (*CheckWatchesRequest) GetPath 

func (r *CheckWatchesRequest) GetPath() string

func (*CheckWatchesRequest) GetType 

func (r *CheckWatchesRequest) GetType() int32

func (*CheckWatchesRequest) Read 

func (r *CheckWatchesRequest) Read(dec jute.Decoder) (err error)

func (*CheckWatchesRequest) String 

func (r *CheckWatchesRequest) String() string

func (*CheckWatchesRequest) Write 

func (r *CheckWatchesRequest) Write(enc jute.Encoder) error

type ConnectRequest 

type ConnectRequest struct {
	ProtocolVersion int32  // protocolVersion
	LastZxidSeen    int64  // lastZxidSeen
	TimeOut         int32  // timeOut
	SessionId       int64  // sessionId
	Passwd          []byte // passwd
}

func (*ConnectRequest) GetLastZxidSeen 

func (r *ConnectRequest) GetLastZxidSeen() int64

func (*ConnectRequest) GetPasswd 

func (r *ConnectRequest) GetPasswd() []byte

func (*ConnectRequest) GetProtocolVersion 

func (r *ConnectRequest) GetProtocolVersion() int32

func (*ConnectRequest) GetSessionId 

func (r *ConnectRequest) GetSessionId() int64

func (*ConnectRequest) GetTimeOut 

func (r *ConnectRequest) GetTimeOut() int32

func (*ConnectRequest) Read 

func (r *ConnectRequest) Read(dec jute.Decoder) (err error)

func (*ConnectRequest) String 

func (r *ConnectRequest) String() string

func (*ConnectRequest) Write 

func (r *ConnectRequest) Write(enc jute.Encoder) error

type ConnectResponse 

type ConnectResponse struct {
	ProtocolVersion int32  // protocolVersion
	TimeOut         int32  // timeOut
	SessionId       int64  // sessionId
	Passwd          []byte // passwd
}

func (*ConnectResponse) GetPasswd 

func (r *ConnectResponse) GetPasswd() []byte

func (*ConnectResponse) GetProtocolVersion 

func (r *ConnectResponse) GetProtocolVersion() int32

func (*ConnectResponse) GetSessionId 

func (r *ConnectResponse) GetSessionId() int64

func (*ConnectResponse) GetTimeOut 

func (r *ConnectResponse) GetTimeOut() int32

func (*ConnectResponse) Read 

func (r *ConnectResponse) Read(dec jute.Decoder) (err error)

func (*ConnectResponse) String 

func (r *ConnectResponse) String() string

func (*ConnectResponse) Write 

func (r *ConnectResponse) Write(enc jute.Encoder) error

type Create2Response 

type Create2Response struct {
	Path string    // path
	Stat data.Stat // stat
}

func (*Create2Response) GetPath 

func (r *Create2Response) GetPath() string

func (*Create2Response) GetStat 

func (r *Create2Response) GetStat() data.Stat

func (*Create2Response) Read 

func (r *Create2Response) Read(dec jute.Decoder) (err error)

func (*Create2Response) String 

func (r *Create2Response) String() string

func (*Create2Response) Write 

func (r *Create2Response) Write(enc jute.Encoder) error

type CreateRequest 

type CreateRequest struct {
	Path  string     // path
	Data  []byte     // data
	Acl   []data.ACL // acl
	Flags int32      // flags
}

func (*CreateRequest) GetAcl 

func (r *CreateRequest) GetAcl() []data.ACL

func (*CreateRequest) GetData 

func (r *CreateRequest) GetData() []byte

func (*CreateRequest) GetFlags 

func (r *CreateRequest) GetFlags() int32

func (*CreateRequest) GetPath 

func (r *CreateRequest) GetPath() string

func (*CreateRequest) Read 

func (r *CreateRequest) Read(dec jute.Decoder) (err error)

func (*CreateRequest) String 

func (r *CreateRequest) String() string

func (*CreateRequest) Write 

func (r *CreateRequest) Write(enc jute.Encoder) error

type CreateResponse 

type CreateResponse struct {
	Path string // path
}

func (*CreateResponse) GetPath 

func (r *CreateResponse) GetPath() string

func (*CreateResponse) Read 

func (r *CreateResponse) Read(dec jute.Decoder) (err error)

func (*CreateResponse) String 

func (r *CreateResponse) String() string

func (*CreateResponse) Write 

func (r *CreateResponse) Write(enc jute.Encoder) error

type CreateTTLRequest 

type CreateTTLRequest struct {
	Path  string     // path
	Data  []byte     // data
	Acl   []data.ACL // acl
	Flags int32      // flags
	Ttl   int64      // ttl
}

func (*CreateTTLRequest) GetAcl 

func (r *CreateTTLRequest) GetAcl() []data.ACL

func (*CreateTTLRequest) GetData 

func (r *CreateTTLRequest) GetData() []byte

func (*CreateTTLRequest) GetFlags 

func (r *CreateTTLRequest) GetFlags() int32

func (*CreateTTLRequest) GetPath 

func (r *CreateTTLRequest) GetPath() string

func (*CreateTTLRequest) GetTtl 

func (r *CreateTTLRequest) GetTtl() int64

func (*CreateTTLRequest) Read 

func (r *CreateTTLRequest) Read(dec jute.Decoder) (err error)

func (*CreateTTLRequest) String 

func (r *CreateTTLRequest) String() string

func (*CreateTTLRequest) Write 

func (r *CreateTTLRequest) Write(enc jute.Encoder) error

type DeleteRequest 

type DeleteRequest struct {
	Path    string // path
	Version int32  // version
}

func (*DeleteRequest) GetPath 

func (r *DeleteRequest) GetPath() string

func (*DeleteRequest) GetVersion 

func (r *DeleteRequest) GetVersion() int32

func (*DeleteRequest) Read 

func (r *DeleteRequest) Read(dec jute.Decoder) (err error)

func (*DeleteRequest) String 

func (r *DeleteRequest) String() string

func (*DeleteRequest) Write 

func (r *DeleteRequest) Write(enc jute.Encoder) error

type ErrorResponse 

type ErrorResponse struct {
	Err int32 // err
}

func (*ErrorResponse) GetErr 

func (r *ErrorResponse) GetErr() int32

func (*ErrorResponse) Read 

func (r *ErrorResponse) Read(dec jute.Decoder) (err error)

func (*ErrorResponse) String 

func (r *ErrorResponse) String() string

func (*ErrorResponse) Write 

func (r *ErrorResponse) Write(enc jute.Encoder) error

type ExistsRequest 

type ExistsRequest struct {
	Path  string // path
	Watch bool   // watch
}

func (*ExistsRequest) GetPath 

func (r *ExistsRequest) GetPath() string

func (*ExistsRequest) GetWatch 

func (r *ExistsRequest) GetWatch() bool

func (*ExistsRequest) Read 

func (r *ExistsRequest) Read(dec jute.Decoder) (err error)

func (*ExistsRequest) String 

func (r *ExistsRequest) String() string

func (*ExistsRequest) Write 

func (r *ExistsRequest) Write(enc jute.Encoder) error

type ExistsResponse 

type ExistsResponse struct {
	Stat data.Stat // stat
}

func (*ExistsResponse) GetStat 

func (r *ExistsResponse) GetStat() data.Stat

func (*ExistsResponse) Read 

func (r *ExistsResponse) Read(dec jute.Decoder) (err error)

func (*ExistsResponse) String 

func (r *ExistsResponse) String() string

func (*ExistsResponse) Write 

func (r *ExistsResponse) Write(enc jute.Encoder) error

type GetACLRequest 

type GetACLRequest struct {
	Path string // path
}

func (*GetACLRequest) GetPath 

func (r *GetACLRequest) GetPath() string

func (*GetACLRequest) Read 

func (r *GetACLRequest) Read(dec jute.Decoder) (err error)

func (*GetACLRequest) String 

func (r *GetACLRequest) String() string

func (*GetACLRequest) Write 

func (r *GetACLRequest) Write(enc jute.Encoder) error

type GetACLResponse 

type GetACLResponse struct {
	Acl  []data.ACL // acl
	Stat data.Stat  // stat
}

func (*GetACLResponse) GetAcl 

func (r *GetACLResponse) GetAcl() []data.ACL

func (*GetACLResponse) GetStat 

func (r *GetACLResponse) GetStat() data.Stat

func (*GetACLResponse) Read 

func (r *GetACLResponse) Read(dec jute.Decoder) (err error)

func (*GetACLResponse) String 

func (r *GetACLResponse) String() string

func (*GetACLResponse) Write 

func (r *GetACLResponse) Write(enc jute.Encoder) error

type GetAllChildrenNumberRequest 

type GetAllChildrenNumberRequest struct {
	Path string // path
}

func (*GetAllChildrenNumberRequest) GetPath 

func (r *GetAllChildrenNumberRequest) GetPath() string

func (*GetAllChildrenNumberRequest) Read 

func (r *GetAllChildrenNumberRequest) Read(dec jute.Decoder) (err error)

func (*GetAllChildrenNumberRequest) String 

func (r *GetAllChildrenNumberRequest) String() string

func (*GetAllChildrenNumberRequest) Write 

func (r *GetAllChildrenNumberRequest) Write(enc jute.Encoder) error

type GetAllChildrenNumberResponse 

type GetAllChildrenNumberResponse struct {
	TotalNumber int32 // totalNumber
}

func (*GetAllChildrenNumberResponse) GetTotalNumber 

func (r *GetAllChildrenNumberResponse) GetTotalNumber() int32

func (*GetAllChildrenNumberResponse) Read 

func (r *GetAllChildrenNumberResponse) Read(dec jute.Decoder) (err error)

func (*GetAllChildrenNumberResponse) String 

func (r *GetAllChildrenNumberResponse) String() string

func (*GetAllChildrenNumberResponse) Write 

func (r *GetAllChildrenNumberResponse) Write(enc jute.Encoder) error

type GetChildren2Request 

type GetChildren2Request struct {
	Path  string // path
	Watch bool   // watch
}

func (*GetChildren2Request) GetPath 

func (r *GetChildren2Request) GetPath() string

func (*GetChildren2Request) GetWatch 

func (r *GetChildren2Request) GetWatch() bool

func (*GetChildren2Request) Read 

func (r *GetChildren2Request) Read(dec jute.Decoder) (err error)

func (*GetChildren2Request) String 

func (r *GetChildren2Request) String() string

func (*GetChildren2Request) Write 

func (r *GetChildren2Request) Write(enc jute.Encoder) error

type GetChildren2Response 

type GetChildren2Response struct {
	Children []string  // children
	Stat     data.Stat // stat
}

func (*GetChildren2Response) GetChildren 

func (r *GetChildren2Response) GetChildren() []string

func (*GetChildren2Response) GetStat 

func (r *GetChildren2Response) GetStat() data.Stat

func (*GetChildren2Response) Read 

func (r *GetChildren2Response) Read(dec jute.Decoder) (err error)

func (*GetChildren2Response) String 

func (r *GetChildren2Response) String() string

func (*GetChildren2Response) Write 

func (r *GetChildren2Response) Write(enc jute.Encoder) error

type GetChildrenRequest 

type GetChildrenRequest struct {
	Path  string // path
	Watch bool   // watch
}

func (*GetChildrenRequest) GetPath 

func (r *GetChildrenRequest) GetPath() string

func (*GetChildrenRequest) GetWatch 

func (r *GetChildrenRequest) GetWatch() bool

func (*GetChildrenRequest) Read 

func (r *GetChildrenRequest) Read(dec jute.Decoder) (err error)

func (*GetChildrenRequest) String 

func (r *GetChildrenRequest) String() string

func (*GetChildrenRequest) Write 

func (r *GetChildrenRequest) Write(enc jute.Encoder) error

type GetChildrenResponse 

type GetChildrenResponse struct {
	Children []string // children
}

func (*GetChildrenResponse) GetChildren 

func (r *GetChildrenResponse) GetChildren() []string

func (*GetChildrenResponse) Read 

func (r *GetChildrenResponse) Read(dec jute.Decoder) (err error)

func (*GetChildrenResponse) String 

func (r *GetChildrenResponse) String() string

func (*GetChildrenResponse) Write 

func (r *GetChildrenResponse) Write(enc jute.Encoder) error

type GetDataRequest 

type GetDataRequest struct {
	Path  string // path
	Watch bool   // watch
}

func (*GetDataRequest) GetPath 

func (r *GetDataRequest) GetPath() string

func (*GetDataRequest) GetWatch 

func (r *GetDataRequest) GetWatch() bool

func (*GetDataRequest) Read 

func (r *GetDataRequest) Read(dec jute.Decoder) (err error)

func (*GetDataRequest) String 

func (r *GetDataRequest) String() string

func (*GetDataRequest) Write 

func (r *GetDataRequest) Write(enc jute.Encoder) error

type GetDataResponse 

type GetDataResponse struct {
	Data []byte    // data
	Stat data.Stat // stat
}

func (*GetDataResponse) GetData 

func (r *GetDataResponse) GetData() []byte

func (*GetDataResponse) GetStat 

func (r *GetDataResponse) GetStat() data.Stat

func (*GetDataResponse) Read 

func (r *GetDataResponse) Read(dec jute.Decoder) (err error)

func (*GetDataResponse) String 

func (r *GetDataResponse) String() string

func (*GetDataResponse) Write 

func (r *GetDataResponse) Write(enc jute.Encoder) error

type GetEphemeralsRequest 

type GetEphemeralsRequest struct {
	PrefixPath string // prefixPath
}

func (*GetEphemeralsRequest) GetPrefixPath 

func (r *GetEphemeralsRequest) GetPrefixPath() string

func (*GetEphemeralsRequest) Read 

func (r *GetEphemeralsRequest) Read(dec jute.Decoder) (err error)

func (*GetEphemeralsRequest) String 

func (r *GetEphemeralsRequest) String() string

func (*GetEphemeralsRequest) Write 

func (r *GetEphemeralsRequest) Write(enc jute.Encoder) error

type GetEphemeralsResponse 

type GetEphemeralsResponse struct {
	Ephemerals []string // ephemerals
}

func (*GetEphemeralsResponse) GetEphemerals 

func (r *GetEphemeralsResponse) GetEphemerals() []string

func (*GetEphemeralsResponse) Read 

func (r *GetEphemeralsResponse) Read(dec jute.Decoder) (err error)

func (*GetEphemeralsResponse) String 

func (r *GetEphemeralsResponse) String() string

func (*GetEphemeralsResponse) Write 

func (r *GetEphemeralsResponse) Write(enc jute.Encoder) error

type GetMaxChildrenRequest 

type GetMaxChildrenRequest struct {
	Path string // path
}

func (*GetMaxChildrenRequest) GetPath 

func (r *GetMaxChildrenRequest) GetPath() string

func (*GetMaxChildrenRequest) Read 

func (r *GetMaxChildrenRequest) Read(dec jute.Decoder) (err error)

func (*GetMaxChildrenRequest) String 

func (r *GetMaxChildrenRequest) String() string

func (*GetMaxChildrenRequest) Write 

func (r *GetMaxChildrenRequest) Write(enc jute.Encoder) error

type GetMaxChildrenResponse 

type GetMaxChildrenResponse struct {
	Max int32 // max
}

func (*GetMaxChildrenResponse) GetMax 

func (r *GetMaxChildrenResponse) GetMax() int32

func (*GetMaxChildrenResponse) Read 

func (r *GetMaxChildrenResponse) Read(dec jute.Decoder) (err error)

func (*GetMaxChildrenResponse) String 

func (r *GetMaxChildrenResponse) String() string

func (*GetMaxChildrenResponse) Write 

func (r *GetMaxChildrenResponse) Write(enc jute.Encoder) error

type GetSASLRequest 

type GetSASLRequest struct {
	Token []byte // token
}

func (*GetSASLRequest) GetToken 

func (r *GetSASLRequest) GetToken() []byte

func (*GetSASLRequest) Read 

func (r *GetSASLRequest) Read(dec jute.Decoder) (err error)

func (*GetSASLRequest) String 

func (r *GetSASLRequest) String() string

func (*GetSASLRequest) Write 

func (r *GetSASLRequest) Write(enc jute.Encoder) error

type MultiHeader 

type MultiHeader struct {
	Type int32 // type
	Done bool  // done
	Err  int32 // err
}

func (*MultiHeader) GetDone 

func (r *MultiHeader) GetDone() bool

func (*MultiHeader) GetErr 

func (r *MultiHeader) GetErr() int32

func (*MultiHeader) GetType 

func (r *MultiHeader) GetType() int32

func (*MultiHeader) Read 

func (r *MultiHeader) Read(dec jute.Decoder) (err error)

func (*MultiHeader) String 

func (r *MultiHeader) String() string

func (*MultiHeader) Write 

func (r *MultiHeader) Write(enc jute.Encoder) error

type ReconfigRequest 

type ReconfigRequest struct {
	JoiningServers string // joiningServers
	LeavingServers string // leavingServers
	NewMembers     string // newMembers
	CurConfigId    int64  // curConfigId
}

func (*ReconfigRequest) GetCurConfigId 

func (r *ReconfigRequest) GetCurConfigId() int64

func (*ReconfigRequest) GetJoiningServers 

func (r *ReconfigRequest) GetJoiningServers() string

func (*ReconfigRequest) GetLeavingServers 

func (r *ReconfigRequest) GetLeavingServers() string

func (*ReconfigRequest) GetNewMembers 

func (r *ReconfigRequest) GetNewMembers() string

func (*ReconfigRequest) Read 

func (r *ReconfigRequest) Read(dec jute.Decoder) (err error)

func (*ReconfigRequest) String 

func (r *ReconfigRequest) String() string

func (*ReconfigRequest) Write 

func (r *ReconfigRequest) Write(enc jute.Encoder) error

type RemoveWatchesRequest 

type RemoveWatchesRequest struct {
	Path string // path
	Type int32  // type
}

func (*RemoveWatchesRequest) GetPath 

func (r *RemoveWatchesRequest) GetPath() string

func (*RemoveWatchesRequest) GetType 

func (r *RemoveWatchesRequest) GetType() int32

func (*RemoveWatchesRequest) Read 

func (r *RemoveWatchesRequest) Read(dec jute.Decoder) (err error)

func (*RemoveWatchesRequest) String 

func (r *RemoveWatchesRequest) String() string

func (*RemoveWatchesRequest) Write 

func (r *RemoveWatchesRequest) Write(enc jute.Encoder) error

type ReplyHeader 

type ReplyHeader struct {
	Xid  int32 // xid
	Zxid int64 // zxid
	Err  int32 // err
}

func (*ReplyHeader) GetErr 

func (r *ReplyHeader) GetErr() int32

func (*ReplyHeader) GetXid 

func (r *ReplyHeader) GetXid() int32

func (*ReplyHeader) GetZxid 

func (r *ReplyHeader) GetZxid() int64

func (*ReplyHeader) Read 

func (r *ReplyHeader) Read(dec jute.Decoder) (err error)

func (*ReplyHeader) String 

func (r *ReplyHeader) String() string

func (*ReplyHeader) Write 

func (r *ReplyHeader) Write(enc jute.Encoder) error

type RequestHeader 

type RequestHeader struct {
	Xid  int32 // xid
	Type int32 // type
}

func (*RequestHeader) GetType 

func (r *RequestHeader) GetType() int32

func (*RequestHeader) GetXid 

func (r *RequestHeader) GetXid() int32

func (*RequestHeader) Read 

func (r *RequestHeader) Read(dec jute.Decoder) (err error)

func (*RequestHeader) String 

func (r *RequestHeader) String() string

func (*RequestHeader) Write 

func (r *RequestHeader) Write(enc jute.Encoder) error

type SetACLRequest 

type SetACLRequest struct {
	Path    string     // path
	Acl     []data.ACL // acl
	Version int32      // version
}

func (*SetACLRequest) GetAcl 

func (r *SetACLRequest) GetAcl() []data.ACL

func (*SetACLRequest) GetPath 

func (r *SetACLRequest) GetPath() string

func (*SetACLRequest) GetVersion 

func (r *SetACLRequest) GetVersion() int32

func (*SetACLRequest) Read 

func (r *SetACLRequest) Read(dec jute.Decoder) (err error)

func (*SetACLRequest) String 

func (r *SetACLRequest) String() string

func (*SetACLRequest) Write 

func (r *SetACLRequest) Write(enc jute.Encoder) error

type SetACLResponse 

type SetACLResponse struct {
	Stat data.Stat // stat
}

func (*SetACLResponse) GetStat 

func (r *SetACLResponse) GetStat() data.Stat

func (*SetACLResponse) Read 

func (r *SetACLResponse) Read(dec jute.Decoder) (err error)

func (*SetACLResponse) String 

func (r *SetACLResponse) String() string

func (*SetACLResponse) Write 

func (r *SetACLResponse) Write(enc jute.Encoder) error

type SetDataRequest 

type SetDataRequest struct {
	Path    string // path
	Data    []byte // data
	Version int32  // version
}

func (*SetDataRequest) GetData 

func (r *SetDataRequest) GetData() []byte

func (*SetDataRequest) GetPath 

func (r *SetDataRequest) GetPath() string

func (*SetDataRequest) GetVersion 

func (r *SetDataRequest) GetVersion() int32

func (*SetDataRequest) Read 

func (r *SetDataRequest) Read(dec jute.Decoder) (err error)

func (*SetDataRequest) String 

func (r *SetDataRequest) String() string

func (*SetDataRequest) Write 

func (r *SetDataRequest) Write(enc jute.Encoder) error

type SetDataResponse 

type SetDataResponse struct {
	Stat data.Stat // stat
}

func (*SetDataResponse) GetStat 

func (r *SetDataResponse) GetStat() data.Stat

func (*SetDataResponse) Read 

func (r *SetDataResponse) Read(dec jute.Decoder) (err error)

func (*SetDataResponse) String 

func (r *SetDataResponse) String() string

func (*SetDataResponse) Write 

func (r *SetDataResponse) Write(enc jute.Encoder) error

type SetMaxChildrenRequest 

type SetMaxChildrenRequest struct {
	Path string // path
	Max  int32  // max
}

func (*SetMaxChildrenRequest) GetMax 

func (r *SetMaxChildrenRequest) GetMax() int32

func (*SetMaxChildrenRequest) GetPath 

func (r *SetMaxChildrenRequest) GetPath() string

func (*SetMaxChildrenRequest) Read 

func (r *SetMaxChildrenRequest) Read(dec jute.Decoder) (err error)

func (*SetMaxChildrenRequest) String 

func (r *SetMaxChildrenRequest) String() string

func (*SetMaxChildrenRequest) Write 

func (r *SetMaxChildrenRequest) Write(enc jute.Encoder) error

type SetSASLRequest 

type SetSASLRequest struct {
	Token []byte // token
}

func (*SetSASLRequest) GetToken 

func (r *SetSASLRequest) GetToken() []byte

func (*SetSASLRequest) Read 

func (r *SetSASLRequest) Read(dec jute.Decoder) (err error)

func (*SetSASLRequest) String 

func (r *SetSASLRequest) String() string

func (*SetSASLRequest) Write 

func (r *SetSASLRequest) Write(enc jute.Encoder) error

type SetSASLResponse 

type SetSASLResponse struct {
	Token []byte // token
}

func (*SetSASLResponse) GetToken 

func (r *SetSASLResponse) GetToken() []byte

func (*SetSASLResponse) Read 

func (r *SetSASLResponse) Read(dec jute.Decoder) (err error)

func (*SetSASLResponse) String 

func (r *SetSASLResponse) String() string

func (*SetSASLResponse) Write 

func (r *SetSASLResponse) Write(enc jute.Encoder) error

type SetWatches 

type SetWatches struct {
	RelativeZxid int64    // relativeZxid
	DataWatches  []string // dataWatches
	ExistWatches []string // existWatches
	ChildWatches []string // childWatches
}

func (*SetWatches) GetChildWatches 

func (r *SetWatches) GetChildWatches() []string

func (*SetWatches) GetDataWatches 

func (r *SetWatches) GetDataWatches() []string

func (*SetWatches) GetExistWatches 

func (r *SetWatches) GetExistWatches() []string

func (*SetWatches) GetRelativeZxid 

func (r *SetWatches) GetRelativeZxid() int64

func (*SetWatches) Read 

func (r *SetWatches) Read(dec jute.Decoder) (err error)

func (*SetWatches) String 

func (r *SetWatches) String() string

func (*SetWatches) Write 

func (r *SetWatches) Write(enc jute.Encoder) error

type SetWatches2 

type SetWatches2 struct {
	RelativeZxid               int64    // relativeZxid
	DataWatches                []string // dataWatches
	ExistWatches               []string // existWatches
	ChildWatches               []string // childWatches
	PersistentWatches          []string // persistentWatches
	PersistentRecursiveWatches []string // persistentRecursiveWatches
}

func (*SetWatches2) GetChildWatches 

func (r *SetWatches2) GetChildWatches() []string

func (*SetWatches2) GetDataWatches 

func (r *SetWatches2) GetDataWatches() []string

func (*SetWatches2) GetExistWatches 

func (r *SetWatches2) GetExistWatches() []string

func (*SetWatches2) GetPersistentRecursiveWatches 

func (r *SetWatches2) GetPersistentRecursiveWatches() []string

func (*SetWatches2) GetPersistentWatches 

func (r *SetWatches2) GetPersistentWatches() []string

func (*SetWatches2) GetRelativeZxid 

func (r *SetWatches2) GetRelativeZxid() int64

func (*SetWatches2) Read 

func (r *SetWatches2) Read(dec jute.Decoder) (err error)

func (*SetWatches2) String 

func (r *SetWatches2) String() string

func (*SetWatches2) Write 

func (r *SetWatches2) Write(enc jute.Encoder) error

type SyncRequest 

type SyncRequest struct {
	Path string // path
}

func (*SyncRequest) GetPath 

func (r *SyncRequest) GetPath() string

func (*SyncRequest) Read 

func (r *SyncRequest) Read(dec jute.Decoder) (err error)

func (*SyncRequest) String 

func (r *SyncRequest) String() string

func (*SyncRequest) Write 

func (r *SyncRequest) Write(enc jute.Encoder) error

type SyncResponse 

type SyncResponse struct {
	Path string // path
}

func (*SyncResponse) GetPath 

func (r *SyncResponse) GetPath() string

func (*SyncResponse) Read 

func (r *SyncResponse) Read(dec jute.Decoder) (err error)

func (*SyncResponse) String 

func (r *SyncResponse) String() string

func (*SyncResponse) Write 

func (r *SyncResponse) Write(enc jute.Encoder) error

type WatcherEvent 

type WatcherEvent struct {
	Type  int32  // type
	State int32  // state
	Path  string // path
}

func (*WatcherEvent) GetPath 

func (r *WatcherEvent) GetPath() string

func (*WatcherEvent) GetState 

func (r *WatcherEvent) GetState() int32

func (*WatcherEvent) GetType 

func (r *WatcherEvent) GetType() int32

func (*WatcherEvent) Read 

func (r *WatcherEvent) Read(dec jute.Decoder) (err error)

func (*WatcherEvent) String 

func (r *WatcherEvent) String() string

func (*WatcherEvent) Write 

func (r *WatcherEvent) Write(enc jute.Encoder) error

type WhoAmIResponse 

type WhoAmIResponse struct {
	ClientInfo []data.ClientInfo // clientInfo
}

func (*WhoAmIResponse) GetClientInfo 

func (r *WhoAmIResponse) GetClientInfo() []data.ClientInfo

func (*WhoAmIResponse) Read 

func (r *WhoAmIResponse) Read(dec jute.Decoder) (err error)

func (*WhoAmIResponse) String 

func (r *WhoAmIResponse) String() string

func (*WhoAmIResponse) Write 

func (r *WhoAmIResponse) Write(enc jute.Encoder) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.