Documentation ¶
Index ¶
- Variables
- type TData
- type TDataResult_
- func (p *TDataResult_) GetData() *TNotifyItem
- 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
- type TDataServiceClient
- func (p *TDataServiceClient) Client_() thrift.TClient
- func (p *TDataServiceClient) GetData(ctx context.Context, key int64) (r *TDataResult_, err error)
- func (p *TDataServiceClient) GetListData(ctx context.Context, lskeys []int64) (r *TListDataResult_, err error)
- func (p *TDataServiceClient) PutData(ctx context.Context, key int64, data *TNotifyItem) (r TErrorCode, err error)
- func (p *TDataServiceClient) RemoveData(ctx context.Context, key int64) (r bool, err error)
- type TDataServiceGetDataArgs
- func (p *TDataServiceGetDataArgs) GetKey() int64
- 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
- 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 TDataServiceGetListDataArgs
- func (p *TDataServiceGetListDataArgs) GetLskeys() []int64
- func (p *TDataServiceGetListDataArgs) Read(iprot thrift.TProtocol) error
- func (p *TDataServiceGetListDataArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TDataServiceGetListDataArgs) String() string
- func (p *TDataServiceGetListDataArgs) Write(oprot thrift.TProtocol) error
- type TDataServiceGetListDataResult
- func (p *TDataServiceGetListDataResult) GetSuccess() *TListDataResult_
- func (p *TDataServiceGetListDataResult) IsSetSuccess() bool
- func (p *TDataServiceGetListDataResult) Read(iprot thrift.TProtocol) error
- func (p *TDataServiceGetListDataResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TDataServiceGetListDataResult) String() string
- func (p *TDataServiceGetListDataResult) Write(oprot thrift.TProtocol) error
- type 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
- func (p *TDataServicePutDataArgs) GetData() *TNotifyItem
- func (p *TDataServicePutDataArgs) GetKey() int64
- func (p *TDataServicePutDataArgs) IsSetData() bool
- func (p *TDataServicePutDataArgs) Read(iprot thrift.TProtocol) error
- func (p *TDataServicePutDataArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TDataServicePutDataArgs) ReadField2(iprot thrift.TProtocol) error
- func (p *TDataServicePutDataArgs) String() string
- func (p *TDataServicePutDataArgs) Write(oprot thrift.TProtocol) error
- type 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
- type TDataServiceRClient
- type TDataServiceRGetDataArgs
- func (p *TDataServiceRGetDataArgs) GetKey() int64
- 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
- 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
- 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 TDataServiceRemoveDataArgs
- func (p *TDataServiceRemoveDataArgs) GetKey() int64
- func (p *TDataServiceRemoveDataArgs) Read(iprot thrift.TProtocol) error
- func (p *TDataServiceRemoveDataArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TDataServiceRemoveDataArgs) String() string
- func (p *TDataServiceRemoveDataArgs) Write(oprot thrift.TProtocol) error
- type TDataServiceRemoveDataResult
- func (p *TDataServiceRemoveDataResult) GetSuccess() bool
- func (p *TDataServiceRemoveDataResult) IsSetSuccess() bool
- func (p *TDataServiceRemoveDataResult) Read(iprot thrift.TProtocol) error
- func (p *TDataServiceRemoveDataResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TDataServiceRemoveDataResult) String() string
- func (p *TDataServiceRemoveDataResult) Write(oprot thrift.TProtocol) error
- type TErrorCode
- type TKey
- type TListDataResult_
- func (p *TListDataResult_) GetDatass() []*TNotifyItem
- func (p *TListDataResult_) GetErrorCode() TErrorCode
- func (p *TListDataResult_) IsSetDatass() bool
- func (p *TListDataResult_) Read(iprot thrift.TProtocol) error
- func (p *TListDataResult_) ReadField1(iprot thrift.TProtocol) error
- func (p *TListDataResult_) ReadField2(iprot thrift.TProtocol) error
- func (p *TListDataResult_) String() string
- func (p *TListDataResult_) Write(oprot thrift.TProtocol) error
- type TNotifyItem
- func (p *TNotifyItem) GetActionId() int64
- func (p *TNotifyItem) GetExtend() string
- func (p *TNotifyItem) GetExtendSubjectId() []int64
- func (p *TNotifyItem) GetKey() int64
- func (p *TNotifyItem) GetMapData() map[string]string
- func (p *TNotifyItem) GetMessage() string
- func (p *TNotifyItem) GetObjectId() int64
- func (p *TNotifyItem) GetParentId() int64
- func (p *TNotifyItem) GetSeen() bool
- func (p *TNotifyItem) GetSourceId() int64
- func (p *TNotifyItem) GetSubjectId() int64
- func (p *TNotifyItem) GetSubjectType() int64
- func (p *TNotifyItem) GetTimestamps() int64
- func (p *TNotifyItem) IsSetExtend() bool
- func (p *TNotifyItem) Read(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField1(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField10(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField11(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField12(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField13(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField14(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField15(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField2(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField3(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField4(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField5(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField7(iprot thrift.TProtocol) error
- func (p *TNotifyItem) ReadField9(iprot thrift.TProtocol) error
- func (p *TNotifyItem) String() string
- func (p *TNotifyItem) Write(oprot thrift.TProtocol) error
- type TNotifyStorageService
- type TNotifyStorageServiceClient
- func NewTNotifyStorageServiceClient(c thrift.TClient) *TNotifyStorageServiceClient
- func NewTNotifyStorageServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TNotifyStorageServiceClient
- func NewTNotifyStorageServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TNotifyStorageServiceClient
- type TNotifyStorageServiceProcessor
Constants ¶
This section is empty.
Variables ¶
View Source
var GoUnusedProtection__ int
View Source
var TDataServiceRemoveDataResult_Success_DEFAULT bool
View Source
var TListDataResult__Datass_DEFAULT []*TNotifyItem
View Source
var TNotifyItem_Extend_DEFAULT string
Functions ¶
This section is empty.
Types ¶
type TDataResult_ ¶
type TDataResult_ struct { ErrorCode TErrorCode `thrift:"errorCode,1" db:"errorCode" json:"errorCode"` Data *TNotifyItem `thrift:"data,2" db:"data" json:"data,omitempty"` }
Attributes:
- ErrorCode
- Data
var TDataServiceGetDataResult_Success_DEFAULT *TDataResult_
var TDataServiceRGetDataResult_Success_DEFAULT *TDataResult_
func NewTDataResult_ ¶
func NewTDataResult_() *TDataResult_
func (*TDataResult_) GetData ¶
func (p *TDataResult_) GetData() *TNotifyItem
func (*TDataResult_) GetErrorCode ¶
func (p *TDataResult_) GetErrorCode() TErrorCode
func (*TDataResult_) IsSetData ¶
func (p *TDataResult_) IsSetData() bool
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
type TDataService ¶
type TDataService interface { // Parameters: // - Key GetData(ctx context.Context, key int64) (r *TDataResult_, err error) // Parameters: // - Key // - Data PutData(ctx context.Context, key int64, data *TNotifyItem) (r TErrorCode, err error) // Parameters: // - Lskeys GetListData(ctx context.Context, lskeys []int64) (r *TListDataResult_, err error) // Parameters: // - Key RemoveData(ctx context.Context, key int64) (r bool, 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 int64) (r *TDataResult_, err error)
Parameters:
- Key
func (*TDataServiceClient) GetListData ¶
func (p *TDataServiceClient) GetListData(ctx context.Context, lskeys []int64) (r *TListDataResult_, err error)
Parameters:
- Lskeys
func (*TDataServiceClient) PutData ¶
func (p *TDataServiceClient) PutData(ctx context.Context, key int64, data *TNotifyItem) (r TErrorCode, err error)
Parameters:
- Key
- Data
type TDataServiceGetDataArgs ¶
type TDataServiceGetDataArgs struct {
Key int64 `thrift:"key,1" db:"key" json:"key"`
}
Attributes:
- Key
func NewTDataServiceGetDataArgs ¶
func NewTDataServiceGetDataArgs() *TDataServiceGetDataArgs
func (*TDataServiceGetDataArgs) GetKey ¶
func (p *TDataServiceGetDataArgs) GetKey() int64
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
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
type TDataServiceGetListDataArgs ¶
type TDataServiceGetListDataArgs struct {
Lskeys []int64 `thrift:"lskeys,1" db:"lskeys" json:"lskeys"`
}
Attributes:
- Lskeys
func NewTDataServiceGetListDataArgs ¶
func NewTDataServiceGetListDataArgs() *TDataServiceGetListDataArgs
func (*TDataServiceGetListDataArgs) GetLskeys ¶
func (p *TDataServiceGetListDataArgs) GetLskeys() []int64
func (*TDataServiceGetListDataArgs) Read ¶
func (p *TDataServiceGetListDataArgs) Read(iprot thrift.TProtocol) error
func (*TDataServiceGetListDataArgs) ReadField1 ¶
func (p *TDataServiceGetListDataArgs) ReadField1(iprot thrift.TProtocol) error
func (*TDataServiceGetListDataArgs) String ¶
func (p *TDataServiceGetListDataArgs) String() string
type TDataServiceGetListDataResult ¶
type TDataServiceGetListDataResult struct {
Success *TListDataResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewTDataServiceGetListDataResult ¶
func NewTDataServiceGetListDataResult() *TDataServiceGetListDataResult
func (*TDataServiceGetListDataResult) GetSuccess ¶
func (p *TDataServiceGetListDataResult) GetSuccess() *TListDataResult_
func (*TDataServiceGetListDataResult) IsSetSuccess ¶
func (p *TDataServiceGetListDataResult) IsSetSuccess() bool
func (*TDataServiceGetListDataResult) Read ¶
func (p *TDataServiceGetListDataResult) Read(iprot thrift.TProtocol) error
func (*TDataServiceGetListDataResult) ReadField0 ¶
func (p *TDataServiceGetListDataResult) ReadField0(iprot thrift.TProtocol) error
func (*TDataServiceGetListDataResult) String ¶
func (p *TDataServiceGetListDataResult) String() string
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 { Key int64 `thrift:"key,1" db:"key" json:"key"` Data *TNotifyItem `thrift:"data,2" db:"data" json:"data"` }
Attributes:
- Key
- Data
func NewTDataServicePutDataArgs ¶
func NewTDataServicePutDataArgs() *TDataServicePutDataArgs
func (*TDataServicePutDataArgs) GetData ¶
func (p *TDataServicePutDataArgs) GetData() *TNotifyItem
func (*TDataServicePutDataArgs) GetKey ¶
func (p *TDataServicePutDataArgs) GetKey() int64
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) ReadField2 ¶
func (p *TDataServicePutDataArgs) ReadField2(iprot thrift.TProtocol) error
func (*TDataServicePutDataArgs) String ¶
func (p *TDataServicePutDataArgs) String() string
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
type TDataServiceR ¶
type TDataServiceR interface { // Parameters: // - Key GetData(ctx context.Context, key int64) (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 int64) (r *TDataResult_, err error)
Parameters:
- Key
type TDataServiceRGetDataArgs ¶
type TDataServiceRGetDataArgs struct {
Key int64 `thrift:"key,1" db:"key" json:"key"`
}
Attributes:
- Key
func NewTDataServiceRGetDataArgs ¶
func NewTDataServiceRGetDataArgs() *TDataServiceRGetDataArgs
func (*TDataServiceRGetDataArgs) GetKey ¶
func (p *TDataServiceRGetDataArgs) GetKey() int64
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
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
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 TDataServiceRemoveDataArgs ¶
type TDataServiceRemoveDataArgs struct {
Key int64 `thrift:"key,1" db:"key" json:"key"`
}
Attributes:
- Key
func NewTDataServiceRemoveDataArgs ¶
func NewTDataServiceRemoveDataArgs() *TDataServiceRemoveDataArgs
func (*TDataServiceRemoveDataArgs) GetKey ¶
func (p *TDataServiceRemoveDataArgs) GetKey() int64
func (*TDataServiceRemoveDataArgs) Read ¶
func (p *TDataServiceRemoveDataArgs) Read(iprot thrift.TProtocol) error
func (*TDataServiceRemoveDataArgs) ReadField1 ¶
func (p *TDataServiceRemoveDataArgs) ReadField1(iprot thrift.TProtocol) error
func (*TDataServiceRemoveDataArgs) String ¶
func (p *TDataServiceRemoveDataArgs) String() string
type TDataServiceRemoveDataResult ¶
type TDataServiceRemoveDataResult struct {
Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewTDataServiceRemoveDataResult ¶
func NewTDataServiceRemoveDataResult() *TDataServiceRemoveDataResult
func (*TDataServiceRemoveDataResult) GetSuccess ¶
func (p *TDataServiceRemoveDataResult) GetSuccess() bool
func (*TDataServiceRemoveDataResult) IsSetSuccess ¶
func (p *TDataServiceRemoveDataResult) IsSetSuccess() bool
func (*TDataServiceRemoveDataResult) Read ¶
func (p *TDataServiceRemoveDataResult) Read(iprot thrift.TProtocol) error
func (*TDataServiceRemoveDataResult) ReadField0 ¶
func (p *TDataServiceRemoveDataResult) ReadField0(iprot thrift.TProtocol) error
func (*TDataServiceRemoveDataResult) String ¶
func (p *TDataServiceRemoveDataResult) String() string
type TErrorCode ¶
type TErrorCode int64
const ( TErrorCode_EGood TErrorCode = 0 TErrorCode_ENotFound TErrorCode = -1 TErrorCode_EUnknown TErrorCode = -2 TErrorCode_EDataExisted TErrorCode = -3 )
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
type TListDataResult_ ¶
type TListDataResult_ struct { ErrorCode TErrorCode `thrift:"errorCode,1" db:"errorCode" json:"errorCode"` Datass []*TNotifyItem `thrift:"datass,2" db:"datass" json:"datass,omitempty"` }
Attributes:
- ErrorCode
- Datass
var TDataServiceGetListDataResult_Success_DEFAULT *TListDataResult_
func NewTListDataResult_ ¶
func NewTListDataResult_() *TListDataResult_
func (*TListDataResult_) GetDatass ¶
func (p *TListDataResult_) GetDatass() []*TNotifyItem
func (*TListDataResult_) GetErrorCode ¶
func (p *TListDataResult_) GetErrorCode() TErrorCode
func (*TListDataResult_) IsSetDatass ¶
func (p *TListDataResult_) IsSetDatass() bool
func (*TListDataResult_) ReadField1 ¶
func (p *TListDataResult_) ReadField1(iprot thrift.TProtocol) error
func (*TListDataResult_) ReadField2 ¶
func (p *TListDataResult_) ReadField2(iprot thrift.TProtocol) error
func (*TListDataResult_) String ¶
func (p *TListDataResult_) String() string
type TNotifyItem ¶
type TNotifyItem struct { Key int64 `thrift:"key,1" db:"key" json:"key"` SubjectId int64 `thrift:"subjectId,2" db:"subjectId" json:"subjectId"` ActionId int64 `thrift:"actionId,3" db:"actionId" json:"actionId"` ObjectId int64 `thrift:"objectId,4" db:"objectId" json:"objectId"` SubjectType int64 `thrift:"subjectType,5" db:"subjectType" json:"subjectType"` // unused field # 6 ExtendSubjectId []int64 `thrift:"extendSubjectId,7" db:"extendSubjectId" json:"extendSubjectId"` // unused field # 8 Message string `thrift:"message,9" db:"message" json:"message"` Extend *string `thrift:"extend,10" db:"extend" json:"extend,omitempty"` Seen bool `thrift:"seen,11" db:"seen" json:"seen"` Timestamps int64 `thrift:"timestamps,12" db:"timestamps" json:"timestamps"` SourceId int64 `thrift:"sourceId,13" db:"sourceId" json:"sourceId"` ParentId int64 `thrift:"parentId,14" db:"parentId" json:"parentId"` MapData map[string]string `thrift:"mapData,15" db:"mapData" json:"mapData"` }
Attributes:
- Key
- SubjectId
- ActionId
- ObjectId
- SubjectType
- ExtendSubjectId
- Message
- Extend
- Seen
- Timestamps
- SourceId
- ParentId
- MapData
var TDataResult__Data_DEFAULT *TNotifyItem
var TDataServicePutDataArgs_Data_DEFAULT *TNotifyItem
func NewTNotifyItem ¶
func NewTNotifyItem() *TNotifyItem
func (*TNotifyItem) GetActionId ¶
func (p *TNotifyItem) GetActionId() int64
func (*TNotifyItem) GetExtend ¶
func (p *TNotifyItem) GetExtend() string
func (*TNotifyItem) GetExtendSubjectId ¶
func (p *TNotifyItem) GetExtendSubjectId() []int64
func (*TNotifyItem) GetKey ¶
func (p *TNotifyItem) GetKey() int64
func (*TNotifyItem) GetMapData ¶
func (p *TNotifyItem) GetMapData() map[string]string
func (*TNotifyItem) GetMessage ¶
func (p *TNotifyItem) GetMessage() string
func (*TNotifyItem) GetObjectId ¶
func (p *TNotifyItem) GetObjectId() int64
func (*TNotifyItem) GetParentId ¶
func (p *TNotifyItem) GetParentId() int64
func (*TNotifyItem) GetSeen ¶
func (p *TNotifyItem) GetSeen() bool
func (*TNotifyItem) GetSourceId ¶
func (p *TNotifyItem) GetSourceId() int64
func (*TNotifyItem) GetSubjectId ¶
func (p *TNotifyItem) GetSubjectId() int64
func (*TNotifyItem) GetSubjectType ¶
func (p *TNotifyItem) GetSubjectType() int64
func (*TNotifyItem) GetTimestamps ¶
func (p *TNotifyItem) GetTimestamps() int64
func (*TNotifyItem) IsSetExtend ¶
func (p *TNotifyItem) IsSetExtend() bool
func (*TNotifyItem) ReadField1 ¶
func (p *TNotifyItem) ReadField1(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField10 ¶
func (p *TNotifyItem) ReadField10(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField11 ¶
func (p *TNotifyItem) ReadField11(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField12 ¶
func (p *TNotifyItem) ReadField12(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField13 ¶
func (p *TNotifyItem) ReadField13(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField14 ¶
func (p *TNotifyItem) ReadField14(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField15 ¶
func (p *TNotifyItem) ReadField15(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField2 ¶
func (p *TNotifyItem) ReadField2(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField3 ¶
func (p *TNotifyItem) ReadField3(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField4 ¶
func (p *TNotifyItem) ReadField4(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField5 ¶
func (p *TNotifyItem) ReadField5(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField7 ¶
func (p *TNotifyItem) ReadField7(iprot thrift.TProtocol) error
func (*TNotifyItem) ReadField9 ¶
func (p *TNotifyItem) ReadField9(iprot thrift.TProtocol) error
func (*TNotifyItem) String ¶
func (p *TNotifyItem) String() string
type TNotifyStorageService ¶
type TNotifyStorageService interface { TDataService }
type TNotifyStorageServiceClient ¶
type TNotifyStorageServiceClient struct {
*TDataServiceClient
}
func NewTNotifyStorageServiceClient ¶
func NewTNotifyStorageServiceClient(c thrift.TClient) *TNotifyStorageServiceClient
func NewTNotifyStorageServiceClientFactory ¶
func NewTNotifyStorageServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TNotifyStorageServiceClient
func NewTNotifyStorageServiceClientProtocol ¶
func NewTNotifyStorageServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TNotifyStorageServiceClient
type TNotifyStorageServiceProcessor ¶
type TNotifyStorageServiceProcessor struct {
*TDataServiceProcessor
}
func NewTNotifyStorageServiceProcessor ¶
func NewTNotifyStorageServiceProcessor(handler TNotifyStorageService) *TNotifyStorageServiceProcessor
Source Files ¶
Click to show internal directories.
Click to hide internal directories.