KVStepCounter

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2020 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var KVStepCounterServiceCreateGeneratorResult_Success_DEFAULT int32
View Source 
var KVStepCounterServiceGetCurrentValueResult_Success_DEFAULT int64
View Source 
var KVStepCounterServiceGetStepValueResult_Success_DEFAULT int64
View Source 
var KVStepCounterServiceGetValueResult_Success_DEFAULT int64
View Source 
var KVStepCounterServiceRemoveGeneratorResult_Success_DEFAULT int32

Functions

This section is empty.

Types

type InvalidOperation 

type InvalidOperation struct {
	ErrorCode int32  `thrift:"errorCode,1" db:"errorCode" json:"errorCode"`
	Message   string `thrift:"message,2" db:"message" json:"message"`
}

Attributes:

  • ErrorCode
  • Message

func NewInvalidOperation 

func NewInvalidOperation() *InvalidOperation

func (*InvalidOperation) Error 

func (p *InvalidOperation) Error() string

func (*InvalidOperation) GetErrorCode 

func (p *InvalidOperation) GetErrorCode() int32

func (*InvalidOperation) GetMessage 

func (p *InvalidOperation) GetMessage() string

func (*InvalidOperation) Read 

func (p *InvalidOperation) Read(iprot thrift.TProtocol) error

func (*InvalidOperation) ReadField1 

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

func (*InvalidOperation) ReadField2 

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

func (*InvalidOperation) String 

func (p *InvalidOperation) String() string

func (*InvalidOperation) Write 

func (p *InvalidOperation) Write(oprot thrift.TProtocol) error

type KVStepCounterService 

type KVStepCounterService interface {
	// Parameters:
	//  - Key
	GetData(ctx context.Context, key TKey) (r *TDataResult_, err error)
	// Parameters:
	//  - Data
	PutData(ctx context.Context, data *TKVCounter) (r TErrorCode, err error)
	// Parameters:
	//  - GenName
	CreateGenerator(ctx context.Context, genName string) (r int32, err error)
	// Parameters:
	//  - GenName
	RemoveGenerator(ctx context.Context, genName string) (r int32, err error)
	// Parameters:
	//  - GenName
	GetCurrentValue(ctx context.Context, genName string) (r int64, err error)
	// Parameters:
	//  - GenName
	GetValue(ctx context.Context, genName string) (r int64, err error)
	// Parameters:
	//  - GenName
	//  - Step
	GetStepValue(ctx context.Context, genName string, step int64) (r int64, err error)
}

type KVStepCounterServiceClient 

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

func NewKVStepCounterServiceClient 

func NewKVStepCounterServiceClient(c thrift.TClient) *KVStepCounterServiceClient

func NewKVStepCounterServiceClientFactory 

func NewKVStepCounterServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *KVStepCounterServiceClient

func NewKVStepCounterServiceClientProtocol 

func NewKVStepCounterServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *KVStepCounterServiceClient

func (*KVStepCounterServiceClient) Client_ 

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

func (*KVStepCounterServiceClient) CreateGenerator 

func (p *KVStepCounterServiceClient) CreateGenerator(ctx context.Context, genName string) (r int32, err error)

Parameters:

  • GenName

func (*KVStepCounterServiceClient) GetCurrentValue 

func (p *KVStepCounterServiceClient) GetCurrentValue(ctx context.Context, genName string) (r int64, err error)

Parameters:

  • GenName

func (*KVStepCounterServiceClient) GetData 

func (p *KVStepCounterServiceClient) GetData(ctx context.Context, key TKey) (r *TDataResult_, err error)

Parameters:

  • Key

func (*KVStepCounterServiceClient) GetStepValue 

func (p *KVStepCounterServiceClient) GetStepValue(ctx context.Context, genName string, step int64) (r int64, err error)

Parameters:

  • GenName
  • Step

func (*KVStepCounterServiceClient) GetValue 

func (p *KVStepCounterServiceClient) GetValue(ctx context.Context, genName string) (r int64, err error)

