Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

stub

package

Go to main page

Versions in this module

v1

v1.0.7

Sep 29, 2024

v1.0.6

May 10, 2024

v1.0.5

Apr 21, 2024

v1.0.4

Mar 27, 2024

Changes in this version

+ type SnapshotBeans struct

+ Beans []*SnapshotBean

+ Id *int64

+ func BytesToSnapshotBeans(bs []byte) (_r *SnapshotBeans, err error)

+ func (*SnapshotBeans) Descriptor() ([]byte, []int)

+ func (*SnapshotBeans) ProtoMessage()

+ func (t *SnapshotBeans) ToBytes() ([]byte, error)

+ func (x *SnapshotBeans) GetBeans() []*SnapshotBean

+ func (x *SnapshotBeans) GetId() int64

+ func (x *SnapshotBeans) ProtoReflect() protoreflect.Message

+ func (x *SnapshotBeans) Reset()

+ func (x *SnapshotBeans) String() string

+ type SnapshotFile struct

+ CompressType *int32

+ Data []byte

+ Id *int64

+ Path *string

+ func BytesToSnapshotFile(bs []byte) (_r *SnapshotFile, err error)

+ func (*SnapshotFile) Descriptor() ([]byte, []int)

+ func (*SnapshotFile) ProtoMessage()

+ func (t *SnapshotFile) ToBytes() ([]byte, error)

+ func (x *SnapshotFile) GetCompressType() int32

+ func (x *SnapshotFile) GetData() []byte

+ func (x *SnapshotFile) GetId() int64

+ func (x *SnapshotFile) GetPath() string

+ func (x *SnapshotFile) ProtoReflect() protoreflect.Message

+ func (x *SnapshotFile) Reset()

+ func (x *SnapshotFile) String() string

v1.0.2

Mar 13, 2024

Changes in this version

+ var File_wfs_proto protoreflect.FileDescriptor

+ var WfsAuth_Name_DEFAULT string

+ var WfsAuth_Pwd_DEFAULT string

+ var WfsData_Data_DEFAULT []byte

+ var WfsError_Code_DEFAULT int32

+ var WfsError_Info_DEFAULT string

+ var WfsFile_Compress_DEFAULT int8

+ var WfsIfacePingResult_Success_DEFAULT int8

+ var WfsReq_Path_DEFAULT string

+ type SnapshotBean struct

+ Key []byte

+ Value []byte

+ func BytesToSnapshotBean(bs []byte) (_r *SnapshotBean, err error)

+ func (*SnapshotBean) Descriptor() ([]byte, []int)

+ func (*SnapshotBean) ProtoMessage()

+ func (t *SnapshotBean) Copy(key, value []byte)

+ func (t *SnapshotBean) ToBytes() ([]byte, error)

+ func (x *SnapshotBean) GetKey() []byte

+ func (x *SnapshotBean) GetValue() []byte

+ func (x *SnapshotBean) ProtoReflect() protoreflect.Message

+ func (x *SnapshotBean) Reset()

+ func (x *SnapshotBean) String() string

+ type WfsAck struct

+ Error *WfsError

+ Ok bool

+ var WfsIfaceAppendResult_Success_DEFAULT *WfsAck

+ var WfsIfaceAuthResult_Success_DEFAULT *WfsAck

+ var WfsIfaceDeleteResult_Success_DEFAULT *WfsAck

+ var WfsIfaceRenameResult_Success_DEFAULT *WfsAck

+ func NewWfsAck() *WfsAck

+ func (p *WfsAck) Equals(other *WfsAck) bool

+ func (p *WfsAck) GetError() *WfsError

+ func (p *WfsAck) GetOk() bool

+ func (p *WfsAck) IsSetError() bool

+ func (p *WfsAck) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsAck) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsAck) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsAck) String() string

+ func (p *WfsAck) Validate() error

+ func (p *WfsAck) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsAuth struct

+ Name *string

+ Pwd *string

+ var WfsIfaceAuthArgs_Wa_DEFAULT *WfsAuth

+ func NewWfsAuth() *WfsAuth

+ func (p *WfsAuth) Equals(other *WfsAuth) bool

+ func (p *WfsAuth) GetName() string

+ func (p *WfsAuth) GetPwd() string

+ func (p *WfsAuth) IsSetName() bool

+ func (p *WfsAuth) IsSetPwd() bool

+ func (p *WfsAuth) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsAuth) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsAuth) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsAuth) String() string

+ func (p *WfsAuth) Validate() error

+ func (p *WfsAuth) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsData struct

+ Data []byte

+ var WfsIfaceGetResult_Success_DEFAULT *WfsData

+ func NewWfsData() *WfsData

+ func (p *WfsData) Equals(other *WfsData) bool

+ func (p *WfsData) GetData() []byte

+ func (p *WfsData) IsSetData() bool

+ func (p *WfsData) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsData) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsData) String() string

+ func (p *WfsData) Validate() error

+ func (p *WfsData) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsError struct

+ Code *int32

+ Info *string

+ var WfsAck_Error_DEFAULT *WfsError

