TNotifyStorageService

package
v0.0.0-...-c5b983b Latest Latest
Warning

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

Go to latest
Published: Jan 16, 2020 License: Apache-2.0 Imports: 7 Imported by: 10

Documentation

Index

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 TData

type TData *TNotifyItem

func TDataPtr

func TDataPtr(v TData) *TData

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_) 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 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 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

func (*TDataServiceClient) RemoveData

func (p *TDataServiceClient) RemoveData(ctx context.Context, key int64) (r bool, err error)

Parameters:

  • Key

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 (*TDataServiceGetDataArgs) ReadField1

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

func (*TDataServiceGetDataArgs) String

func (p *TDataServiceGetDataArgs) String() string

func (*TDataServiceGetDataArgs) Write

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 (*TDataServiceGetDataResult) ReadField0

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

func (*TDataServiceGetDataResult) String

func (p *TDataServiceGetDataResult) String() string

func (*TDataServiceGetDataResult) Write

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 (*TDataServiceGetListDataArgs) ReadField1

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

func (*TDataServiceGetListDataArgs) String

func (p *TDataServiceGetListDataArgs) String() string

func (*TDataServiceGetListDataArgs) Write

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 (*TDataServiceGetListDataResult) IsSetSuccess

func (p *TDataServiceGetListDataResult) IsSetSuccess() bool

func (*TDataServiceGetListDataResult) Read

func (*TDataServiceGetListDataResult) ReadField0

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

func (*TDataServiceGetListDataResult) String

func (*TDataServiceGetListDataResult) Write

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 (*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

func (*TDataServicePutDataArgs) Write

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 (*TDataServicePutDataResult) ReadField0

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

func (*TDataServicePutDataResult) String

func (p *TDataServicePutDataResult) String() string

func (*TDataServicePutDataResult) Write

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 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 (*TDataServiceRGetDataArgs) ReadField1

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

func (*TDataServiceRGetDataArgs) String

func (p *TDataServiceRGetDataArgs) String() string

func (*TDataServiceRGetDataArgs) Write

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 (*TDataServiceRGetDataResult) ReadField0

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

func (*TDataServiceRGetDataResult) String

func (p *TDataServiceRGetDataResult) String() string

func (*TDataServiceRGetDataResult) Write

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

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 (*TDataServiceRemoveDataArgs) ReadField1

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

func (*TDataServiceRemoveDataArgs) String

func (p *TDataServiceRemoveDataArgs) String() string

func (*TDataServiceRemoveDataArgs) Write

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 (*TDataServiceRemoveDataResult) ReadField0

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

func (*TDataServiceRemoveDataResult) String

func (*TDataServiceRemoveDataResult) Write

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

func (*TErrorCode) Value

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

type TKey

type TKey int64

func TKeyPtr

func TKeyPtr(v TKey) *TKey

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_) Read

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

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

func (*TListDataResult_) Write

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

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) Read

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

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

func (*TNotifyItem) Write

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

type TNotifyStorageService

type TNotifyStorageService interface {
	TDataService
}

type TNotifyStorageServiceClient

type TNotifyStorageServiceClient struct {
	*TDataServiceClient
}

func NewTNotifyStorageServiceClient

func NewTNotifyStorageServiceClient(c thrift.TClient) *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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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