Parameters:

  • GenName

func (*KVStepCounterServiceClient) PutData 

func (p *KVStepCounterServiceClient) PutData(ctx context.Context, data *TKVCounter) (r TErrorCode, err error)

Parameters:

  • Data

func (*KVStepCounterServiceClient) RemoveGenerator 

func (p *KVStepCounterServiceClient) RemoveGenerator(ctx context.Context, genName string) (r int32, err error)

Parameters:

  • GenName

type KVStepCounterServiceCreateGeneratorArgs 

type KVStepCounterServiceCreateGeneratorArgs struct {
	GenName string `thrift:"genName,1" db:"genName" json:"genName"`
}

Attributes:

  • GenName

func NewKVStepCounterServiceCreateGeneratorArgs 

func NewKVStepCounterServiceCreateGeneratorArgs() *KVStepCounterServiceCreateGeneratorArgs

func (*KVStepCounterServiceCreateGeneratorArgs) GetGenName 

func (p *KVStepCounterServiceCreateGeneratorArgs) GetGenName() string

func (*KVStepCounterServiceCreateGeneratorArgs) Read 

func (p *KVStepCounterServiceCreateGeneratorArgs) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceCreateGeneratorArgs) ReadField1 

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

func (*KVStepCounterServiceCreateGeneratorArgs) String 

func (p *KVStepCounterServiceCreateGeneratorArgs) String() string

func (*KVStepCounterServiceCreateGeneratorArgs) Write 

func (p *KVStepCounterServiceCreateGeneratorArgs) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceCreateGeneratorResult 

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

Attributes:

  • Success

func NewKVStepCounterServiceCreateGeneratorResult 

func NewKVStepCounterServiceCreateGeneratorResult() *KVStepCounterServiceCreateGeneratorResult

func (*KVStepCounterServiceCreateGeneratorResult) GetSuccess 

func (p *KVStepCounterServiceCreateGeneratorResult) GetSuccess() int32

func (*KVStepCounterServiceCreateGeneratorResult) IsSetSuccess 

func (p *KVStepCounterServiceCreateGeneratorResult) IsSetSuccess() bool

func (*KVStepCounterServiceCreateGeneratorResult) Read 

func (p *KVStepCounterServiceCreateGeneratorResult) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceCreateGeneratorResult) ReadField0 

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

func (*KVStepCounterServiceCreateGeneratorResult) String 

func (p *KVStepCounterServiceCreateGeneratorResult) String() string

func (*KVStepCounterServiceCreateGeneratorResult) Write 

func (p *KVStepCounterServiceCreateGeneratorResult) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceGetCurrentValueArgs 

type KVStepCounterServiceGetCurrentValueArgs struct {
	GenName string `thrift:"genName,1" db:"genName" json:"genName"`
}

Attributes:

  • GenName

func NewKVStepCounterServiceGetCurrentValueArgs 

func NewKVStepCounterServiceGetCurrentValueArgs() *KVStepCounterServiceGetCurrentValueArgs

func (*KVStepCounterServiceGetCurrentValueArgs) GetGenName 

func (p *KVStepCounterServiceGetCurrentValueArgs) GetGenName() string

func (*KVStepCounterServiceGetCurrentValueArgs) Read 

func (p *KVStepCounterServiceGetCurrentValueArgs) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceGetCurrentValueArgs) ReadField1 

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

func (*KVStepCounterServiceGetCurrentValueArgs) String 

func (p *KVStepCounterServiceGetCurrentValueArgs) String() string

func (*KVStepCounterServiceGetCurrentValueArgs) Write 

func (p *KVStepCounterServiceGetCurrentValueArgs) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceGetCurrentValueResult 

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

Attributes:

  • Success

func NewKVStepCounterServiceGetCurrentValueResult 

func NewKVStepCounterServiceGetCurrentValueResult() *KVStepCounterServiceGetCurrentValueResult