+ func NewWfsError() *WfsError

+ func (p *WfsError) Equals(other *WfsError) bool

+ func (p *WfsError) GetCode() int32

+ func (p *WfsError) GetInfo() string

+ func (p *WfsError) IsSetCode() bool

+ func (p *WfsError) IsSetInfo() bool

+ func (p *WfsError) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsError) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsError) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsError) String() string

+ func (p *WfsError) Validate() error

+ func (p *WfsError) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsFile struct

+ Compress *int8

+ Data []byte

+ Name string

+ var WfsIfaceAppendArgs_File_DEFAULT *WfsFile

+ func NewWfsFile() *WfsFile

+ func (p *WfsFile) Equals(other *WfsFile) bool

+ func (p *WfsFile) GetCompress() int8

+ func (p *WfsFile) GetData() []byte

+ func (p *WfsFile) GetName() string

+ func (p *WfsFile) IsSetCompress() bool

+ func (p *WfsFile) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsFile) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsFile) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsFile) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsFile) String() string

+ func (p *WfsFile) Validate() error

+ func (p *WfsFile) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsFileBean struct

+ CompressType *int32

+ Offset *int64

+ Refercount *int32

+ Size *int64

+ Storenode *string

+ func (*WfsFileBean) Descriptor() ([]byte, []int)

+ func (*WfsFileBean) ProtoMessage()

+ func (x *WfsFileBean) GetCompressType() int32

+ func (x *WfsFileBean) GetOffset() int64

+ func (x *WfsFileBean) GetRefercount() int32

+ func (x *WfsFileBean) GetSize() int64

+ func (x *WfsFileBean) GetStorenode() string

+ func (x *WfsFileBean) ProtoReflect() protoreflect.Message

+ func (x *WfsFileBean) Reset()

+ func (x *WfsFileBean) String() string

+ type WfsIface interface

+ Append func(ctx context.Context, file *WfsFile) (_r *WfsAck, _err error)

+ Auth func(ctx context.Context, wa *WfsAuth) (_r *WfsAck, _err error)

+ Delete func(ctx context.Context, path string) (_r *WfsAck, _err error)

+ Get func(ctx context.Context, path string) (_r *WfsData, _err error)

+ Ping func(ctx context.Context) (_r int8, _err error)

+ Rename func(ctx context.Context, path string, newpath string) (_r *WfsAck, _err error)

+ type WfsIfaceAppendArgs struct

+ File *WfsFile

+ func NewWfsIfaceAppendArgs() *WfsIfaceAppendArgs

+ func (p *WfsIfaceAppendArgs) GetFile() *WfsFile

+ func (p *WfsIfaceAppendArgs) IsSetFile() bool

+ func (p *WfsIfaceAppendArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceAppendArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceAppendArgs) String() string

+ func (p *WfsIfaceAppendArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfaceAppendResult struct

+ Success *WfsAck

+ func NewWfsIfaceAppendResult() *WfsIfaceAppendResult

+ func (p *WfsIfaceAppendResult) GetSuccess() *WfsAck

+ func (p *WfsIfaceAppendResult) IsSetSuccess() bool

+ func (p *WfsIfaceAppendResult) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceAppendResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceAppendResult) String() string

+ func (p *WfsIfaceAppendResult) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfaceAuthArgs struct

+ Wa *WfsAuth

+ func NewWfsIfaceAuthArgs() *WfsIfaceAuthArgs

+ func (p *WfsIfaceAuthArgs) GetWa() *WfsAuth

+ func (p *WfsIfaceAuthArgs) IsSetWa() bool

+ func (p *WfsIfaceAuthArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceAuthArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceAuthArgs) String() string

+ func (p *WfsIfaceAuthArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfaceAuthResult struct

+ Success *WfsAck

+ func NewWfsIfaceAuthResult() *WfsIfaceAuthResult

+ func (p *WfsIfaceAuthResult) GetSuccess() *WfsAck

+ func (p *WfsIfaceAuthResult) IsSetSuccess() bool

+ func (p *WfsIfaceAuthResult) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceAuthResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceAuthResult) String() string

+ func (p *WfsIfaceAuthResult) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfaceClient struct

+ func NewWfsIfaceClient(c thrift.TClient) *WfsIfaceClient

+ func NewWfsIfaceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *WfsIfaceClient

+ func NewWfsIfaceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *WfsIfaceClient

+ func (p *WfsIfaceClient) Append(ctx context.Context, file *WfsFile) (_r *WfsAck, _err error)

+ func (p *WfsIfaceClient) Auth(ctx context.Context, wa *WfsAuth) (_r *WfsAck, _err error)

+ func (p *WfsIfaceClient) Client_() thrift.TClient

+ func (p *WfsIfaceClient) Delete(ctx context.Context, path string) (_r *WfsAck, _err error)

+ func (p *WfsIfaceClient) Get(ctx context.Context, path string) (_r *WfsData, _err error)

+ func (p *WfsIfaceClient) LastResponseMeta_() thrift.ResponseMeta

