Versions in this module Expand all Collapse all v0 v0.1.1 Nov 7, 2020 v0.1.0 Nov 7, 2020 Changes in this version + var GoUnusedProtection__ int + var KVStepCounterServiceCreateGeneratorResult_Success_DEFAULT int32 + var KVStepCounterServiceGetCurrentValueResult_Success_DEFAULT int64 + var KVStepCounterServiceGetStepValueResult_Success_DEFAULT int64 + var KVStepCounterServiceGetValueResult_Success_DEFAULT int64 + var KVStepCounterServiceRemoveGeneratorResult_Success_DEFAULT int32 + type InvalidOperation struct + ErrorCode int32 + Message string + func NewInvalidOperation() *InvalidOperation + func (p *InvalidOperation) Error() string + func (p *InvalidOperation) GetErrorCode() int32 + func (p *InvalidOperation) GetMessage() string + func (p *InvalidOperation) Read(iprot thrift.TProtocol) error + func (p *InvalidOperation) ReadField1(iprot thrift.TProtocol) error + func (p *InvalidOperation) ReadField2(iprot thrift.TProtocol) error + func (p *InvalidOperation) String() string + func (p *InvalidOperation) Write(oprot thrift.TProtocol) error + type KVStepCounterService interface + CreateGenerator func(ctx context.Context, genName string) (r int32, err error) + GetCurrentValue func(ctx context.Context, genName string) (r int64, err error) + GetData func(ctx context.Context, key TKey) (r *TDataResult_, err error) + GetStepValue func(ctx context.Context, genName string, step int64) (r int64, err error) + GetValue func(ctx context.Context, genName string) (r int64, err error) + PutData func(ctx context.Context, data *TKVCounter) (r TErrorCode, err error) + RemoveGenerator func(ctx context.Context, genName string) (r int32, err error) + type KVStepCounterServiceClient struct + func NewKVStepCounterServiceClient(c thrift.TClient) *KVStepCounterServiceClient + func NewKVStepCounterServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *KVStepCounterServiceClient + func NewKVStepCounterServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *KVStepCounterServiceClient + func (p *KVStepCounterServiceClient) Client_() thrift.TClient + func (p *KVStepCounterServiceClient) CreateGenerator(ctx context.Context, genName string) (r int32, err error) + func (p *KVStepCounterServiceClient) GetCurrentValue(ctx context.Context, genName string) (r int64, err error) + func (p *KVStepCounterServiceClient) GetData(ctx context.Context, key TKey) (r *TDataResult_, err error) + func (p *KVStepCounterServiceClient) GetStepValue(ctx context.Context, genName string, step int64) (r int64, err error) + func (p *KVStepCounterServiceClient) GetValue(ctx context.Context, genName string) (r int64, err error) + func (p *KVStepCounterServiceClient) PutData(ctx context.Context, data *TKVCounter) (r TErrorCode, err error) + func (p *KVStepCounterServiceClient) RemoveGenerator(ctx context.Context, genName string) (r int32, err error) + type KVStepCounterServiceCreateGeneratorArgs struct + GenName string + func NewKVStepCounterServiceCreateGeneratorArgs() *KVStepCounterServiceCreateGeneratorArgs + func (p *KVStepCounterServiceCreateGeneratorArgs) GetGenName() string + func (p *KVStepCounterServiceCreateGeneratorArgs) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceCreateGeneratorArgs) ReadField1(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceCreateGeneratorArgs) String() string + func (p *KVStepCounterServiceCreateGeneratorArgs) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceCreateGeneratorResult struct + Success *int32 + func NewKVStepCounterServiceCreateGeneratorResult() *KVStepCounterServiceCreateGeneratorResult + func (p *KVStepCounterServiceCreateGeneratorResult) GetSuccess() int32 + func (p *KVStepCounterServiceCreateGeneratorResult) IsSetSuccess() bool + func (p *KVStepCounterServiceCreateGeneratorResult) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceCreateGeneratorResult) ReadField0(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceCreateGeneratorResult) String() string + func (p *KVStepCounterServiceCreateGeneratorResult) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceGetCurrentValueArgs struct + GenName string + func NewKVStepCounterServiceGetCurrentValueArgs() *KVStepCounterServiceGetCurrentValueArgs + func (p *KVStepCounterServiceGetCurrentValueArgs) GetGenName() string + func (p *KVStepCounterServiceGetCurrentValueArgs) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetCurrentValueArgs) ReadField1(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetCurrentValueArgs) String() string + func (p *KVStepCounterServiceGetCurrentValueArgs) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceGetCurrentValueResult struct + Success *int64 + func NewKVStepCounterServiceGetCurrentValueResult() *KVStepCounterServiceGetCurrentValueResult + func (p *KVStepCounterServiceGetCurrentValueResult) GetSuccess() int64 + func (p *KVStepCounterServiceGetCurrentValueResult) IsSetSuccess() bool + func (p *KVStepCounterServiceGetCurrentValueResult) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetCurrentValueResult) ReadField0(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetCurrentValueResult) String() string + func (p *KVStepCounterServiceGetCurrentValueResult) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceGetDataArgs struct + Key TKey + func NewKVStepCounterServiceGetDataArgs() *KVStepCounterServiceGetDataArgs + func (p *KVStepCounterServiceGetDataArgs) GetKey() TKey + func (p *KVStepCounterServiceGetDataArgs) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetDataArgs) ReadField1(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetDataArgs) String() string + func (p *KVStepCounterServiceGetDataArgs) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceGetDataResult struct + Success *TDataResult_ + func NewKVStepCounterServiceGetDataResult() *KVStepCounterServiceGetDataResult + func (p *KVStepCounterServiceGetDataResult) GetSuccess() *TDataResult_ + func (p *KVStepCounterServiceGetDataResult) IsSetSuccess() bool + func (p *KVStepCounterServiceGetDataResult) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetDataResult) ReadField0(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetDataResult) String() string + func (p *KVStepCounterServiceGetDataResult) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceGetStepValueArgs struct + GenName string + Step int64 + func NewKVStepCounterServiceGetStepValueArgs() *KVStepCounterServiceGetStepValueArgs + func (p *KVStepCounterServiceGetStepValueArgs) GetGenName() string + func (p *KVStepCounterServiceGetStepValueArgs) GetStep() int64 + func (p *KVStepCounterServiceGetStepValueArgs) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetStepValueArgs) ReadField1(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetStepValueArgs) ReadField2(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetStepValueArgs) String() string + func (p *KVStepCounterServiceGetStepValueArgs) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceGetStepValueResult struct + Success *int64 + func NewKVStepCounterServiceGetStepValueResult() *KVStepCounterServiceGetStepValueResult + func (p *KVStepCounterServiceGetStepValueResult) GetSuccess() int64 + func (p *KVStepCounterServiceGetStepValueResult) IsSetSuccess() bool + func (p *KVStepCounterServiceGetStepValueResult) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetStepValueResult) ReadField0(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetStepValueResult) String() string + func (p *KVStepCounterServiceGetStepValueResult) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceGetValueArgs struct + GenName string + func NewKVStepCounterServiceGetValueArgs() *KVStepCounterServiceGetValueArgs + func (p *KVStepCounterServiceGetValueArgs) GetGenName() string + func (p *KVStepCounterServiceGetValueArgs) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetValueArgs) ReadField1(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetValueArgs) String() string + func (p *KVStepCounterServiceGetValueArgs) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceGetValueResult struct + Success *int64 + func NewKVStepCounterServiceGetValueResult() *KVStepCounterServiceGetValueResult + func (p *KVStepCounterServiceGetValueResult) GetSuccess() int64 + func (p *KVStepCounterServiceGetValueResult) IsSetSuccess() bool + func (p *KVStepCounterServiceGetValueResult) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetValueResult) ReadField0(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceGetValueResult) String() string + func (p *KVStepCounterServiceGetValueResult) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceProcessor struct + func NewKVStepCounterServiceProcessor(handler KVStepCounterService) *KVStepCounterServiceProcessor + func (p *KVStepCounterServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *KVStepCounterServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *KVStepCounterServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *KVStepCounterServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type KVStepCounterServicePutDataArgs struct + Data *TKVCounter + func NewKVStepCounterServicePutDataArgs() *KVStepCounterServicePutDataArgs + func (p *KVStepCounterServicePutDataArgs) GetData() *TKVCounter + func (p *KVStepCounterServicePutDataArgs) IsSetData() bool + func (p *KVStepCounterServicePutDataArgs) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServicePutDataArgs) ReadField1(iprot thrift.TProtocol) error + func (p *KVStepCounterServicePutDataArgs) String() string + func (p *KVStepCounterServicePutDataArgs) Write(oprot thrift.TProtocol) error + type KVStepCounterServicePutDataResult struct + Success *TErrorCode + func NewKVStepCounterServicePutDataResult() *KVStepCounterServicePutDataResult + func (p *KVStepCounterServicePutDataResult) GetSuccess() TErrorCode + func (p *KVStepCounterServicePutDataResult) IsSetSuccess() bool + func (p *KVStepCounterServicePutDataResult) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServicePutDataResult) ReadField0(iprot thrift.TProtocol) error + func (p *KVStepCounterServicePutDataResult) String() string + func (p *KVStepCounterServicePutDataResult) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceRemoveGeneratorArgs struct + GenName string + func NewKVStepCounterServiceRemoveGeneratorArgs() *KVStepCounterServiceRemoveGeneratorArgs + func (p *KVStepCounterServiceRemoveGeneratorArgs) GetGenName() string + func (p *KVStepCounterServiceRemoveGeneratorArgs) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceRemoveGeneratorArgs) ReadField1(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceRemoveGeneratorArgs) String() string + func (p *KVStepCounterServiceRemoveGeneratorArgs) Write(oprot thrift.TProtocol) error + type KVStepCounterServiceRemoveGeneratorResult struct + Success *int32 + func NewKVStepCounterServiceRemoveGeneratorResult() *KVStepCounterServiceRemoveGeneratorResult + func (p *KVStepCounterServiceRemoveGeneratorResult) GetSuccess() int32 + func (p *KVStepCounterServiceRemoveGeneratorResult) IsSetSuccess() bool + func (p *KVStepCounterServiceRemoveGeneratorResult) Read(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceRemoveGeneratorResult) ReadField0(iprot thrift.TProtocol) error + func (p *KVStepCounterServiceRemoveGeneratorResult) String() string + func (p *KVStepCounterServiceRemoveGeneratorResult) Write(oprot thrift.TProtocol) error + type TData *TKVCounter + func TDataPtr(v TData) *TData + type TDataResult_ struct + Data *TKVCounter + ErrorCode TErrorCode + var KVStepCounterServiceGetDataResult_Success_DEFAULT *TDataResult_ + var TDataServiceGetDataResult_Success_DEFAULT *TDataResult_ + var TDataServiceRGetDataResult_Success_DEFAULT *TDataResult_ + func NewTDataResult_() *TDataResult_ + func (p *TDataResult_) GetData() *TKVCounter + func (p *TDataResult_) GetErrorCode() TErrorCode + func (p *TDataResult_) IsSetData() bool + func (p *TDataResult_) Read(iprot thrift.TProtocol) error + func (p *TDataResult_) ReadField1(iprot thrift.TProtocol) error + func (p *TDataResult_) ReadField2(iprot thrift.TProtocol) error + func (p *TDataResult_) String() string + func (p *TDataResult_) Write(oprot thrift.TProtocol) error + type TDataService interface + GetData func(ctx context.Context, key TKey) (r *TDataResult_, err error) + PutData func(ctx context.Context, data *TKVCounter) (r TErrorCode, err error) + type TDataServiceClient struct + func NewTDataServiceClient(c thrift.TClient) *TDataServiceClient + func NewTDataServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TDataServiceClient + func NewTDataServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TDataServiceClient + func (p *TDataServiceClient) Client_() thrift.TClient + func (p *TDataServiceClient) GetData(ctx context.Context, key TKey) (r *TDataResult_, err error) + func (p *TDataServiceClient) PutData(ctx context.Context, data *TKVCounter) (r TErrorCode, err error) + type TDataServiceGetDataArgs struct + Key TKey + func NewTDataServiceGetDataArgs() *TDataServiceGetDataArgs + func (p *TDataServiceGetDataArgs) GetKey() TKey + func (p *TDataServiceGetDataArgs) Read(iprot thrift.TProtocol) error + func (p *TDataServiceGetDataArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TDataServiceGetDataArgs) String() string + func (p *TDataServiceGetDataArgs) Write(oprot thrift.TProtocol) error + type TDataServiceGetDataResult struct + Success *TDataResult_ + func NewTDataServiceGetDataResult() *TDataServiceGetDataResult + func (p *TDataServiceGetDataResult) GetSuccess() *TDataResult_ + func (p *TDataServiceGetDataResult) IsSetSuccess() bool + func (p *TDataServiceGetDataResult) Read(iprot thrift.TProtocol) error + func (p *TDataServiceGetDataResult) ReadField0(iprot thrift.TProtocol) error + func (p *TDataServiceGetDataResult) String() string + func (p *TDataServiceGetDataResult) Write(oprot thrift.TProtocol) error + type TDataServiceProcessor struct + func NewTDataServiceProcessor(handler TDataService) *TDataServiceProcessor + func (p *TDataServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *TDataServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *TDataServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *TDataServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type TDataServicePutDataArgs struct + Data *TKVCounter + func NewTDataServicePutDataArgs() *TDataServicePutDataArgs + func (p *TDataServicePutDataArgs) GetData() *TKVCounter + func (p *TDataServicePutDataArgs) IsSetData() bool + func (p *TDataServicePutDataArgs) Read(iprot thrift.TProtocol) error + func (p *TDataServicePutDataArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TDataServicePutDataArgs) String() string + func (p *TDataServicePutDataArgs) Write(oprot thrift.TProtocol) error + type TDataServicePutDataResult struct + Success *TErrorCode + func NewTDataServicePutDataResult() *TDataServicePutDataResult + func (p *TDataServicePutDataResult) GetSuccess() TErrorCode + func (p *TDataServicePutDataResult) IsSetSuccess() bool + func (p *TDataServicePutDataResult) Read(iprot thrift.TProtocol) error + func (p *TDataServicePutDataResult) ReadField0(iprot thrift.TProtocol) error + func (p *TDataServicePutDataResult) String() string + func (p *TDataServicePutDataResult) Write(oprot thrift.TProtocol) error + type TDataServiceR interface + GetData func(ctx context.Context, key TKey) (r *TDataResult_, err error) + type TDataServiceRClient struct + func NewTDataServiceRClient(c thrift.TClient) *TDataServiceRClient + func NewTDataServiceRClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TDataServiceRClient + func NewTDataServiceRClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TDataServiceRClient + func (p *TDataServiceRClient) Client_() thrift.TClient + func (p *TDataServiceRClient) GetData(ctx context.Context, key TKey) (r *TDataResult_, err error) + type TDataServiceRGetDataArgs struct + Key TKey + func NewTDataServiceRGetDataArgs() *TDataServiceRGetDataArgs + func (p *TDataServiceRGetDataArgs) GetKey() TKey + func (p *TDataServiceRGetDataArgs) Read(iprot thrift.TProtocol) error + func (p *TDataServiceRGetDataArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TDataServiceRGetDataArgs) String() string + func (p *TDataServiceRGetDataArgs) Write(oprot thrift.TProtocol) error + type TDataServiceRGetDataResult struct + Success *TDataResult_ + func NewTDataServiceRGetDataResult() *TDataServiceRGetDataResult + func (p *TDataServiceRGetDataResult) GetSuccess() *TDataResult_ + func (p *TDataServiceRGetDataResult) IsSetSuccess() bool + func (p *TDataServiceRGetDataResult) Read(iprot thrift.TProtocol) error + func (p *TDataServiceRGetDataResult) ReadField0(iprot thrift.TProtocol) error + func (p *TDataServiceRGetDataResult) String() string + func (p *TDataServiceRGetDataResult) Write(oprot thrift.TProtocol) error + type TDataServiceRProcessor struct + func NewTDataServiceRProcessor(handler TDataServiceR) *TDataServiceRProcessor + func (p *TDataServiceRProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *TDataServiceRProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *TDataServiceRProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *TDataServiceRProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type TErrorCode int64 + const TErrorCode_EDataExisted + const TErrorCode_EGood + const TErrorCode_ENotFound + const TErrorCode_EUnknown + var KVStepCounterServicePutDataResult_Success_DEFAULT TErrorCode + var TDataServicePutDataResult_Success_DEFAULT TErrorCode + func TErrorCodeFromString(s string) (TErrorCode, error) + func TErrorCodePtr(v TErrorCode) *TErrorCode + func (p *TErrorCode) Scan(value interface{}) error + func (p *TErrorCode) UnmarshalText(text []byte) error + func (p *TErrorCode) Value() (driver.Value, error) + func (p TErrorCode) MarshalText() ([]byte, error) + func (p TErrorCode) String() string + type TKVCounter struct + Cid TKey + Value int64 + var KVStepCounterServicePutDataArgs_Data_DEFAULT *TKVCounter + var TDataResult__Data_DEFAULT *TKVCounter + var TDataServicePutDataArgs_Data_DEFAULT *TKVCounter + func NewTKVCounter() *TKVCounter + func (p *TKVCounter) GetCid() TKey + func (p *TKVCounter) GetValue() int64 + func (p *TKVCounter) Read(iprot thrift.TProtocol) error + func (p *TKVCounter) ReadField1(iprot thrift.TProtocol) error + func (p *TKVCounter) ReadField2(iprot thrift.TProtocol) error + func (p *TKVCounter) String() string + func (p *TKVCounter) Write(oprot thrift.TProtocol) error + type TKey string + func TKeyPtr(v TKey) *TKey
Go to main page