func (*KVStepCounterServiceGetCurrentValueResult) GetSuccess 

func (p *KVStepCounterServiceGetCurrentValueResult) GetSuccess() int64

func (*KVStepCounterServiceGetCurrentValueResult) IsSetSuccess 

func (p *KVStepCounterServiceGetCurrentValueResult) IsSetSuccess() bool

func (*KVStepCounterServiceGetCurrentValueResult) Read 

func (p *KVStepCounterServiceGetCurrentValueResult) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceGetCurrentValueResult) ReadField0 

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

func (*KVStepCounterServiceGetCurrentValueResult) String 

func (p *KVStepCounterServiceGetCurrentValueResult) String() string

func (*KVStepCounterServiceGetCurrentValueResult) Write 

func (p *KVStepCounterServiceGetCurrentValueResult) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceGetDataArgs 

type KVStepCounterServiceGetDataArgs struct {
	Key TKey `thrift:"key,1" db:"key" json:"key"`
}

Attributes:

  • Key

func NewKVStepCounterServiceGetDataArgs 

func NewKVStepCounterServiceGetDataArgs() *KVStepCounterServiceGetDataArgs

func (*KVStepCounterServiceGetDataArgs) GetKey 

func (p *KVStepCounterServiceGetDataArgs) GetKey() TKey

func (*KVStepCounterServiceGetDataArgs) Read 

func (p *KVStepCounterServiceGetDataArgs) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceGetDataArgs) ReadField1 

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

func (*KVStepCounterServiceGetDataArgs) String 

func (p *KVStepCounterServiceGetDataArgs) String() string

func (*KVStepCounterServiceGetDataArgs) Write 

func (p *KVStepCounterServiceGetDataArgs) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceGetDataResult 

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

Attributes:

  • Success

func NewKVStepCounterServiceGetDataResult 

func NewKVStepCounterServiceGetDataResult() *KVStepCounterServiceGetDataResult

func (*KVStepCounterServiceGetDataResult) GetSuccess 

func (p *KVStepCounterServiceGetDataResult) GetSuccess() *TDataResult_

func (*KVStepCounterServiceGetDataResult) IsSetSuccess 

func (p *KVStepCounterServiceGetDataResult) IsSetSuccess() bool

func (*KVStepCounterServiceGetDataResult) Read 

func (p *KVStepCounterServiceGetDataResult) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceGetDataResult) ReadField0 

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

func (*KVStepCounterServiceGetDataResult) String 

func (p *KVStepCounterServiceGetDataResult) String() string

func (*KVStepCounterServiceGetDataResult) Write 

func (p *KVStepCounterServiceGetDataResult) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceGetStepValueArgs 

type KVStepCounterServiceGetStepValueArgs struct {
	GenName string `thrift:"genName,1" db:"genName" json:"genName"`
	Step    int64  `thrift:"step,2" db:"step" json:"step"`
}

Attributes:

  • GenName
  • Step

func NewKVStepCounterServiceGetStepValueArgs 

func NewKVStepCounterServiceGetStepValueArgs() *KVStepCounterServiceGetStepValueArgs

func (*KVStepCounterServiceGetStepValueArgs) GetGenName 

func (p *KVStepCounterServiceGetStepValueArgs) GetGenName() string

func (*KVStepCounterServiceGetStepValueArgs) GetStep 

func (p *KVStepCounterServiceGetStepValueArgs) GetStep() int64

func (*KVStepCounterServiceGetStepValueArgs) Read 

func (p *KVStepCounterServiceGetStepValueArgs) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceGetStepValueArgs) ReadField1 

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

func (*KVStepCounterServiceGetStepValueArgs) ReadField2 

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

func (*KVStepCounterServiceGetStepValueArgs) String 

func (p *KVStepCounterServiceGetStepValueArgs) String() string

func (*KVStepCounterServiceGetStepValueArgs) Write 

func (p *KVStepCounterServiceGetStepValueArgs) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceGetStepValueResult 

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

