stub

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: BSD-3-Clause Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_wfs_proto protoreflect.FileDescriptor
View Source 
var WfsAuth_Name_DEFAULT string
View Source 
var WfsAuth_Pwd_DEFAULT string
View Source 
var WfsData_Data_DEFAULT []byte
View Source 
var WfsError_Code_DEFAULT int32
View Source 
var WfsError_Info_DEFAULT string
View Source 
var WfsFile_Compress_DEFAULT int8
View Source 
var WfsIfacePingResult_Success_DEFAULT int8
View Source 
var WfsReq_Path_DEFAULT string

Functions

This section is empty.

Types

type SnapshotBean 

type SnapshotBean struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func BytesToSnapshotBean 

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

func (*SnapshotBean) Copy 

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

func (*SnapshotBean) Descriptor deprecated 

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

Deprecated: Use SnapshotBean.ProtoReflect.Descriptor instead.

func (*SnapshotBean) GetKey 

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

func (*SnapshotBean) GetValue 

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

func (*SnapshotBean) ProtoMessage 

func (*SnapshotBean) ProtoMessage()

func (*SnapshotBean) ProtoReflect 

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

func (*SnapshotBean) Reset 

func (x *SnapshotBean) Reset()

func (*SnapshotBean) String 

func (x *SnapshotBean) String() string

func (*SnapshotBean) ToBytes 

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

type WfsAck 

type WfsAck struct {
	Ok    bool      `thrift:"ok,1,required" db:"ok" json:"ok"`
	Error *WfsError `thrift:"error,2" db:"error" json:"error,omitempty"`
}

Attributes:

  • Ok
  • Error
var WfsIfaceAppendResult_Success_DEFAULT *WfsAck
var WfsIfaceAuthResult_Success_DEFAULT *WfsAck
var WfsIfaceDeleteResult_Success_DEFAULT *WfsAck
var WfsIfaceRenameResult_Success_DEFAULT *WfsAck

func NewWfsAck 

func NewWfsAck() *WfsAck

func (*WfsAck) Equals 

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

func (*WfsAck) GetError 

func (p *WfsAck) GetError() *WfsError

func (*WfsAck) GetOk 

func (p *WfsAck) GetOk() bool

func (*WfsAck) IsSetError 

func (p *WfsAck) IsSetError() bool

func (*WfsAck) Read 

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

func (*WfsAck) ReadField1 

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

func (*WfsAck) ReadField2 

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

func (*WfsAck) String 

func (p *WfsAck) String() string

func (*WfsAck) Validate 

func (p *WfsAck) Validate() error

func (*WfsAck) Write 

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

type WfsAuth 

type WfsAuth struct {
	Name *string `thrift:"name,1" db:"name" json:"name,omitempty"`
	Pwd  *string `thrift:"pwd,2" db:"pwd" json:"pwd,omitempty"`
}

Attributes:

  • Name
  • Pwd
var WfsIfaceAuthArgs_Wa_DEFAULT *WfsAuth

func NewWfsAuth 

func NewWfsAuth() *WfsAuth

func (*WfsAuth) Equals 

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

func (*WfsAuth) GetName 

func (p *WfsAuth) GetName() string

func (*WfsAuth) GetPwd 

func (p *WfsAuth) GetPwd() string

func (*WfsAuth) IsSetName 

func (p *WfsAuth) IsSetName() bool

func (*WfsAuth) IsSetPwd 

func (p *WfsAuth) IsSetPwd() bool

func (*WfsAuth) Read 

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

func (*WfsAuth) ReadField1 

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

func (*WfsAuth) ReadField2 

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

func (*WfsAuth) String 

func (p *WfsAuth) String() string

func (*WfsAuth) Validate 

func (p *WfsAuth) Validate() error

func (*WfsAuth) Write 

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

type WfsData 

type WfsData struct {
	Data []byte `thrift:"data,1" db:"data" json:"data,omitempty"`
}

Attributes:

  • Data
var WfsIfaceGetResult_Success_DEFAULT *WfsData

func NewWfsData 

func NewWfsData() *WfsData

func (*WfsData) Equals 

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

func (*WfsData) GetData 

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

func (*WfsData) IsSetData 

func (p *WfsData) IsSetData() bool

func (*WfsData) Read 

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

func (*WfsData) ReadField1 

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

func (*WfsData) String 

func (p *WfsData) String() string

func (*WfsData) Validate 

