Versions in this module Expand all Collapse all v0 v0.2.1 Jul 31, 2023 v0.2.0 Apr 6, 2023 Changes in this version + var CreateBlobResponse_BaseResp_DEFAULT *base.BaseResponse + var GetBlobURLResponse_BaseResp_DEFAULT *base.BaseResponse + var KitexUnusedProtection = struct{} + type BlobService interface + CreateBlob func(ctx context.Context, req *CreateBlobRequest) (r *CreateBlobResponse, err error) + GetBlobURL func(ctx context.Context, req *GetBlobURLRequest) (r *GetBlobURLResponse, err error) + type BlobServiceClient struct + func NewBlobServiceClient(c thrift.TClient) *BlobServiceClient + func NewBlobServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *BlobServiceClient + func NewBlobServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *BlobServiceClient + func (p *BlobServiceClient) Client_() thrift.TClient + func (p *BlobServiceClient) CreateBlob(ctx context.Context, req *CreateBlobRequest) (r *CreateBlobResponse, err error) + func (p *BlobServiceClient) GetBlobURL(ctx context.Context, req *GetBlobURLRequest) (r *GetBlobURLResponse, err error) + type BlobServiceCreateBlobArgs struct + Req *CreateBlobRequest + func NewBlobServiceCreateBlobArgs() *BlobServiceCreateBlobArgs + func (p *BlobServiceCreateBlobArgs) BLength() int + func (p *BlobServiceCreateBlobArgs) DeepEqual(ano *BlobServiceCreateBlobArgs) bool + func (p *BlobServiceCreateBlobArgs) FastRead(buf []byte) (int, error) + func (p *BlobServiceCreateBlobArgs) FastReadField1(buf []byte) (int, error) + func (p *BlobServiceCreateBlobArgs) FastWrite(buf []byte) int + func (p *BlobServiceCreateBlobArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *BlobServiceCreateBlobArgs) Field1DeepEqual(src *CreateBlobRequest) bool + func (p *BlobServiceCreateBlobArgs) GetFirstArgument() interface{} + func (p *BlobServiceCreateBlobArgs) GetReq() (v *CreateBlobRequest) + func (p *BlobServiceCreateBlobArgs) InitDefault() + func (p *BlobServiceCreateBlobArgs) IsSetReq() bool + func (p *BlobServiceCreateBlobArgs) Read(iprot thrift.TProtocol) (err error) + func (p *BlobServiceCreateBlobArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BlobServiceCreateBlobArgs) SetReq(val *CreateBlobRequest) + func (p *BlobServiceCreateBlobArgs) String() string + func (p *BlobServiceCreateBlobArgs) Write(oprot thrift.TProtocol) (err error) + type BlobServiceCreateBlobResult struct + Success *CreateBlobResponse + func NewBlobServiceCreateBlobResult() *BlobServiceCreateBlobResult + func (p *BlobServiceCreateBlobResult) BLength() int + func (p *BlobServiceCreateBlobResult) DeepEqual(ano *BlobServiceCreateBlobResult) bool + func (p *BlobServiceCreateBlobResult) FastRead(buf []byte) (int, error) + func (p *BlobServiceCreateBlobResult) FastReadField0(buf []byte) (int, error) + func (p *BlobServiceCreateBlobResult) FastWrite(buf []byte) int + func (p *BlobServiceCreateBlobResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *BlobServiceCreateBlobResult) Field0DeepEqual(src *CreateBlobResponse) bool + func (p *BlobServiceCreateBlobResult) GetResult() interface{} + func (p *BlobServiceCreateBlobResult) GetSuccess() (v *CreateBlobResponse) + func (p *BlobServiceCreateBlobResult) InitDefault() + func (p *BlobServiceCreateBlobResult) IsSetSuccess() bool + func (p *BlobServiceCreateBlobResult) Read(iprot thrift.TProtocol) (err error) + func (p *BlobServiceCreateBlobResult) ReadField0(iprot thrift.TProtocol) error + func (p *BlobServiceCreateBlobResult) SetSuccess(x interface{}) + func (p *BlobServiceCreateBlobResult) String() string + func (p *BlobServiceCreateBlobResult) Write(oprot thrift.TProtocol) (err error) + type BlobServiceGetBlobURLArgs struct + Req *GetBlobURLRequest + func NewBlobServiceGetBlobURLArgs() *BlobServiceGetBlobURLArgs + func (p *BlobServiceGetBlobURLArgs) BLength() int + func (p *BlobServiceGetBlobURLArgs) DeepEqual(ano *BlobServiceGetBlobURLArgs) bool + func (p *BlobServiceGetBlobURLArgs) FastRead(buf []byte) (int, error) + func (p *BlobServiceGetBlobURLArgs) FastReadField1(buf []byte) (int, error) + func (p *BlobServiceGetBlobURLArgs) FastWrite(buf []byte) int + func (p *BlobServiceGetBlobURLArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *BlobServiceGetBlobURLArgs) Field1DeepEqual(src *GetBlobURLRequest) bool + func (p *BlobServiceGetBlobURLArgs) GetFirstArgument() interface{} + func (p *BlobServiceGetBlobURLArgs) GetReq() (v *GetBlobURLRequest) + func (p *BlobServiceGetBlobURLArgs) InitDefault() + func (p *BlobServiceGetBlobURLArgs) IsSetReq() bool + func (p *BlobServiceGetBlobURLArgs) Read(iprot thrift.TProtocol) (err error) + func (p *BlobServiceGetBlobURLArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BlobServiceGetBlobURLArgs) SetReq(val *GetBlobURLRequest) + func (p *BlobServiceGetBlobURLArgs) String() string + func (p *BlobServiceGetBlobURLArgs) Write(oprot thrift.TProtocol) (err error) + type BlobServiceGetBlobURLResult struct + Success *GetBlobURLResponse + func NewBlobServiceGetBlobURLResult() *BlobServiceGetBlobURLResult + func (p *BlobServiceGetBlobURLResult) BLength() int + func (p *BlobServiceGetBlobURLResult) DeepEqual(ano *BlobServiceGetBlobURLResult) bool + func (p *BlobServiceGetBlobURLResult) FastRead(buf []byte) (int, error) + func (p *BlobServiceGetBlobURLResult) FastReadField0(buf []byte) (int, error) + func (p *BlobServiceGetBlobURLResult) FastWrite(buf []byte) int + func (p *BlobServiceGetBlobURLResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *BlobServiceGetBlobURLResult) Field0DeepEqual(src *GetBlobURLResponse) bool + func (p *BlobServiceGetBlobURLResult) GetResult() interface{} + func (p *BlobServiceGetBlobURLResult) GetSuccess() (v *GetBlobURLResponse) + func (p *BlobServiceGetBlobURLResult) InitDefault() + func (p *BlobServiceGetBlobURLResult) IsSetSuccess() bool + func (p *BlobServiceGetBlobURLResult) Read(iprot thrift.TProtocol) (err error) + func (p *BlobServiceGetBlobURLResult) ReadField0(iprot thrift.TProtocol) error + func (p *BlobServiceGetBlobURLResult) SetSuccess(x interface{}) + func (p *BlobServiceGetBlobURLResult) String() string + func (p *BlobServiceGetBlobURLResult) Write(oprot thrift.TProtocol) (err error) + type BlobServiceProcessor struct + func NewBlobServiceProcessor(handler BlobService) *BlobServiceProcessor + func (p *BlobServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *BlobServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *BlobServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *BlobServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type CreateBlobRequest struct + AccountId int64 + UploadUrlTimeoutSec int32 + var BlobServiceCreateBlobArgs_Req_DEFAULT *CreateBlobRequest + func NewCreateBlobRequest() *CreateBlobRequest + func (p *CreateBlobRequest) BLength() int + func (p *CreateBlobRequest) DeepEqual(ano *CreateBlobRequest) bool + func (p *CreateBlobRequest) FastRead(buf []byte) (int, error) + func (p *CreateBlobRequest) FastReadField1(buf []byte) (int, error) + func (p *CreateBlobRequest) FastReadField2(buf []byte) (int, error) + func (p *CreateBlobRequest) FastWrite(buf []byte) int + func (p *CreateBlobRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *CreateBlobRequest) Field1DeepEqual(src int64) bool + func (p *CreateBlobRequest) Field2DeepEqual(src int32) bool + func (p *CreateBlobRequest) GetAccountId() (v int64) + func (p *CreateBlobRequest) GetUploadUrlTimeoutSec() (v int32) + func (p *CreateBlobRequest) InitDefault() + func (p *CreateBlobRequest) Read(iprot thrift.TProtocol) (err error) + func (p *CreateBlobRequest) ReadField1(iprot thrift.TProtocol) error + func (p *CreateBlobRequest) ReadField2(iprot thrift.TProtocol) error + func (p *CreateBlobRequest) SetAccountId(val int64) + func (p *CreateBlobRequest) SetUploadUrlTimeoutSec(val int32) + func (p *CreateBlobRequest) String() string + func (p *CreateBlobRequest) Write(oprot thrift.TProtocol) (err error) + type CreateBlobResponse struct + BaseResp *base.BaseResponse + Id int64 + UploadUrl string + var BlobServiceCreateBlobResult_Success_DEFAULT *CreateBlobResponse + func NewCreateBlobResponse() *CreateBlobResponse + func (p *CreateBlobResponse) BLength() int + func (p *CreateBlobResponse) DeepEqual(ano *CreateBlobResponse) bool + func (p *CreateBlobResponse) FastRead(buf []byte) (int, error) + func (p *CreateBlobResponse) FastReadField1(buf []byte) (int, error) + func (p *CreateBlobResponse) FastReadField2(buf []byte) (int, error) + func (p *CreateBlobResponse) FastReadField3(buf []byte) (int, error) + func (p *CreateBlobResponse) FastWrite(buf []byte) int + func (p *CreateBlobResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *CreateBlobResponse) Field1DeepEqual(src *base.BaseResponse) bool + func (p *CreateBlobResponse) Field2DeepEqual(src int64) bool + func (p *CreateBlobResponse) Field3DeepEqual(src string) bool + func (p *CreateBlobResponse) GetBaseResp() (v *base.BaseResponse) + func (p *CreateBlobResponse) GetId() (v int64) + func (p *CreateBlobResponse) GetUploadUrl() (v string) + func (p *CreateBlobResponse) InitDefault() + func (p *CreateBlobResponse) IsSetBaseResp() bool + func (p *CreateBlobResponse) Read(iprot thrift.TProtocol) (err error) + func (p *CreateBlobResponse) ReadField1(iprot thrift.TProtocol) error + func (p *CreateBlobResponse) ReadField2(iprot thrift.TProtocol) error + func (p *CreateBlobResponse) ReadField3(iprot thrift.TProtocol) error + func (p *CreateBlobResponse) SetBaseResp(val *base.BaseResponse) + func (p *CreateBlobResponse) SetId(val int64) + func (p *CreateBlobResponse) SetUploadUrl(val string) + func (p *CreateBlobResponse) String() string + func (p *CreateBlobResponse) Write(oprot thrift.TProtocol) (err error) + type GetBlobURLRequest struct + Id int64 + TimeoutSec int32 + var BlobServiceGetBlobURLArgs_Req_DEFAULT *GetBlobURLRequest + func NewGetBlobURLRequest() *GetBlobURLRequest + func (p *GetBlobURLRequest) BLength() int + func (p *GetBlobURLRequest) DeepEqual(ano *GetBlobURLRequest) bool + func (p *GetBlobURLRequest) FastRead(buf []byte) (int, error) + func (p *GetBlobURLRequest) FastReadField1(buf []byte) (int, error) + func (p *GetBlobURLRequest) FastReadField2(buf []byte) (int, error) + func (p *GetBlobURLRequest) FastWrite(buf []byte) int + func (p *GetBlobURLRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *GetBlobURLRequest) Field1DeepEqual(src int64) bool + func (p *GetBlobURLRequest) Field2DeepEqual(src int32) bool + func (p *GetBlobURLRequest) GetId() (v int64) + func (p *GetBlobURLRequest) GetTimeoutSec() (v int32) + func (p *GetBlobURLRequest) InitDefault() + func (p *GetBlobURLRequest) Read(iprot thrift.TProtocol) (err error) + func (p *GetBlobURLRequest) ReadField1(iprot thrift.TProtocol) error + func (p *GetBlobURLRequest) ReadField2(iprot thrift.TProtocol) error + func (p *GetBlobURLRequest) SetId(val int64) + func (p *GetBlobURLRequest) SetTimeoutSec(val int32) + func (p *GetBlobURLRequest) String() string + func (p *GetBlobURLRequest) Write(oprot thrift.TProtocol) (err error) + type GetBlobURLResponse struct + BaseResp *base.BaseResponse + Url string + var BlobServiceGetBlobURLResult_Success_DEFAULT *GetBlobURLResponse + func NewGetBlobURLResponse() *GetBlobURLResponse + func (p *GetBlobURLResponse) BLength() int + func (p *GetBlobURLResponse) DeepEqual(ano *GetBlobURLResponse) bool + func (p *GetBlobURLResponse) FastRead(buf []byte) (int, error) + func (p *GetBlobURLResponse) FastReadField1(buf []byte) (int, error) + func (p *GetBlobURLResponse) FastReadField2(buf []byte) (int, error) + func (p *GetBlobURLResponse) FastWrite(buf []byte) int + func (p *GetBlobURLResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *GetBlobURLResponse) Field1DeepEqual(src *base.BaseResponse) bool + func (p *GetBlobURLResponse) Field2DeepEqual(src string) bool + func (p *GetBlobURLResponse) GetBaseResp() (v *base.BaseResponse) + func (p *GetBlobURLResponse) GetUrl() (v string) + func (p *GetBlobURLResponse) InitDefault() + func (p *GetBlobURLResponse) IsSetBaseResp() bool + func (p *GetBlobURLResponse) Read(iprot thrift.TProtocol) (err error) + func (p *GetBlobURLResponse) ReadField1(iprot thrift.TProtocol) error + func (p *GetBlobURLResponse) ReadField2(iprot thrift.TProtocol) error + func (p *GetBlobURLResponse) SetBaseResp(val *base.BaseResponse) + func (p *GetBlobURLResponse) SetUrl(val string) + func (p *GetBlobURLResponse) String() string + func (p *GetBlobURLResponse) Write(oprot thrift.TProtocol) (err error)
Go to main page