Attributes:

  • Success

func NewKVStepCounterServiceGetStepValueResult 

func NewKVStepCounterServiceGetStepValueResult() *KVStepCounterServiceGetStepValueResult

func (*KVStepCounterServiceGetStepValueResult) GetSuccess 

func (p *KVStepCounterServiceGetStepValueResult) GetSuccess() int64

func (*KVStepCounterServiceGetStepValueResult) IsSetSuccess 

func (p *KVStepCounterServiceGetStepValueResult) IsSetSuccess() bool

func (*KVStepCounterServiceGetStepValueResult) Read 

func (p *KVStepCounterServiceGetStepValueResult) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceGetStepValueResult) ReadField0 

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

func (*KVStepCounterServiceGetStepValueResult) String 

func (p *KVStepCounterServiceGetStepValueResult) String() string

func (*KVStepCounterServiceGetStepValueResult) Write 

func (p *KVStepCounterServiceGetStepValueResult) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceGetValueArgs 

type KVStepCounterServiceGetValueArgs struct {
	GenName string `thrift:"genName,1" db:"genName" json:"genName"`
}

Attributes:

  • GenName

func NewKVStepCounterServiceGetValueArgs 

func NewKVStepCounterServiceGetValueArgs() *KVStepCounterServiceGetValueArgs

func (*KVStepCounterServiceGetValueArgs) GetGenName 

func (p *KVStepCounterServiceGetValueArgs) GetGenName() string

func (*KVStepCounterServiceGetValueArgs) Read 

func (p *KVStepCounterServiceGetValueArgs) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceGetValueArgs) ReadField1 

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

func (*KVStepCounterServiceGetValueArgs) String 

func (p *KVStepCounterServiceGetValueArgs) String() string

func (*KVStepCounterServiceGetValueArgs) Write 

func (p *KVStepCounterServiceGetValueArgs) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceGetValueResult 

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

Attributes:

  • Success

func NewKVStepCounterServiceGetValueResult 

func NewKVStepCounterServiceGetValueResult() *KVStepCounterServiceGetValueResult

func (*KVStepCounterServiceGetValueResult) GetSuccess 

func (p *KVStepCounterServiceGetValueResult) GetSuccess() int64

func (*KVStepCounterServiceGetValueResult) IsSetSuccess 

func (p *KVStepCounterServiceGetValueResult) IsSetSuccess() bool

func (*KVStepCounterServiceGetValueResult) Read 

func (p *KVStepCounterServiceGetValueResult) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceGetValueResult) ReadField0 

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

func (*KVStepCounterServiceGetValueResult) String 

func (p *KVStepCounterServiceGetValueResult) String() string

func (*KVStepCounterServiceGetValueResult) Write 

func (p *KVStepCounterServiceGetValueResult) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceProcessor 

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

func NewKVStepCounterServiceProcessor 

func NewKVStepCounterServiceProcessor(handler KVStepCounterService) *KVStepCounterServiceProcessor

func (*KVStepCounterServiceProcessor) AddToProcessorMap 

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

func (*KVStepCounterServiceProcessor) GetProcessorFunction 

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

func (*KVStepCounterServiceProcessor) Process 

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

func (*KVStepCounterServiceProcessor) ProcessorMap 

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

type KVStepCounterServicePutDataArgs 

type KVStepCounterServicePutDataArgs struct {
	Data *TKVCounter `thrift:"data,1" db:"data" json:"data"`
}

Attributes:

  • Data

func NewKVStepCounterServicePutDataArgs 

func NewKVStepCounterServicePutDataArgs() *KVStepCounterServicePutDataArgs

func (*KVStepCounterServicePutDataArgs) GetData 

func (p *KVStepCounterServicePutDataArgs) GetData() *TKVCounter

func (*KVStepCounterServicePutDataArgs) IsSetData 

func (p *KVStepCounterServicePutDataArgs) IsSetData() bool