func (p *WfsData) Validate() error

func (*WfsData) Write 

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

type WfsError 

type WfsError struct {
	Code *int32  `thrift:"code,1" db:"code" json:"code,omitempty"`
	Info *string `thrift:"info,2" db:"info" json:"info,omitempty"`
}

Attributes:

  • Code
  • Info
var WfsAck_Error_DEFAULT *WfsError

func NewWfsError 

func NewWfsError() *WfsError

func (*WfsError) Equals 

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

func (*WfsError) GetCode 

func (p *WfsError) GetCode() int32

func (*WfsError) GetInfo 

func (p *WfsError) GetInfo() string

func (*WfsError) IsSetCode 

func (p *WfsError) IsSetCode() bool

func (*WfsError) IsSetInfo 

func (p *WfsError) IsSetInfo() bool

func (*WfsError) Read 

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

func (*WfsError) ReadField1 

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

func (*WfsError) ReadField2 

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

func (*WfsError) String 

func (p *WfsError) String() string

func (*WfsError) Validate 

func (p *WfsError) Validate() error

func (*WfsError) Write 

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

type WfsFile 

type WfsFile struct {
	Data     []byte `thrift:"data,1,required" db:"data" json:"data"`
	Name     string `thrift:"name,2,required" db:"name" json:"name"`
	Compress *int8  `thrift:"compress,3" db:"compress" json:"compress,omitempty"`
}

Attributes:

  • Data
  • Name
  • Compress
var WfsIfaceAppendArgs_File_DEFAULT *WfsFile

func NewWfsFile 

func NewWfsFile() *WfsFile

func (*WfsFile) Equals 

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

func (*WfsFile) GetCompress 

func (p *WfsFile) GetCompress() int8

func (*WfsFile) GetData 

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

func (*WfsFile) GetName 

func (p *WfsFile) GetName() string

func (*WfsFile) IsSetCompress 

func (p *WfsFile) IsSetCompress() bool

func (*WfsFile) Read 

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

func (*WfsFile) ReadField1 

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

func (*WfsFile) ReadField2 

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

func (*WfsFile) ReadField3 

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

func (*WfsFile) String 

func (p *WfsFile) String() string

func (*WfsFile) Validate 

func (p *WfsFile) Validate() error

func (*WfsFile) Write 

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

type WfsFileBean 

