storage

package
v0.0.0-...-a299116 Latest Latest
Warning

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

Go to latest
Published: Oct 15, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var KitexUnusedProtection = struct{}{}

KitexUnusedProtection is used to prevent 'imported and not used' error.

View Source
var StorageServiceCalculateResult_Success_DEFAULT int32

Functions

This section is empty.

Types

type StorageService

type StorageService interface {
	Deduct(ctx context.Context, commodityCode string, count int32) (err error)

	Calculate(ctx context.Context, commodityCode string, count int32) (r int32, err error)
}

type StorageServiceCalculateArgs

type StorageServiceCalculateArgs struct {
	CommodityCode string `thrift:"commodityCode,1" frugal:"1,default,string" json:"commodityCode"`
	Count         int32  `thrift:"count,2" frugal:"2,default,i32" json:"count"`
}

func NewStorageServiceCalculateArgs

func NewStorageServiceCalculateArgs() *StorageServiceCalculateArgs

func (*StorageServiceCalculateArgs) BLength

func (p *StorageServiceCalculateArgs) BLength() int

func (*StorageServiceCalculateArgs) DeepEqual

func (*StorageServiceCalculateArgs) FastRead

func (p *StorageServiceCalculateArgs) FastRead(buf []byte) (int, error)

func (*StorageServiceCalculateArgs) FastReadField1

func (p *StorageServiceCalculateArgs) FastReadField1(buf []byte) (int, error)

func (*StorageServiceCalculateArgs) FastReadField2

func (p *StorageServiceCalculateArgs) FastReadField2(buf []byte) (int, error)

func (*StorageServiceCalculateArgs) FastWrite

func (p *StorageServiceCalculateArgs) FastWrite(buf []byte) int

for compatibility

func (*StorageServiceCalculateArgs) FastWriteNocopy

func (p *StorageServiceCalculateArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*StorageServiceCalculateArgs) Field1DeepEqual

func (p *StorageServiceCalculateArgs) Field1DeepEqual(src string) bool

func (*StorageServiceCalculateArgs) Field2DeepEqual

func (p *StorageServiceCalculateArgs) Field2DeepEqual(src int32) bool

func (*StorageServiceCalculateArgs) GetCommodityCode

func (p *StorageServiceCalculateArgs) GetCommodityCode() (v string)

func (*StorageServiceCalculateArgs) GetCount

func (p *StorageServiceCalculateArgs) GetCount() (v int32)

func (*StorageServiceCalculateArgs) GetFirstArgument

func (p *StorageServiceCalculateArgs) GetFirstArgument() interface{}

func (*StorageServiceCalculateArgs) InitDefault

func (p *StorageServiceCalculateArgs) InitDefault()

func (*StorageServiceCalculateArgs) Read

func (p *StorageServiceCalculateArgs) Read(iprot thrift.TProtocol) (err error)

func (*StorageServiceCalculateArgs) ReadField1

func (p *StorageServiceCalculateArgs) ReadField1(iprot thrift.TProtocol) error

func (*StorageServiceCalculateArgs) ReadField2

func (p *StorageServiceCalculateArgs) ReadField2(iprot thrift.TProtocol) error

func (*StorageServiceCalculateArgs) SetCommodityCode

func (p *StorageServiceCalculateArgs) SetCommodityCode(val string)

func (*StorageServiceCalculateArgs) SetCount

func (p *StorageServiceCalculateArgs) SetCount(val int32)

func (*StorageServiceCalculateArgs) String

func (p *StorageServiceCalculateArgs) String() string

func (*StorageServiceCalculateArgs) Write

func (p *StorageServiceCalculateArgs) Write(oprot thrift.TProtocol) (err error)

type StorageServiceCalculateResult

type StorageServiceCalculateResult struct {
	Success *int32 `thrift:"success,0,optional" frugal:"0,optional,i32" json:"success,omitempty"`
}

func NewStorageServiceCalculateResult

func NewStorageServiceCalculateResult() *StorageServiceCalculateResult

func (*StorageServiceCalculateResult) BLength

func (p *StorageServiceCalculateResult) BLength() int

func (*StorageServiceCalculateResult) DeepEqual

func (*StorageServiceCalculateResult) FastRead

func (p *StorageServiceCalculateResult) FastRead(buf []byte) (int, error)

func (*StorageServiceCalculateResult) FastReadField0

func (p *StorageServiceCalculateResult) FastReadField0(buf []byte) (int, error)

func (*StorageServiceCalculateResult) FastWrite

func (p *StorageServiceCalculateResult) FastWrite(buf []byte) int

for compatibility

func (*StorageServiceCalculateResult) FastWriteNocopy

func (p *StorageServiceCalculateResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*StorageServiceCalculateResult) Field0DeepEqual

func (p *StorageServiceCalculateResult) Field0DeepEqual(src *int32) bool

func (*StorageServiceCalculateResult) GetResult

func (p *StorageServiceCalculateResult) GetResult() interface{}

func (*StorageServiceCalculateResult) GetSuccess

func (p *StorageServiceCalculateResult) GetSuccess() (v int32)

func (*StorageServiceCalculateResult) InitDefault

func (p *StorageServiceCalculateResult) InitDefault()

func (*StorageServiceCalculateResult) IsSetSuccess

func (p *StorageServiceCalculateResult) IsSetSuccess() bool

func (*StorageServiceCalculateResult) Read

func (p *StorageServiceCalculateResult) Read(iprot thrift.TProtocol) (err error)

func (*StorageServiceCalculateResult) ReadField0

func (p *StorageServiceCalculateResult) ReadField0(iprot thrift.TProtocol) error

func (*StorageServiceCalculateResult) SetSuccess