func (*KVStepCounterServicePutDataArgs) Read 

func (p *KVStepCounterServicePutDataArgs) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServicePutDataArgs) ReadField1 

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

func (*KVStepCounterServicePutDataArgs) String 

func (p *KVStepCounterServicePutDataArgs) String() string

func (*KVStepCounterServicePutDataArgs) Write 

func (p *KVStepCounterServicePutDataArgs) Write(oprot thrift.TProtocol) error

type KVStepCounterServicePutDataResult 

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

Attributes:

  • Success

func NewKVStepCounterServicePutDataResult 

func NewKVStepCounterServicePutDataResult() *KVStepCounterServicePutDataResult

func (*KVStepCounterServicePutDataResult) GetSuccess 

func (p *KVStepCounterServicePutDataResult) GetSuccess() TErrorCode

func (*KVStepCounterServicePutDataResult) IsSetSuccess 

func (p *KVStepCounterServicePutDataResult) IsSetSuccess() bool

func (*KVStepCounterServicePutDataResult) Read 

func (p *KVStepCounterServicePutDataResult) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServicePutDataResult) ReadField0 

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

func (*KVStepCounterServicePutDataResult) String 

func (p *KVStepCounterServicePutDataResult) String() string

func (*KVStepCounterServicePutDataResult) Write 

func (p *KVStepCounterServicePutDataResult) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceRemoveGeneratorArgs 

type KVStepCounterServiceRemoveGeneratorArgs struct {
	GenName string `thrift:"genName,1" db:"genName" json:"genName"`
}

Attributes:

  • GenName

func NewKVStepCounterServiceRemoveGeneratorArgs 

func NewKVStepCounterServiceRemoveGeneratorArgs() *KVStepCounterServiceRemoveGeneratorArgs

func (*KVStepCounterServiceRemoveGeneratorArgs) GetGenName 

func (p *KVStepCounterServiceRemoveGeneratorArgs) GetGenName() string

func (*KVStepCounterServiceRemoveGeneratorArgs) Read 

func (p *KVStepCounterServiceRemoveGeneratorArgs) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceRemoveGeneratorArgs) ReadField1 

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

func (*KVStepCounterServiceRemoveGeneratorArgs) String 

func (p *KVStepCounterServiceRemoveGeneratorArgs) String() string

func (*KVStepCounterServiceRemoveGeneratorArgs) Write 

func (p *KVStepCounterServiceRemoveGeneratorArgs) Write(oprot thrift.TProtocol) error

type KVStepCounterServiceRemoveGeneratorResult 

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

Attributes:

  • Success

func NewKVStepCounterServiceRemoveGeneratorResult 

func NewKVStepCounterServiceRemoveGeneratorResult() *KVStepCounterServiceRemoveGeneratorResult

func (*KVStepCounterServiceRemoveGeneratorResult) GetSuccess 

func (p *KVStepCounterServiceRemoveGeneratorResult) GetSuccess() int32

func (*KVStepCounterServiceRemoveGeneratorResult) IsSetSuccess 

func (p *KVStepCounterServiceRemoveGeneratorResult) IsSetSuccess() bool

func (*KVStepCounterServiceRemoveGeneratorResult) Read 

func (p *KVStepCounterServiceRemoveGeneratorResult) Read(iprot thrift.TProtocol) error

func (*KVStepCounterServiceRemoveGeneratorResult) ReadField0 

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

func (*KVStepCounterServiceRemoveGeneratorResult) String 

func (p *KVStepCounterServiceRemoveGeneratorResult) String() string

func (*KVStepCounterServiceRemoveGeneratorResult) Write 

func (p *KVStepCounterServiceRemoveGeneratorResult) Write(oprot thrift.TProtocol) error

type TData 

type TData *TKVCounter

func TDataPtr 

func TDataPtr(v TData) *TData

type TDataResult_ 