type WfsFileBean struct {
	Storenode    *string `protobuf:"bytes,1,opt,name=storenode" json:"storenode,omitempty"`
	Offset       *int64  `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
	Size         *int64  `protobuf:"varint,3,opt,name=size" json:"size,omitempty"`
	CompressType *int32  `protobuf:"varint,4,opt,name=compressType" json:"compressType,omitempty"`
	Refercount   *int32  `protobuf:"varint,5,opt,name=refercount" json:"refercount,omitempty"`
	// contains filtered or unexported fields
}

func (*WfsFileBean) Descriptor deprecated 

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

Deprecated: Use WfsFileBean.ProtoReflect.Descriptor instead.

func (*WfsFileBean) GetCompressType 

func (x *WfsFileBean) GetCompressType() int32

func (*WfsFileBean) GetOffset 

func (x *WfsFileBean) GetOffset() int64

func (*WfsFileBean) GetRefercount 

func (x *WfsFileBean) GetRefercount() int32

func (*WfsFileBean) GetSize 

func (x *WfsFileBean) GetSize() int64

func (*WfsFileBean) GetStorenode 

func (x *WfsFileBean) GetStorenode() string

func (*WfsFileBean) ProtoMessage 

func (*WfsFileBean) ProtoMessage()

func (*WfsFileBean) ProtoReflect 

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

func (*WfsFileBean) Reset 

func (x *WfsFileBean) Reset()

func (*WfsFileBean) String 

func (x *WfsFileBean) String() string

type WfsIface 

type WfsIface interface {
	// Parameters:
	//  - File
	Append(ctx context.Context, file *WfsFile) (_r *WfsAck, _err error)
	// Parameters:
	//  - Path
	Delete(ctx context.Context, path string) (_r *WfsAck, _err error)
	// Parameters:
	//  - Path
	//  - Newpath_
	Rename(ctx context.Context, path string, newpath string) (_r *WfsAck, _err error)
	// Parameters:
	//  - Wa
	Auth(ctx context.Context, wa *WfsAuth) (_r *WfsAck, _err error)
	// Parameters:
	//  - Path
	Get(ctx context.Context, path string) (_r *WfsData, _err error)
	Ping(ctx context.Context) (_r int8, _err error)
}

type WfsIfaceAppendArgs 

type WfsIfaceAppendArgs struct {
	File *WfsFile `thrift:"file,1" db:"file" json:"file"`
}

Attributes:

  • File

func NewWfsIfaceAppendArgs 

func NewWfsIfaceAppendArgs() *WfsIfaceAppendArgs

func (*WfsIfaceAppendArgs) GetFile 

func (p *WfsIfaceAppendArgs) GetFile() *WfsFile

func (*WfsIfaceAppendArgs) IsSetFile 

func (p *WfsIfaceAppendArgs) IsSetFile() bool

func (*WfsIfaceAppendArgs) Read 

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

func (*WfsIfaceAppendArgs) ReadField1 

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

func (*WfsIfaceAppendArgs) String 

func (p *WfsIfaceAppendArgs) String() string

func (*WfsIfaceAppendArgs) Write 

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

type WfsIfaceAppendResult 

type WfsIfaceAppendResult struct {
	Success *WfsAck `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewWfsIfaceAppendResult 

func NewWfsIfaceAppendResult() *WfsIfaceAppendResult

func (*WfsIfaceAppendResult) GetSuccess 

func (p *WfsIfaceAppendResult) GetSuccess() *WfsAck

func (*WfsIfaceAppendResult) IsSetSuccess 

func (p *WfsIfaceAppendResult) IsSetSuccess() bool

func (*WfsIfaceAppendResult) Read 

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

func (*WfsIfaceAppendResult) ReadField0 

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

func (*WfsIfaceAppendResult) String 

func (p *WfsIfaceAppendResult) String() string

func (*WfsIfaceAppendResult) Write 

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

type WfsIfaceAuthArgs 

type WfsIfaceAuthArgs struct {
	Wa *WfsAuth `thrift:"wa,1" db:"wa" json:"wa"`
}

Attributes:

  • Wa

func NewWfsIfaceAuthArgs 

func NewWfsIfaceAuthArgs() *WfsIfaceAuthArgs

func (*WfsIfaceAuthArgs) GetWa 

func (p *WfsIfaceAuthArgs) GetWa() *WfsAuth

func (*WfsIfaceAuthArgs) IsSetWa 

func (p *WfsIfaceAuthArgs) IsSetWa() bool

func (*WfsIfaceAuthArgs) Read 

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

func (*WfsIfaceAuthArgs) ReadField1 

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

func (*WfsIfaceAuthArgs) String 

func (p *WfsIfaceAuthArgs) String() string

func (*WfsIfaceAuthArgs) Write 

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

type WfsIfaceAuthResult 

type WfsIfaceAuthResult struct {
	Success *WfsAck `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewWfsIfaceAuthResult 

func NewWfsIfaceAuthResult() *WfsIfaceAuthResult

func (*WfsIfaceAuthResult) GetSuccess 

func (p *WfsIfaceAuthResult) GetSuccess() *WfsAck

func (*WfsIfaceAuthResult) IsSetSuccess 

func (p *WfsIfaceAuthResult) IsSetSuccess() bool

func (*WfsIfaceAuthResult) Read 

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

func (*WfsIfaceAuthResult) ReadField0 

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

func (*WfsIfaceAuthResult) String 

func (p *WfsIfaceAuthResult) String() string

func (*WfsIfaceAuthResult) Write 

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

type WfsIfaceClient 

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

func NewWfsIfaceClient 

func NewWfsIfaceClient(c thrift.TClient) *WfsIfaceClient

func NewWfsIfaceClientFactory 

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

func NewWfsIfaceClientProtocol 

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

func (*WfsIfaceClient) Append 

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

Parameters:

  • File

func (*WfsIfaceClient) Auth 

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

Parameters:

  • Wa

func (*WfsIfaceClient) Client_ 

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

func (*WfsIfaceClient) Delete 

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

Parameters:

  • Path

func (*WfsIfaceClient) Get 

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

Parameters:

  • Path

func (*WfsIfaceClient) LastResponseMeta_ 

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

func (*WfsIfaceClient) Ping 

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

func (*WfsIfaceClient) Rename 

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

Parameters:

  • Path
  • Newpath_

func (*WfsIfaceClient) SetLastResponseMeta_ 

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

type WfsIfaceDeleteArgs 

type WfsIfaceDeleteArgs struct {
	Path string `thrift:"path,1" db:"path" json:"path"`
}

Attributes:

  • Path

func NewWfsIfaceDeleteArgs 

func NewWfsIfaceDeleteArgs() *WfsIfaceDeleteArgs

func (*WfsIfaceDeleteArgs) GetPath 

func (p *WfsIfaceDeleteArgs) GetPath() string

func (*WfsIfaceDeleteArgs) Read 

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

func (*WfsIfaceDeleteArgs) ReadField1 

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

func (*WfsIfaceDeleteArgs) String 

func (p *WfsIfaceDeleteArgs) String() string

func (*WfsIfaceDeleteArgs) Write 

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

type WfsIfaceDeleteResult 

type WfsIfaceDeleteResult struct {
	Success *WfsAck `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewWfsIfaceDeleteResult 

func NewWfsIfaceDeleteResult() *WfsIfaceDeleteResult

func (*WfsIfaceDeleteResult) GetSuccess 

func (p *WfsIfaceDeleteResult) GetSuccess() *WfsAck

func (*WfsIfaceDeleteResult) IsSetSuccess 

func (p *WfsIfaceDeleteResult) IsSetSuccess() bool

func (*WfsIfaceDeleteResult) Read 

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

func (*WfsIfaceDeleteResult) ReadField0 

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

func (*WfsIfaceDeleteResult) String 

func (p *WfsIfaceDeleteResult) String() string

func (*WfsIfaceDeleteResult) Write 

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

type WfsIfaceGetArgs 

type WfsIfaceGetArgs struct {
	Path string `thrift:"path,1" db:"path" json:"path"`
}

Attributes:

  • Path

func NewWfsIfaceGetArgs 

func NewWfsIfaceGetArgs() *WfsIfaceGetArgs

func (*WfsIfaceGetArgs) GetPath 

func (p *WfsIfaceGetArgs) GetPath() string

func (*WfsIfaceGetArgs) Read 

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

func (*WfsIfaceGetArgs) ReadField1 

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

func (*WfsIfaceGetArgs) String 

func (p *WfsIfaceGetArgs) String() string

func (*WfsIfaceGetArgs) Write 

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

type WfsIfaceGetResult 

type WfsIfaceGetResult struct {
	Success *WfsData `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewWfsIfaceGetResult 

func NewWfsIfaceGetResult() *WfsIfaceGetResult

func (*WfsIfaceGetResult) GetSuccess 

func (p *WfsIfaceGetResult) GetSuccess() *WfsData

func (*WfsIfaceGetResult) IsSetSuccess 

func (p *WfsIfaceGetResult) IsSetSuccess() bool

func (*WfsIfaceGetResult) Read 

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

func (*WfsIfaceGetResult) ReadField0 

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

func (*WfsIfaceGetResult) String 

func (p *WfsIfaceGetResult) String() string

func (*WfsIfaceGetResult) Write 

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

type WfsIfacePingArgs 

type WfsIfacePingArgs struct {
}

func NewWfsIfacePingArgs 

func NewWfsIfacePingArgs() *WfsIfacePingArgs

func (*WfsIfacePingArgs) Read 

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

func (*WfsIfacePingArgs) String 

func (p *WfsIfacePingArgs) String() string

func (*WfsIfacePingArgs) Write 

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

type WfsIfacePingResult 

type WfsIfacePingResult struct {
	Success *int8 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewWfsIfacePingResult 

func NewWfsIfacePingResult() *WfsIfacePingResult

func (*WfsIfacePingResult) GetSuccess 

func (p *WfsIfacePingResult) GetSuccess() int8

func (*WfsIfacePingResult) IsSetSuccess 

func (p *WfsIfacePingResult) IsSetSuccess() bool

func (*WfsIfacePingResult) Read 

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

func (*WfsIfacePingResult) ReadField0 

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

func (*WfsIfacePingResult) String 

func (p *WfsIfacePingResult) String() string

func (*WfsIfacePingResult) Write 

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

type WfsIfaceProcessor 

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

func NewWfsIfaceProcessor 

func NewWfsIfaceProcessor(handler WfsIface) *WfsIfaceProcessor

func (*WfsIfaceProcessor) AddToProcessorMap 

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

func (*WfsIfaceProcessor) GetProcessorFunction 

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

func (*WfsIfaceProcessor) Process 

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

func (*WfsIfaceProcessor) ProcessorMap 

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

type WfsIfaceRenameArgs 

type WfsIfaceRenameArgs struct {
	Path     string `thrift:"path,1" db:"path" json:"path"`
	Newpath_ string `thrift:"newpath,2" db:"newpath" json:"newpath"`
}

Attributes:

  • Path
  • Newpath_

func NewWfsIfaceRenameArgs 

func NewWfsIfaceRenameArgs() *WfsIfaceRenameArgs

func (*WfsIfaceRenameArgs) GetNewpath_ 

func (p *WfsIfaceRenameArgs) GetNewpath_() string

func (*WfsIfaceRenameArgs) GetPath 

func (p *WfsIfaceRenameArgs) GetPath() string

func (*WfsIfaceRenameArgs) Read 

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

func (*WfsIfaceRenameArgs) ReadField1 

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

func (*WfsIfaceRenameArgs) ReadField2 

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

func (*WfsIfaceRenameArgs) String 

func (p *WfsIfaceRenameArgs) String() string

func (*WfsIfaceRenameArgs) Write 

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

type WfsIfaceRenameResult 

type WfsIfaceRenameResult struct {
	Success *WfsAck `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewWfsIfaceRenameResult 

func NewWfsIfaceRenameResult() *WfsIfaceRenameResult

func (*WfsIfaceRenameResult) GetSuccess 

func (p *WfsIfaceRenameResult) GetSuccess() *WfsAck

func (*WfsIfaceRenameResult) IsSetSuccess 

func (p *WfsIfaceRenameResult) IsSetSuccess() bool

func (*WfsIfaceRenameResult) Read 

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

func (*WfsIfaceRenameResult) ReadField0 

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

func (*WfsIfaceRenameResult) String 

func (p *WfsIfaceRenameResult) String() string

func (*WfsIfaceRenameResult) Write 

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

type WfsNodeBean 

type WfsNodeBean struct {
	Rmsize *int64 `protobuf:"varint,1,opt,name=rmsize" json:"rmsize,omitempty"`
	// contains filtered or unexported fields
}

func (*WfsNodeBean) Descriptor deprecated 

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

Deprecated: Use WfsNodeBean.ProtoReflect.Descriptor instead.

func (*WfsNodeBean) GetRmsize 

func (x *WfsNodeBean) GetRmsize() int64

func (*WfsNodeBean) ProtoMessage 

func (*WfsNodeBean) ProtoMessage()

func (*WfsNodeBean) ProtoReflect 

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

func (*WfsNodeBean) Reset 

func (x *WfsNodeBean) Reset()

func (*WfsNodeBean) String 

func (x *WfsNodeBean) String() string

type WfsPathBean 

type WfsPathBean struct {
	Path       *string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
	Timestramp *int64  `protobuf:"varint,2,opt,name=timestramp" json:"timestramp,omitempty"`
	// contains filtered or unexported fields
}

func (*WfsPathBean) Descriptor deprecated 

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

Deprecated: Use WfsPathBean.ProtoReflect.Descriptor instead.

func (*WfsPathBean) GetPath 

func (x *WfsPathBean) GetPath() string

func (*WfsPathBean) GetTimestramp 

func (x *WfsPathBean) GetTimestramp() int64

func (*WfsPathBean) ProtoMessage 

func (*WfsPathBean) ProtoMessage()

func (*WfsPathBean) ProtoReflect 

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

func (*WfsPathBean) Reset 

func (x *WfsPathBean) Reset()

func (*WfsPathBean) String 

func (x *WfsPathBean) String() string

type WfsReq 

type WfsReq struct {
	Path *string `thrift:"path,1" db:"path" json:"path,omitempty"`
}

Attributes:

  • Path

func NewWfsReq 

func NewWfsReq() *WfsReq

func (*WfsReq) Equals 

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

func (*WfsReq) GetPath 

func (p *WfsReq) GetPath() string

func (*WfsReq) IsSetPath 

func (p *WfsReq) IsSetPath() bool

func (*WfsReq) Read 

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

func (*WfsReq) ReadField1 

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

func (*WfsReq) String 

func (p *WfsReq) String() string

func (*WfsReq) Validate 

func (p *WfsReq) Validate() error

func (*WfsReq) Write 

func (p *WfsReq) Write(ctx context.Context, oprot thrift.TProtocol) 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.