func (p *StorageServiceCalculateResult) SetSuccess(x interface{})

func (*StorageServiceCalculateResult) String

func (*StorageServiceCalculateResult) Write

func (p *StorageServiceCalculateResult) Write(oprot thrift.TProtocol) (err error)

type StorageServiceClient

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

func NewStorageServiceClient

func NewStorageServiceClient(c thrift.TClient) *StorageServiceClient

func NewStorageServiceClientProtocol

func NewStorageServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *StorageServiceClient

func (*StorageServiceClient) Calculate

func (p *StorageServiceClient) Calculate(ctx context.Context, commodityCode string, count int32) (r int32, err error)

func (*StorageServiceClient) Client_

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

func (*StorageServiceClient) Deduct

func (p *StorageServiceClient) Deduct(ctx context.Context, commodityCode string, count int32) (err error)

type StorageServiceDeductArgs

type StorageServiceDeductArgs struct {
	CommodityCode string `thrift:"commodityCode,1" frugal:"1,default,string" json:"commodityCode"`
	Count         int32  `thrift:"count,2" frugal:"2,default,i32" json:"count"`
}

func NewStorageServiceDeductArgs

func NewStorageServiceDeductArgs() *StorageServiceDeductArgs

func (*StorageServiceDeductArgs) BLength

func (p *StorageServiceDeductArgs) BLength() int

func (*StorageServiceDeductArgs) DeepEqual

func (*StorageServiceDeductArgs) FastRead

func (p *StorageServiceDeductArgs) FastRead(buf []byte) (int, error)

func (*StorageServiceDeductArgs) FastReadField1

func (p *StorageServiceDeductArgs) FastReadField1(buf []byte) (int, error)

func (*StorageServiceDeductArgs) FastReadField2

func (p *StorageServiceDeductArgs) FastReadField2(buf []byte) (int, error)

func (*StorageServiceDeductArgs) FastWrite

func (p *StorageServiceDeductArgs) FastWrite(buf []byte) int

for compatibility

func (*StorageServiceDeductArgs) FastWriteNocopy

func (p *StorageServiceDeductArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*StorageServiceDeductArgs) Field1DeepEqual

func (p *StorageServiceDeductArgs) Field1DeepEqual(src string) bool

func (*StorageServiceDeductArgs) Field2DeepEqual

func (p *StorageServiceDeductArgs) Field2DeepEqual(src int32) bool

func (*StorageServiceDeductArgs) GetCommodityCode

func (p *StorageServiceDeductArgs) GetCommodityCode() (v string)

func (*StorageServiceDeductArgs) GetCount

func (p *StorageServiceDeductArgs) GetCount() (v int32)

func (*StorageServiceDeductArgs) GetFirstArgument

func (p *StorageServiceDeductArgs) GetFirstArgument() interface{}

func (*StorageServiceDeductArgs) InitDefault

func (p *StorageServiceDeductArgs) InitDefault()

func (*StorageServiceDeductArgs) Read

func (p *StorageServiceDeductArgs) Read(iprot thrift.TProtocol) (err error)

func (*StorageServiceDeductArgs) ReadField1

func (p *StorageServiceDeductArgs) ReadField1(iprot thrift.TProtocol) error

func (*StorageServiceDeductArgs) ReadField2

func (p *StorageServiceDeductArgs) ReadField2(iprot thrift.TProtocol) error

func (*StorageServiceDeductArgs) SetCommodityCode

func (p *StorageServiceDeductArgs) SetCommodityCode(val string)

func (*StorageServiceDeductArgs) SetCount

func (p *StorageServiceDeductArgs) SetCount(val int32)

func (*StorageServiceDeductArgs) String

func (p *StorageServiceDeductArgs) String() string

func (*StorageServiceDeductArgs) Write

func (p *StorageServiceDeductArgs) Write(oprot thrift.TProtocol) (err error)

type StorageServiceDeductResult

type StorageServiceDeductResult struct {
}

func NewStorageServiceDeductResult

func NewStorageServiceDeductResult() *StorageServiceDeductResult

func (*StorageServiceDeductResult) BLength

func (p *StorageServiceDeductResult) BLength() int

func (*StorageServiceDeductResult) DeepEqual

func (*StorageServiceDeductResult) FastRead

func (p *StorageServiceDeductResult) FastRead(buf []byte) (int, error)

func (*StorageServiceDeductResult) FastWrite

func (p *StorageServiceDeductResult) FastWrite(buf []byte) int

for compatibility

func (*StorageServiceDeductResult) FastWriteNocopy

func (p *StorageServiceDeductResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*StorageServiceDeductResult) GetResult

func (p *StorageServiceDeductResult) GetResult() interface{}

func (*StorageServiceDeductResult) InitDefault

func (p *StorageServiceDeductResult) InitDefault()

func (*StorageServiceDeductResult) Read

func (p *StorageServiceDeductResult) Read(iprot thrift.TProtocol) (err error)

func (*StorageServiceDeductResult) String

func (p *StorageServiceDeductResult) String() string

func (*StorageServiceDeductResult) Write

func (p *StorageServiceDeductResult) Write(oprot thrift.TProtocol) (err error)

type StorageServiceProcessor

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

func NewStorageServiceProcessor

func NewStorageServiceProcessor(handler StorageService) *StorageServiceProcessor

func (*StorageServiceProcessor) AddToProcessorMap

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

func (*StorageServiceProcessor) GetProcessorFunction

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

func (*StorageServiceProcessor) Process

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

func (*StorageServiceProcessor) ProcessorMap

Directories

Path Synopsis
Code generated by Kitex v0.9.1.
Code generated by Kitex v0.9.1.

Jump to

Keyboard shortcuts

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