type TDataResult_ struct {
	ErrorCode TErrorCode  `thrift:"errorCode,1" db:"errorCode" json:"errorCode"`
	Data      *TKVCounter `thrift:"data,2" db:"data" json:"data,omitempty"`
}

Attributes:

  • ErrorCode
  • Data
var KVStepCounterServiceGetDataResult_Success_DEFAULT *TDataResult_
var TDataServiceGetDataResult_Success_DEFAULT *TDataResult_
var TDataServiceRGetDataResult_Success_DEFAULT *TDataResult_

func NewTDataResult_ 

func NewTDataResult_() *TDataResult_

func (*TDataResult_) GetData 

func (p *TDataResult_) GetData() *TKVCounter

func (*TDataResult_) GetErrorCode 

func (p *TDataResult_) GetErrorCode() TErrorCode

func (*TDataResult_) IsSetData 

func (p *TDataResult_) IsSetData() bool

func (*TDataResult_) Read 

func (p *TDataResult_) Read(iprot thrift.TProtocol) error

func (*TDataResult_) ReadField1 

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

func (*TDataResult_) ReadField2 

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

func (*TDataResult_) String 

func (p *TDataResult_) String() string

func (*TDataResult_) Write 

func (p *TDataResult_) Write(oprot thrift.TProtocol) error

type TDataService 

type TDataService interface {
	// Parameters:
	//  - Key
	GetData(ctx context.Context, key TKey) (r *TDataResult_, err error)
	// Parameters:
	//  - Data
	PutData(ctx context.Context, data *TKVCounter) (r TErrorCode, err error)
}

type TDataServiceClient 

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

func NewTDataServiceClient 

func NewTDataServiceClient(c thrift.TClient) *TDataServiceClient

func NewTDataServiceClientFactory 

func NewTDataServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TDataServiceClient

func NewTDataServiceClientProtocol 

func NewTDataServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TDataServiceClient

func (*TDataServiceClient) Client_ 

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

func (*TDataServiceClient) GetData 

func (p *TDataServiceClient) GetData(ctx context.Context, key TKey) (r *TDataResult_, err error)

Parameters:

  • Key

func (*TDataServiceClient) PutData 

func (p *TDataServiceClient) PutData(ctx context.Context, data *TKVCounter) (r TErrorCode, err error)

Parameters:

  • Data

type TDataServiceGetDataArgs 

type TDataServiceGetDataArgs struct {
	Key TKey `thrift:"key,1" db:"key" json:"key"`
}

Attributes:

  • Key

func NewTDataServiceGetDataArgs 

func NewTDataServiceGetDataArgs() *TDataServiceGetDataArgs

func (*TDataServiceGetDataArgs) GetKey 

func (p *TDataServiceGetDataArgs) GetKey() TKey

func (*TDataServiceGetDataArgs) Read 

func (p *TDataServiceGetDataArgs) Read(iprot thrift.TProtocol) error

func (*TDataServiceGetDataArgs) ReadField1 

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

func (*TDataServiceGetDataArgs) String 

func (p *TDataServiceGetDataArgs) String() string

func (*TDataServiceGetDataArgs) Write 

func (p *TDataServiceGetDataArgs) Write(oprot thrift.TProtocol) error

type TDataServiceGetDataResult 

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

Attributes:

  • Success

func NewTDataServiceGetDataResult 

func NewTDataServiceGetDataResult() *TDataServiceGetDataResult

func (*TDataServiceGetDataResult) GetSuccess 

func (p *TDataServiceGetDataResult) GetSuccess() *TDataResult_

func (*TDataServiceGetDataResult) IsSetSuccess 

func (p *TDataServiceGetDataResult) IsSetSuccess() bool

func (*TDataServiceGetDataResult) Read 

func (p *TDataServiceGetDataResult) Read(iprot thrift.TProtocol) error

func (*TDataServiceGetDataResult) ReadField0 

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

func (*TDataServiceGetDataResult) String 

func (p *TDataServiceGetDataResult) String() string

func (*TDataServiceGetDataResult) Write 