+ func (p *WfsIfaceClient) Ping(ctx context.Context) (_r int8, _err error)

+ func (p *WfsIfaceClient) Rename(ctx context.Context, path string, newpath string) (_r *WfsAck, _err error)

+ func (p *WfsIfaceClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

+ type WfsIfaceDeleteArgs struct

+ Path string

+ func NewWfsIfaceDeleteArgs() *WfsIfaceDeleteArgs

+ func (p *WfsIfaceDeleteArgs) GetPath() string

+ func (p *WfsIfaceDeleteArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceDeleteArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceDeleteArgs) String() string

+ func (p *WfsIfaceDeleteArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfaceDeleteResult struct

+ Success *WfsAck

+ func NewWfsIfaceDeleteResult() *WfsIfaceDeleteResult

+ func (p *WfsIfaceDeleteResult) GetSuccess() *WfsAck

+ func (p *WfsIfaceDeleteResult) IsSetSuccess() bool

+ func (p *WfsIfaceDeleteResult) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceDeleteResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceDeleteResult) String() string

+ func (p *WfsIfaceDeleteResult) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfaceGetArgs struct

+ Path string

+ func NewWfsIfaceGetArgs() *WfsIfaceGetArgs

+ func (p *WfsIfaceGetArgs) GetPath() string

+ func (p *WfsIfaceGetArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceGetArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceGetArgs) String() string

+ func (p *WfsIfaceGetArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfaceGetResult struct

+ Success *WfsData

+ func NewWfsIfaceGetResult() *WfsIfaceGetResult

+ func (p *WfsIfaceGetResult) GetSuccess() *WfsData

+ func (p *WfsIfaceGetResult) IsSetSuccess() bool

+ func (p *WfsIfaceGetResult) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceGetResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceGetResult) String() string

+ func (p *WfsIfaceGetResult) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfacePingArgs struct

+ func NewWfsIfacePingArgs() *WfsIfacePingArgs

+ func (p *WfsIfacePingArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfacePingArgs) String() string

+ func (p *WfsIfacePingArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfacePingResult struct

+ Success *int8

+ func NewWfsIfacePingResult() *WfsIfacePingResult

+ func (p *WfsIfacePingResult) GetSuccess() int8

+ func (p *WfsIfacePingResult) IsSetSuccess() bool

+ func (p *WfsIfacePingResult) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfacePingResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfacePingResult) String() string

+ func (p *WfsIfacePingResult) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfaceProcessor struct

+ func NewWfsIfaceProcessor(handler WfsIface) *WfsIfaceProcessor

+ func (p *WfsIfaceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

+ func (p *WfsIfaceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

+ func (p *WfsIfaceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

+ func (p *WfsIfaceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

+ type WfsIfaceRenameArgs struct

+ Newpath_ string

+ Path string

+ func NewWfsIfaceRenameArgs() *WfsIfaceRenameArgs

+ func (p *WfsIfaceRenameArgs) GetNewpath_() string

+ func (p *WfsIfaceRenameArgs) GetPath() string

+ func (p *WfsIfaceRenameArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceRenameArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceRenameArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceRenameArgs) String() string

+ func (p *WfsIfaceRenameArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsIfaceRenameResult struct

+ Success *WfsAck

+ func NewWfsIfaceRenameResult() *WfsIfaceRenameResult

+ func (p *WfsIfaceRenameResult) GetSuccess() *WfsAck

+ func (p *WfsIfaceRenameResult) IsSetSuccess() bool

+ func (p *WfsIfaceRenameResult) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceRenameResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsIfaceRenameResult) String() string

+ func (p *WfsIfaceRenameResult) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type WfsNodeBean struct

+ Rmsize *int64

+ func (*WfsNodeBean) Descriptor() ([]byte, []int)

+ func (*WfsNodeBean) ProtoMessage()

+ func (x *WfsNodeBean) GetRmsize() int64

+ func (x *WfsNodeBean) ProtoReflect() protoreflect.Message

+ func (x *WfsNodeBean) Reset()

+ func (x *WfsNodeBean) String() string

+ type WfsPathBean struct

+ Path *string

+ Timestramp *int64

+ func (*WfsPathBean) Descriptor() ([]byte, []int)

+ func (*WfsPathBean) ProtoMessage()

+ func (x *WfsPathBean) GetPath() string

+ func (x *WfsPathBean) GetTimestramp() int64

+ func (x *WfsPathBean) ProtoReflect() protoreflect.Message

+ func (x *WfsPathBean) Reset()

+ func (x *WfsPathBean) String() string

+ type WfsReq struct

+ Path *string

+ func NewWfsReq() *WfsReq

+ func (p *WfsReq) Equals(other *WfsReq) bool

+ func (p *WfsReq) GetPath() string

+ func (p *WfsReq) IsSetPath() bool

+ func (p *WfsReq) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *WfsReq) String() string

+ func (p *WfsReq) Validate() error

+ func (p *WfsReq) Write(ctx context.Context, oprot thrift.TProtocol) error

v1.0.1

Mar 7, 2024