func (p *TDataServiceGetDataResult) Write(oprot thrift.TProtocol) error

type TDataServiceProcessor 

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

func NewTDataServiceProcessor 

func NewTDataServiceProcessor(handler TDataService) *TDataServiceProcessor

func (*TDataServiceProcessor) AddToProcessorMap 

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

func (*TDataServiceProcessor) GetProcessorFunction 

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

func (*TDataServiceProcessor) Process 

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

func (*TDataServiceProcessor) ProcessorMap 

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

type TDataServicePutDataArgs 

type TDataServicePutDataArgs struct {
	Data *TKVCounter `thrift:"data,1" db:"data" json:"data"`
}

Attributes:

  • Data

func NewTDataServicePutDataArgs 

func NewTDataServicePutDataArgs() *TDataServicePutDataArgs

func (*TDataServicePutDataArgs) GetData 

func (p *TDataServicePutDataArgs) GetData() *TKVCounter

func (*TDataServicePutDataArgs) IsSetData 

func (p *TDataServicePutDataArgs) IsSetData() bool

func (*TDataServicePutDataArgs) Read 

func (p *TDataServicePutDataArgs) Read(iprot thrift.TProtocol) error

func (*TDataServicePutDataArgs) ReadField1 

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

func (*TDataServicePutDataArgs) String 

func (p *TDataServicePutDataArgs) String() string

func (*TDataServicePutDataArgs) Write 

func (p *TDataServicePutDataArgs) Write(oprot thrift.TProtocol) error

type TDataServicePutDataResult 

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

Attributes:

  • Success

func NewTDataServicePutDataResult 

func NewTDataServicePutDataResult() *TDataServicePutDataResult

func (*TDataServicePutDataResult) GetSuccess 

func (p *TDataServicePutDataResult) GetSuccess() TErrorCode

func (*TDataServicePutDataResult) IsSetSuccess 

func (p *TDataServicePutDataResult) IsSetSuccess() bool

func (*TDataServicePutDataResult) Read 

func (p *TDataServicePutDataResult) Read(iprot thrift.TProtocol) error

func (*TDataServicePutDataResult) ReadField0 

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

func (*TDataServicePutDataResult) String 

func (p *TDataServicePutDataResult) String() string

func (*TDataServicePutDataResult) Write 

func (p *TDataServicePutDataResult) Write(oprot thrift.TProtocol) error

type TDataServiceR 

type TDataServiceR interface {
	// Parameters:
	//  - Key
	GetData(ctx context.Context, key TKey) (r *TDataResult_, err error)
}

type TDataServiceRClient 

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

func NewTDataServiceRClient 

func NewTDataServiceRClient(c thrift.TClient) *TDataServiceRClient

func NewTDataServiceRClientFactory 

func NewTDataServiceRClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TDataServiceRClient

func NewTDataServiceRClientProtocol 

func NewTDataServiceRClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TDataServiceRClient

func (*TDataServiceRClient) Client_ 

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

func (*TDataServiceRClient) GetData 

func (p *TDataServiceRClient) GetData(ctx context.Context, key TKey) (r *TDataResult_, err error)

Parameters:

  • Key

type TDataServiceRGetDataArgs 

type TDataServiceRGetDataArgs struct {
	Key TKey `thrift:"key,1" db:"key" json:"key"`
}

Attributes:

  • Key

func NewTDataServiceRGetDataArgs 

func NewTDataServiceRGetDataArgs() *TDataServiceRGetDataArgs

func (*TDataServiceRGetDataArgs) GetKey 

func (p *TDataServiceRGetDataArgs) GetKey() TKey

func (*TDataServiceRGetDataArgs) Read 

func (p *TDataServiceRGetDataArgs) Read(iprot thrift.TProtocol) error

func (*TDataServiceRGetDataArgs) ReadField1 

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

func (*TDataServiceRGetDataArgs) String 

func (p *TDataServiceRGetDataArgs) String() string

func (*TDataServiceRGetDataArgs) Write 

func (p *TDataServiceRGetDataArgs) Write(oprot thrift.TProtocol) error

type TDataServiceRGetDataResult 

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

Attributes:

  • Success

func NewTDataServiceRGetDataResult 

func NewTDataServiceRGetDataResult() *TDataServiceRGetDataResult

func (*TDataServiceRGetDataResult) GetSuccess 

func (p *TDataServiceRGetDataResult) GetSuccess() *TDataResult_

func (*TDataServiceRGetDataResult) IsSetSuccess 

func (p *TDataServiceRGetDataResult) IsSetSuccess() bool

func (*TDataServiceRGetDataResult) Read 

func (p *TDataServiceRGetDataResult) Read(iprot thrift.TProtocol) error

func (*TDataServiceRGetDataResult) ReadField0 

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

func (*TDataServiceRGetDataResult) String 

func (p *TDataServiceRGetDataResult) String() string

func (*TDataServiceRGetDataResult) Write 

func (p *TDataServiceRGetDataResult) Write(oprot thrift.TProtocol) error

type TDataServiceRProcessor 

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

func NewTDataServiceRProcessor 

func NewTDataServiceRProcessor(handler TDataServiceR) *TDataServiceRProcessor

func (*TDataServiceRProcessor) AddToProcessorMap 

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

func (*TDataServiceRProcessor) GetProcessorFunction 

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

func (*TDataServiceRProcessor) Process 

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

func (*TDataServiceRProcessor) ProcessorMap 

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

type TErrorCode 

type TErrorCode int64
const (
	TErrorCode_EGood        TErrorCode = 0
	TErrorCode_ENotFound    TErrorCode = -1
	TErrorCode_EUnknown     TErrorCode = -2
	TErrorCode_EDataExisted TErrorCode = -3
)
var KVStepCounterServicePutDataResult_Success_DEFAULT TErrorCode
var TDataServicePutDataResult_Success_DEFAULT TErrorCode

func TErrorCodeFromString 

func TErrorCodeFromString(s string) (TErrorCode, error)

func TErrorCodePtr 

func TErrorCodePtr(v TErrorCode) *TErrorCode

func (TErrorCode) MarshalText 

func (p TErrorCode) MarshalText() ([]byte, error)

func (*TErrorCode) Scan 

func (p *TErrorCode) Scan(value interface{}) error

func (TErrorCode) String 

func (p TErrorCode) String() string

func (*TErrorCode) UnmarshalText 

func (p *TErrorCode) UnmarshalText(text []byte) error

func (*TErrorCode) Value 

func (p *TErrorCode) Value() (driver.Value, error)

type TKVCounter 

type TKVCounter struct {
	Cid   TKey  `thrift:"cid,1" db:"cid" json:"cid"`
	Value int64 `thrift:"value,2" db:"value" json:"value"`
}

Attributes:

  • Cid
  • Value
var KVStepCounterServicePutDataArgs_Data_DEFAULT *TKVCounter
var TDataResult__Data_DEFAULT *TKVCounter
var TDataServicePutDataArgs_Data_DEFAULT *TKVCounter

func NewTKVCounter 

func NewTKVCounter() *TKVCounter

func (*TKVCounter) GetCid 

func (p *TKVCounter) GetCid() TKey

func (*TKVCounter) GetValue 

func (p *TKVCounter) GetValue() int64

func (*TKVCounter) Read 

func (p *TKVCounter) Read(iprot thrift.TProtocol) error

func (*TKVCounter) ReadField1 

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

func (*TKVCounter) ReadField2 

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

func (*TKVCounter) String 

func (p *TKVCounter) String() string

func (*TKVCounter) Write 

func (p *TKVCounter) Write(oprot thrift.TProtocol) error

type TKey 

type TKey string

func TKeyPtr 

func TKeyPtr(v TKey) *TKey

Source Files

View all Source files

Directories

Path Synopsis

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.