level1

package
v0.0.0-...-b22f859 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2024 License: BSD-3-Clause Imports: 25 Imported by: 0

Documentation

Overview

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/tldb

Index

Constants

View Source 
const (
	TOKEN_ACK          int8 = 0
	TOKEN_BACK         int8 = 1
	TOKEN_REQ_NEW      int8 = 2
	TOKEN_RESPUUID     int8 = 3
	TOKEN_REQ_TOKEN    int8 = 4
	TOKEN_REQ_INIT     int8 = 5
	TOKEN_TRYGET_TOKEN int8 = 6
)

**********************************************************

Variables

View Source 
var AlterTable func(ts *TableStub) (err error)
View Source 
var BatchPacket_Dels_DEFAULT []string
View Source 
var BatchPacket_Kvmap_DEFAULT map[string][]byte
View Source 
var ClusPub func(mqType int8, bs []byte) (err error)
View Source 
var CreateTable func(ts *TableStub) (err error)
View Source 
var CreateTableMq func(ts *TableStub) (err error)
View Source 
var Delete func(call int, ts *TableStub) (err error)
View Source 
var DeleteBatch func(call int, tablename string, ids []int64) (err error)
View Source 
var DeleteBatches func(call int, tablename string, fromId, toId int64) (err error)
View Source 
var DropTable func(ts *TableStub) (err error)
View Source 
var Insert func(call int, db *TableStub) (seq int64, err error)
View Source 
var InsertMq func(call int, db *TableStub) (seq int64, err error)
View Source 
var Level1 = &level1{}
View Source 
var LoadBean_Logm_DEFAULT map[int64]*LogKV
View Source 
var LoadMQTableInfo func() (tss []*TableStub)
View Source 
var LoadTableInfo func() (tss []*TableStub)
View Source 
var LogKV_Value_DEFAULT []byte
View Source 
var Node_Nodekv_DEFAULT map[int64]string
View Source 
var PonBean_ClusterNode_DEFAULT []int64
View Source 
var PonBean_ExecNode_DEFAULT []int64
View Source 
var PonBean_Key_DEFAULT []byte
View Source 
var PonBean_Pbtime_DEFAULT []byte
View Source 
var PonBean_RunUUID_DEFAULT []int64
View Source 
var PonBean_SyncId_DEFAULT int64
View Source 
var PonBean_Value_DEFAULT []byte
View Source 
var SelectById func(call int, db *TableStub) (_r *TableStub, err error)
View Source 
var SelectByIdx func(call int, table_name, idx_name string, _idx_value []byte) (_r *TableStub, err error)
View Source 
var SelectByIdxAscLimit func(call int, table_name string, idx_name string, _idx_value []byte, startId int64, limit int64) (_r []*TableStub, err error)
View Source 
var SelectByIdxDescLimit func(call int, table_name string, idx_name string, _idx_value []byte, startId int64, limit int64) (_r []*TableStub, err error)
View Source 
var SelectId func(call int, db *TableStub) (_r int64, err error)
View Source 
var SelectIdByIdx func(call int, table_name, idx_name string, _idx_value []byte) (_r int64, err error)
View Source 
var SelectIdByIdxSeq func(call int, table_name string, idx_name string, _idx_value []byte, seq int64) (_r int64, err error)
View Source 
var SelectsByIdLimit func(call int, db *TableStub, start, limit int64) (_r []*TableStub, err error)
View Source 
var SelectsByIdx func(call int, table_name, idx_name string, _idx_value []byte) (_r []*TableStub, err error)
View Source 
var SelectsByIdxLimit func(call int, table_name, idx_name string, idxValues [][]byte, startId, limit int64) (_r []*TableStub, err error)
View Source 
var T _DTYPE = 0
View Source 
var TokenTrans_BackOk_DEFAULT bool
View Source 
var TokenTrans_Bs_DEFAULT []byte
View Source 
var TokenTrans_Extra_DEFAULT map[string][]byte
View Source 
var TokenTrans_ForceBack_DEFAULT bool
View Source 
var TokenTrans_List_DEFAULT []*TokenTrans
View Source 
var TokenTrans_SyncId_DEFAULT int64
View Source 
var Update func(call int, ts *TableStub) (err error)
View Source 
var Z _DTYPE = 1

Functions

func AddInject 

func AddInject(id int64, f func())

func BroadcastMQ 

func BroadcastMQ(mqType int8, bs []byte)

func BroadcastProxy 

func BroadcastProxy(tp *TableParam, uuid int64, pType int8, ctype int8) (_r *TableParam, exce *sys.Exception)

func BroadcastReinit 

func BroadcastReinit(sbean *SysBean) (exce *sys.Exception)

func DecodeDataBeen 

func DecodeDataBeen(bs []byte) (_r *DataBeen)

func EncodeBatchPacket 

func EncodeBatchPacket(bc *BatchPacket) *Buffer

func EncodeDataBean 

func EncodeDataBean(db *DataBeen) (buf *Buffer)

func EncodePonBean 

func EncodePonBean(pb *PonBean) (buf *Buffer)

func GetRemoteRunUUID 

func GetRemoteRunUUID() []int64

func IsClusRun 

func IsClusRun() bool

func LB 

func LB() (_r int64)

func NewBatchProcessTask 

func NewBatchProcessTask(txid int64) task

****************************************************************************

func NewBatchTask 

func NewBatchTask(txid int64) task

func NewGetRemoteTask 

func NewGetRemoteTask(txid int64) task

****************************************************

func NewGetTask 

func NewGetTask(txid int64) task

****************************************************

func NewIncrTask 

func NewIncrTask(txid int64) task

****************************************************

func NewLoadTask 

func NewLoadTask(txid int64) task

****************************************************

func NewMergeSyncTx 

func NewMergeSyncTx() Merge[*syncBean, map[int64]int8]

*******************************************************************

func NewNodeWare 

func NewNodeWare() (_r *_nodeWare)

func NewSeqTask 

func NewSeqTask(txid int64) task

****************************************************

func NewStatAdmin 

func NewStatAdmin() (_r *_statAdmin)

func NewStatTask 

func NewStatTask(txid int64) task

****************************************************

func NewStrToken 

func NewStrToken(sl string, status int8, tokenFlag int64) (_r *strToken)

func NewSyncKeyTask 

func NewSyncKeyTask(txid int64) task

****************************************************

func NewTaskWare 

func NewTaskWare() (_r *_taskWare)

func NewTimeTask 

func NewTimeTask(txid int64) task

****************************************************

func NewTrans 

func NewTrans(key string, kvmap map[string][]byte, dels []string) (t *trans)

func Pon 

func Pon() *pon

func PonUUIDS 

func PonUUIDS(uuids []int64) *pon

func PrintBeen 

func PrintBeen(bs []byte) string

func WriteBatchLogBuffer 

func WriteBatchLogBuffer(bp *BatchPacket) (buf *Buffer)

Types

type BatchPacket 

type BatchPacket struct {
	Kvmap map[string][]byte `thrift:"kvmap,1" db:"kvmap" json:"kvmap,omitempty"`
	Dels  []string          `thrift:"dels,2" db:"dels" json:"dels,omitempty"`
}

Attributes:

  • Kvmap
  • Dels
var PonBean_Batch_DEFAULT *BatchPacket

func DecodeBatchPacket 

func DecodeBatchPacket(bs []byte) (bc *BatchPacket)

func NewBatchPacket 

func NewBatchPacket() *BatchPacket

func (*BatchPacket) Equals 

func (p *BatchPacket) Equals(other *BatchPacket) bool

func (*BatchPacket) GetDels 

func (p *BatchPacket) GetDels() []string

func (*BatchPacket) GetKvmap 

func (p *BatchPacket) GetKvmap() map[string][]byte

func (*BatchPacket) IsSetDels 

func (p *BatchPacket) IsSetDels() bool

func (*BatchPacket) IsSetKvmap 

func (p *BatchPacket) IsSetKvmap() bool

func (*BatchPacket) Read 

func (p *BatchPacket) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*BatchPacket) ReadField1 

func (p *BatchPacket) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*BatchPacket) ReadField2 

func (p *BatchPacket) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*BatchPacket) String 

func (p *BatchPacket) String() string

func (*BatchPacket) Validate 

func (p *BatchPacket) Validate() error

func (*BatchPacket) Write 

func (p *BatchPacket) Write(ctx context.Context, oprot thrift.TProtocol) error

type FileBean 

type FileBean struct {
	Filename string `thrift:"filename,1,required" db:"filename" json:"filename"`
	Size     int64  `thrift:"size,2,required" db:"size" json:"size"`
	Body     []byte `thrift:"body,3,required" db:"body" json:"body"`
	StatKey  int64  `thrift:"statKey,4,required" db:"statKey" json:"statKey"`
}

Attributes:

  • Filename
  • Size
  • Body
  • StatKey
var LogDataBean_FBean_DEFAULT *FileBean

func NewFileBean 

func NewFileBean() *FileBean

func (*FileBean) Equals 

func (p *FileBean) Equals(other *FileBean) bool

func (*FileBean) GetBody 

func (p *FileBean) GetBody() []byte

func (*FileBean) GetFilename 

func (p *FileBean) GetFilename() string

func (*FileBean) GetSize 

func (p *FileBean) GetSize() int64

func (*FileBean) GetStatKey 

func (p *FileBean) GetStatKey() int64

func (*FileBean) Read 

func (p *FileBean) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*FileBean) ReadField1 

func (p *FileBean) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*FileBean) ReadField2 

func (p *FileBean) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*FileBean) ReadField3 

func (p *FileBean) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*FileBean) ReadField4 

func (p *FileBean) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*FileBean) String 

func (p *FileBean) String() string

func (*FileBean) Validate 

func (p *FileBean) Validate() error

func (*FileBean) Write 

func (p *FileBean) Write(ctx context.Context, oprot thrift.TProtocol) error

type Itnet 

type Itnet interface {
	// Parameters:
	//  - Ping
	Ping(ctx context.Context, ping int64) (_err error)
	// Parameters:
	//  - PongBs
	Pong(ctx context.Context, pongBs []byte) (_err error)
	// Parameters:
	//  - AuthKey
	Auth(ctx context.Context, authKey []byte) (_err error)
	// Parameters:
	//  - AuthKey
	Auth2(ctx context.Context, authKey []byte) (_err error)
	// Parameters:
	//  - Pblist
	//  - ID
	PonMerge(ctx context.Context, pblist []*PonBean, id int64) (_err error)
	// Parameters:
	//  - PonBeanBytes
	//  - ID
	Pon(ctx context.Context, PonBeanBytes []byte, id int64) (_err error)
	// Parameters:
	//  - Pb
	//  - ID
	Pon2(ctx context.Context, pb *PonBean, id int64) (_err error)
	// Parameters:
	//  - PonBeanBytes
	//  - ID
	//  - Ack
	Pon3(ctx context.Context, PonBeanBytes []byte, id int64, ack bool) (_err error)
	// Parameters:
	//  - Pretimenano
	//  - Timenano
	//  - Num
	//  - Ir
	Time(ctx context.Context, pretimenano int64, timenano int64, num int16, ir bool) (_err error)
	// Parameters:
	//  - Node
	//  - Ir
	SyncNode(ctx context.Context, node *Node, ir bool) (_err error)
	// Parameters:
	//  - SyncId
	//  - Result_
	SyncTx(ctx context.Context, syncId int64, result int8) (_err error)
	// Parameters:
	//  - SyncList
	SyncTxMerge(ctx context.Context, syncList map[int64]int8) (_err error)
	// Parameters:
	//  - SyncId
	//  - Txid
	CommitTx(ctx context.Context, syncId int64, txid int64) (_err error)
	// Parameters:
	//  - SyncId
	//  - Txid
	//  - Commit
	CommitTx2(ctx context.Context, syncId int64, txid int64, commit bool) (_err error)
	// Parameters:
	//  - SyncId
	//  - MqType
	//  - Bs
	PubMq(ctx context.Context, syncId int64, mqType int8, bs []byte) (_err error)
	// Parameters:
	//  - SyncId
	//  - Ldb
	PullData(ctx context.Context, syncId int64, ldb *LogDataBean) (_err error)
	// Parameters:
	//  - SyncId
	//  - Sbean
	ReInit(ctx context.Context, syncId int64, sbean *SysBean) (_err error)
	// Parameters:
	//  - SyncId
	//  - ParamData
	//  - PType
	//  - Ctype
	ProxyCall(ctx context.Context, syncId int64, paramData []byte, pType int8, ctype int8) (_err error)
	// Parameters:
	//  - SyncId
	//  - Tt
	//  - Ack
	BroadToken(ctx context.Context, syncId int64, tt *TokenTrans, ack bool) (_err error)
}

type ItnetAuth2Args 

type ItnetAuth2Args struct {
	AuthKey []byte `thrift:"authKey,1" db:"authKey" json:"authKey"`
}

Attributes:

  • AuthKey

func NewItnetAuth2Args 

func NewItnetAuth2Args() *ItnetAuth2Args

func (*ItnetAuth2Args) GetAuthKey 

func (p *ItnetAuth2Args) GetAuthKey() []byte

func (*ItnetAuth2Args) Read 

func (p *ItnetAuth2Args) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetAuth2Args) ReadField1 

func (p *ItnetAuth2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetAuth2Args) String 

func (p *ItnetAuth2Args) String() string

func (*ItnetAuth2Args) Write 

func (p *ItnetAuth2Args) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetAuthArgs 

type ItnetAuthArgs struct {
	AuthKey []byte `thrift:"authKey,1" db:"authKey" json:"authKey"`
}

Attributes:

  • AuthKey

func NewItnetAuthArgs 

func NewItnetAuthArgs() *ItnetAuthArgs

func (*ItnetAuthArgs) GetAuthKey 

func (p *ItnetAuthArgs) GetAuthKey() []byte

func (*ItnetAuthArgs) Read 

func (p *ItnetAuthArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetAuthArgs) ReadField1 

func (p *ItnetAuthArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetAuthArgs) String 

func (p *ItnetAuthArgs) String() string

func (*ItnetAuthArgs) Write 

func (p *ItnetAuthArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetBroadTokenArgs 

type ItnetBroadTokenArgs struct {
	SyncId int64       `thrift:"syncId,1" db:"syncId" json:"syncId"`
	Tt     *TokenTrans `thrift:"tt,2" db:"tt" json:"tt"`
	Ack    bool        `thrift:"ack,3" db:"ack" json:"ack"`
}

Attributes:

  • SyncId
  • Tt
  • Ack

func NewItnetBroadTokenArgs 

func NewItnetBroadTokenArgs() *ItnetBroadTokenArgs

func (*ItnetBroadTokenArgs) GetAck 

func (p *ItnetBroadTokenArgs) GetAck() bool

func (*ItnetBroadTokenArgs) GetSyncId 

func (p *ItnetBroadTokenArgs) GetSyncId() int64

func (*ItnetBroadTokenArgs) GetTt 

func (p *ItnetBroadTokenArgs) GetTt() *TokenTrans

func (*ItnetBroadTokenArgs) IsSetTt 

func (p *ItnetBroadTokenArgs) IsSetTt() bool

func (*ItnetBroadTokenArgs) Read 

func (p *ItnetBroadTokenArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetBroadTokenArgs) ReadField1 

func (p *ItnetBroadTokenArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetBroadTokenArgs) ReadField2 

func (p *ItnetBroadTokenArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetBroadTokenArgs) ReadField3 

func (p *ItnetBroadTokenArgs) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetBroadTokenArgs) String 

func (p *ItnetBroadTokenArgs) String() string

func (*ItnetBroadTokenArgs) Write 

func (p *ItnetBroadTokenArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetClient 

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

func NewItnetClient 

func NewItnetClient(c thrift.TClient) *ItnetClient

func NewItnetClientFactory 

func NewItnetClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ItnetClient

func NewItnetClientProtocol 

func NewItnetClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ItnetClient

func (*ItnetClient) Auth 

func (p *ItnetClient) Auth(ctx context.Context, authKey []byte) (_err error)

Parameters:

  • AuthKey

func (*ItnetClient) Auth2 

func (p *ItnetClient) Auth2(ctx context.Context, authKey []byte) (_err error)

Parameters:

  • AuthKey

func (*ItnetClient) BroadToken 

func (p *ItnetClient) BroadToken(ctx context.Context, syncId int64, tt *TokenTrans, ack bool) (_err error)

Parameters:

  • SyncId
  • Tt
  • Ack

func (*ItnetClient) Client_ 

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

func (*ItnetClient) CommitTx 

func (p *ItnetClient) CommitTx(ctx context.Context, syncId int64, txid int64) (_err error)

Parameters:

  • SyncId
  • Txid

func (*ItnetClient) CommitTx2 

func (p *ItnetClient) CommitTx2(ctx context.Context, syncId int64, txid int64, commit bool) (_err error)

Parameters:

  • SyncId
  • Txid
  • Commit

func (*ItnetClient) LastResponseMeta_ 

func (p *ItnetClient) LastResponseMeta_() thrift.ResponseMeta

func (*ItnetClient) Ping 

func (p *ItnetClient) Ping(ctx context.Context, ping int64) (_err error)

Parameters:

  • Ping

func (*ItnetClient) Pon 

func (p *ItnetClient) Pon(ctx context.Context, PonBeanBytes []byte, id int64) (_err error)

Parameters:

  • PonBeanBytes
  • ID

func (*ItnetClient) Pon2 

func (p *ItnetClient) Pon2(ctx context.Context, pb *PonBean, id int64) (_err error)

Parameters:

  • Pb
  • ID

func (*ItnetClient) Pon3 

func (p *ItnetClient) Pon3(ctx context.Context, PonBeanBytes []byte, id int64, ack bool) (_err error)

Parameters:

  • PonBeanBytes
  • ID
  • Ack

func (*ItnetClient) PonMerge 

func (p *ItnetClient) PonMerge(ctx context.Context, pblist []*PonBean, id int64) (_err error)

Parameters:

  • Pblist
  • ID

func (*ItnetClient) Pong 

func (p *ItnetClient) Pong(ctx context.Context, pongBs []byte) (_err error)

Parameters:

  • PongBs

func (*ItnetClient) ProxyCall 

func (p *ItnetClient) ProxyCall(ctx context.Context, syncId int64, paramData []byte, pType int8, ctype int8) (_err error)

Parameters:

  • SyncId
  • ParamData
  • PType
  • Ctype

func (*ItnetClient) PubMq 

func (p *ItnetClient) PubMq(ctx context.Context, syncId int64, mqType int8, bs []byte) (_err error)

Parameters:

  • SyncId
  • MqType
  • Bs

func (*ItnetClient) PullData 

func (p *ItnetClient) PullData(ctx context.Context, syncId int64, ldb *LogDataBean) (_err error)

Parameters:

  • SyncId
  • Ldb

func (*ItnetClient) ReInit 

func (p *ItnetClient) ReInit(ctx context.Context, syncId int64, sbean *SysBean) (_err error)

Parameters:

  • SyncId
  • Sbean

func (*ItnetClient) SetLastResponseMeta_ 

func (p *ItnetClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

func (*ItnetClient) SyncNode 

func (p *ItnetClient) SyncNode(ctx context.Context, node *Node, ir bool) (_err error)

Parameters:

  • Node
  • Ir

func (*ItnetClient) SyncTx 

func (p *ItnetClient) SyncTx(ctx context.Context, syncId int64, result int8) (_err error)

Parameters:

  • SyncId
  • Result_

func (*ItnetClient) SyncTxMerge 

func (p *ItnetClient) SyncTxMerge(ctx context.Context, syncList map[int64]int8) (_err error)

Parameters:

  • SyncList

func (*ItnetClient) Time 

func (p *ItnetClient) Time(ctx context.Context, pretimenano int64, timenano int64, num int16, ir bool) (_err error)

Parameters:

  • Pretimenano
  • Timenano
  • Num
  • Ir

type ItnetCommitTx2Args 

type ItnetCommitTx2Args struct {
	SyncId int64 `thrift:"syncId,1" db:"syncId" json:"syncId"`
	Txid   int64 `thrift:"txid,2" db:"txid" json:"txid"`
	Commit bool  `thrift:"commit,3" db:"commit" json:"commit"`
}

Attributes:

  • SyncId
  • Txid
  • Commit

func NewItnetCommitTx2Args 

func NewItnetCommitTx2Args() *ItnetCommitTx2Args

func (*ItnetCommitTx2Args) GetCommit 

func (p *ItnetCommitTx2Args) GetCommit() bool

func (*ItnetCommitTx2Args) GetSyncId 

func (p *ItnetCommitTx2Args) GetSyncId() int64

func (*ItnetCommitTx2Args) GetTxid 

func (p *ItnetCommitTx2Args) GetTxid() int64

func (*ItnetCommitTx2Args) Read 

func (p *ItnetCommitTx2Args) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetCommitTx2Args) ReadField1 

func (p *ItnetCommitTx2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetCommitTx2Args) ReadField2 

func (p *ItnetCommitTx2Args) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetCommitTx2Args) ReadField3 

func (p *ItnetCommitTx2Args) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetCommitTx2Args) String 

func (p *ItnetCommitTx2Args) String() string

func (*ItnetCommitTx2Args) Write 

func (p *ItnetCommitTx2Args) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetCommitTxArgs 

type ItnetCommitTxArgs struct {
	SyncId int64 `thrift:"syncId,1" db:"syncId" json:"syncId"`
	Txid   int64 `thrift:"txid,2" db:"txid" json:"txid"`
}

Attributes:

  • SyncId
  • Txid

func NewItnetCommitTxArgs 

func NewItnetCommitTxArgs() *ItnetCommitTxArgs

func (*ItnetCommitTxArgs) GetSyncId 

func (p *ItnetCommitTxArgs) GetSyncId() int64

func (*ItnetCommitTxArgs) GetTxid 

func (p *ItnetCommitTxArgs) GetTxid() int64

func (*ItnetCommitTxArgs) Read 

func (p *ItnetCommitTxArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetCommitTxArgs) ReadField1 

func (p *ItnetCommitTxArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetCommitTxArgs) ReadField2 

func (p *ItnetCommitTxArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetCommitTxArgs) String 

func (p *ItnetCommitTxArgs) String() string

func (*ItnetCommitTxArgs) Write 

func (p *ItnetCommitTxArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetImpl 

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

func (*ItnetImpl) Auth 

func (this *ItnetImpl) Auth(ctx context.Context, authKey []byte) (_err error)

Parameters:

  • AuthKey

func (*ItnetImpl) Auth2 

func (this *ItnetImpl) Auth2(ctx context.Context, authKey []byte) (_err error)

Parameters:

  • AuthKey

func (*ItnetImpl) BroadToken 

func (this *ItnetImpl) BroadToken(ctx context.Context, syncId int64, tt *TokenTrans, ack bool) (_err error)

func (*ItnetImpl) CommitTx 

func (this *ItnetImpl) CommitTx(ctx context.Context, syncId int64, txid int64) (_err error)

Parameters:

  • SyncId
  • Txid

func (*ItnetImpl) CommitTx2 

func (this *ItnetImpl) CommitTx2(ctx context.Context, syncId int64, txid int64, commit bool) (_err error)

Parameters:

  • SyncId
  • Commit

func (*ItnetImpl) Ping 

func (this *ItnetImpl) Ping(ctx context.Context, pingstr int64) (_err error)

func (*ItnetImpl) Pon 

func (this *ItnetImpl) Pon(ctx context.Context, ponBeanBytes []byte, id int64) (_err error)

Parameters:

  • Pb

func (*ItnetImpl) Pon2 

func (this *ItnetImpl) Pon2(ctx context.Context, pb *PonBean, id int64) (_err error)

Parameters:

  • Pb

func (*ItnetImpl) Pon3 

func (this *ItnetImpl) Pon3(ctx context.Context, ponBeanBytes []byte, id int64, ack bool) (_err error)

Parameters:

  • Pb

func (*ItnetImpl) PonMerge 

func (this *ItnetImpl) PonMerge(ctx context.Context, pblist []*PonBean, id int64) (_err error)

func (*ItnetImpl) Pong 

func (this *ItnetImpl) Pong(ctx context.Context, pongBs []byte) (_err error)

func (*ItnetImpl) ProxyCall 

func (this *ItnetImpl) ProxyCall(ctx context.Context, syncId int64, paramData []byte, pType int8, ctype int8) (_err error)

func (*ItnetImpl) PubMq 

func (this *ItnetImpl) PubMq(ctx context.Context, syncId int64, mqType int8, bs []byte) (_err error)

func (*ItnetImpl) PullData 

func (this *ItnetImpl) PullData(ctx context.Context, syncId int64, ldb *LogDataBean) (_err error)

func (*ItnetImpl) ReInit 

func (this *ItnetImpl) ReInit(ctx context.Context, syncId int64, sbean *SysBean) (_err error)

func (*ItnetImpl) SyncNode 

func (this *ItnetImpl) SyncNode(ctx context.Context, node *Node, ir bool) (_err error)

Parameters:

  • Node
  • Ir

func (*ItnetImpl) SyncTx 

func (this *ItnetImpl) SyncTx(ctx context.Context, syncId int64, result int8) (_err error)

func (*ItnetImpl) SyncTxMerge 

func (this *ItnetImpl) SyncTxMerge(ctx context.Context, syncList map[int64]int8) (_err error)

func (*ItnetImpl) Time 

func (this *ItnetImpl) Time(ctx context.Context, pretimenano int64, timenano int64, num int16, ir bool) (_err error)

Parameters:

  • Pretimenano
  • Timenano
  • Num
  • Ir

type ItnetPingArgs 

type ItnetPingArgs struct {
	Ping int64 `thrift:"ping,1" db:"ping" json:"ping"`
}

Attributes:

  • Ping

func NewItnetPingArgs 

func NewItnetPingArgs() *ItnetPingArgs

func (*ItnetPingArgs) GetPing 

func (p *ItnetPingArgs) GetPing() int64

func (*ItnetPingArgs) Read 

func (p *ItnetPingArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPingArgs) ReadField1 

func (p *ItnetPingArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPingArgs) String 

func (p *ItnetPingArgs) String() string

func (*ItnetPingArgs) Write 

func (p *ItnetPingArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetPon2Args 

type ItnetPon2Args struct {
	Pb *PonBean `thrift:"pb,1" db:"pb" json:"pb"`
	ID int64    `thrift:"id,2" db:"id" json:"id"`
}

Attributes:

  • Pb
  • ID

func NewItnetPon2Args 

func NewItnetPon2Args() *ItnetPon2Args

func (*ItnetPon2Args) GetID 

func (p *ItnetPon2Args) GetID() int64

func (*ItnetPon2Args) GetPb 

func (p *ItnetPon2Args) GetPb() *PonBean

func (*ItnetPon2Args) IsSetPb 

func (p *ItnetPon2Args) IsSetPb() bool

func (*ItnetPon2Args) Read 

func (p *ItnetPon2Args) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPon2Args) ReadField1 

func (p *ItnetPon2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPon2Args) ReadField2 

func (p *ItnetPon2Args) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPon2Args) String 

func (p *ItnetPon2Args) String() string

func (*ItnetPon2Args) Write 

func (p *ItnetPon2Args) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetPon3Args 

type ItnetPon3Args struct {
	PonBeanBytes []byte `thrift:"PonBeanBytes,1" db:"PonBeanBytes" json:"PonBeanBytes"`
	ID           int64  `thrift:"id,2" db:"id" json:"id"`
	Ack          bool   `thrift:"ack,3" db:"ack" json:"ack"`
}

Attributes:

  • PonBeanBytes
  • ID
  • Ack

func NewItnetPon3Args 

func NewItnetPon3Args() *ItnetPon3Args

func (*ItnetPon3Args) GetAck 

func (p *ItnetPon3Args) GetAck() bool

func (*ItnetPon3Args) GetID 

func (p *ItnetPon3Args) GetID() int64

func (*ItnetPon3Args) GetPonBeanBytes 

func (p *ItnetPon3Args) GetPonBeanBytes() []byte

func (*ItnetPon3Args) Read 

func (p *ItnetPon3Args) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPon3Args) ReadField1 

func (p *ItnetPon3Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPon3Args) ReadField2 

func (p *ItnetPon3Args) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPon3Args) ReadField3 

func (p *ItnetPon3Args) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPon3Args) String 

func (p *ItnetPon3Args) String() string

func (*ItnetPon3Args) Write 

func (p *ItnetPon3Args) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetPonArgs 

type ItnetPonArgs struct {
	PonBeanBytes []byte `thrift:"PonBeanBytes,1" db:"PonBeanBytes" json:"PonBeanBytes"`
	ID           int64  `thrift:"id,2" db:"id" json:"id"`
}

Attributes:

  • PonBeanBytes
  • ID

func NewItnetPonArgs 

func NewItnetPonArgs() *ItnetPonArgs

func (*ItnetPonArgs) GetID 

func (p *ItnetPonArgs) GetID() int64

func (*ItnetPonArgs) GetPonBeanBytes 

func (p *ItnetPonArgs) GetPonBeanBytes() []byte

func (*ItnetPonArgs) Read 

func (p *ItnetPonArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPonArgs) ReadField1 

func (p *ItnetPonArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPonArgs) ReadField2 

func (p *ItnetPonArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPonArgs) String 

func (p *ItnetPonArgs) String() string

func (*ItnetPonArgs) Write 

func (p *ItnetPonArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetPonMergeArgs 

type ItnetPonMergeArgs struct {
	Pblist []*PonBean `thrift:"pblist,1" db:"pblist" json:"pblist"`
	ID     int64      `thrift:"id,2" db:"id" json:"id"`
}

Attributes:

  • Pblist
  • ID

func NewItnetPonMergeArgs 

func NewItnetPonMergeArgs() *ItnetPonMergeArgs

func (*ItnetPonMergeArgs) GetID 

func (p *ItnetPonMergeArgs) GetID() int64

func (*ItnetPonMergeArgs) GetPblist 

func (p *ItnetPonMergeArgs) GetPblist() []*PonBean

func (*ItnetPonMergeArgs) Read 

func (p *ItnetPonMergeArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPonMergeArgs) ReadField1 

func (p *ItnetPonMergeArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPonMergeArgs) ReadField2 

func (p *ItnetPonMergeArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPonMergeArgs) String 

func (p *ItnetPonMergeArgs) String() string

func (*ItnetPonMergeArgs) Write 

func (p *ItnetPonMergeArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetPongArgs 

type ItnetPongArgs struct {
	PongBs []byte `thrift:"pongBs,1" db:"pongBs" json:"pongBs"`
}

Attributes:

  • PongBs

func NewItnetPongArgs 

func NewItnetPongArgs() *ItnetPongArgs

func (*ItnetPongArgs) GetPongBs 

func (p *ItnetPongArgs) GetPongBs() []byte

func (*ItnetPongArgs) Read 

func (p *ItnetPongArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPongArgs) ReadField1 

func (p *ItnetPongArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPongArgs) String 

func (p *ItnetPongArgs) String() string

func (*ItnetPongArgs) Write 

func (p *ItnetPongArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetProcessor 

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

func NewItnetProcessor 

func NewItnetProcessor(handler Itnet) *ItnetProcessor

func (*ItnetProcessor) AddToProcessorMap 

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

func (*ItnetProcessor) GetProcessorFunction 

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

func (*ItnetProcessor) Process 

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

func (*ItnetProcessor) ProcessorMap 

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

type ItnetProxyCallArgs 

type ItnetProxyCallArgs struct {
	SyncId    int64  `thrift:"syncId,1" db:"syncId" json:"syncId"`
	ParamData []byte `thrift:"paramData,2" db:"paramData" json:"paramData"`
	PType     int8   `thrift:"pType,3" db:"pType" json:"pType"`
	Ctype     int8   `thrift:"ctype,4" db:"ctype" json:"ctype"`
}

Attributes:

  • SyncId
  • ParamData
  • PType
  • Ctype

func NewItnetProxyCallArgs 

func NewItnetProxyCallArgs() *ItnetProxyCallArgs

func (*ItnetProxyCallArgs) GetCtype 

func (p *ItnetProxyCallArgs) GetCtype() int8

func (*ItnetProxyCallArgs) GetPType 

func (p *ItnetProxyCallArgs) GetPType() int8

func (*ItnetProxyCallArgs) GetParamData 

func (p *ItnetProxyCallArgs) GetParamData() []byte

func (*ItnetProxyCallArgs) GetSyncId 

func (p *ItnetProxyCallArgs) GetSyncId() int64

func (*ItnetProxyCallArgs) Read 

func (p *ItnetProxyCallArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetProxyCallArgs) ReadField1 

func (p *ItnetProxyCallArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetProxyCallArgs) ReadField2 

func (p *ItnetProxyCallArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetProxyCallArgs) ReadField3 

func (p *ItnetProxyCallArgs) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetProxyCallArgs) ReadField4 

func (p *ItnetProxyCallArgs) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetProxyCallArgs) String 

func (p *ItnetProxyCallArgs) String() string

func (*ItnetProxyCallArgs) Write 

func (p *ItnetProxyCallArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetPubMqArgs 

type ItnetPubMqArgs struct {
	SyncId int64  `thrift:"syncId,1" db:"syncId" json:"syncId"`
	MqType int8   `thrift:"mqType,2" db:"mqType" json:"mqType"`
	Bs     []byte `thrift:"bs,3" db:"bs" json:"bs"`
}

Attributes:

  • SyncId
  • MqType
  • Bs

func NewItnetPubMqArgs 

func NewItnetPubMqArgs() *ItnetPubMqArgs

func (*ItnetPubMqArgs) GetBs 

func (p *ItnetPubMqArgs) GetBs() []byte

func (*ItnetPubMqArgs) GetMqType 

func (p *ItnetPubMqArgs) GetMqType() int8

func (*ItnetPubMqArgs) GetSyncId 

func (p *ItnetPubMqArgs) GetSyncId() int64

func (*ItnetPubMqArgs) Read 

func (p *ItnetPubMqArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPubMqArgs) ReadField1 

func (p *ItnetPubMqArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPubMqArgs) ReadField2 

func (p *ItnetPubMqArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPubMqArgs) ReadField3 

func (p *ItnetPubMqArgs) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPubMqArgs) String 

func (p *ItnetPubMqArgs) String() string

func (*ItnetPubMqArgs) Write 

func (p *ItnetPubMqArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetPullDataArgs 

type ItnetPullDataArgs struct {
	SyncId int64        `thrift:"syncId,1" db:"syncId" json:"syncId"`
	Ldb    *LogDataBean `thrift:"ldb,2" db:"ldb" json:"ldb"`
}

Attributes:

  • SyncId
  • Ldb

func NewItnetPullDataArgs 

func NewItnetPullDataArgs() *ItnetPullDataArgs

func (*ItnetPullDataArgs) GetLdb 

func (p *ItnetPullDataArgs) GetLdb() *LogDataBean

func (*ItnetPullDataArgs) GetSyncId 

func (p *ItnetPullDataArgs) GetSyncId() int64

func (*ItnetPullDataArgs) IsSetLdb 

func (p *ItnetPullDataArgs) IsSetLdb() bool

func (*ItnetPullDataArgs) Read 

func (p *ItnetPullDataArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPullDataArgs) ReadField1 

func (p *ItnetPullDataArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPullDataArgs) ReadField2 

func (p *ItnetPullDataArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetPullDataArgs) String 

func (p *ItnetPullDataArgs) String() string

func (*ItnetPullDataArgs) Write 

func (p *ItnetPullDataArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetReInitArgs 

type ItnetReInitArgs struct {
	SyncId int64    `thrift:"syncId,1" db:"syncId" json:"syncId"`
	Sbean  *SysBean `thrift:"sbean,2" db:"sbean" json:"sbean"`
}

Attributes:

  • SyncId
  • Sbean

func NewItnetReInitArgs 

func NewItnetReInitArgs() *ItnetReInitArgs

func (*ItnetReInitArgs) GetSbean 

func (p *ItnetReInitArgs) GetSbean() *SysBean

func (*ItnetReInitArgs) GetSyncId 

func (p *ItnetReInitArgs) GetSyncId() int64

func (*ItnetReInitArgs) IsSetSbean 

func (p *ItnetReInitArgs) IsSetSbean() bool

func (*ItnetReInitArgs) Read 

func (p *ItnetReInitArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetReInitArgs) ReadField1 

func (p *ItnetReInitArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetReInitArgs) ReadField2 

func (p *ItnetReInitArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetReInitArgs) String 

func (p *ItnetReInitArgs) String() string

func (*ItnetReInitArgs) Write 

func (p *ItnetReInitArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetServ 

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

func (*ItnetServ) Auth 

func (this *ItnetServ) Auth(ctx context.Context, authKey []byte) (_err error)

func (*ItnetServ) Auth2 

func (this *ItnetServ) Auth2(ctx context.Context, authKey []byte) (_err error)

func (*ItnetServ) BroadToken 

func (this *ItnetServ) BroadToken(ctx context.Context, syncId int64, tt *TokenTrans, ack bool) (_err error)

func (*ItnetServ) CommitTx 

func (this *ItnetServ) CommitTx(ctx context.Context, syncId int64, txid int64) (_err error)

Parameters:

  • SyncId
  • Txid

func (*ItnetServ) CommitTx2 

func (this *ItnetServ) CommitTx2(ctx context.Context, syncId int64, txid int64, commit bool) (_err error)

Parameters:

  • SyncId
  • Commit

func (*ItnetServ) Ping 

func (this *ItnetServ) Ping(ctx context.Context, pingstr int64) (_err error)

//////////////////////////////////////

func (*ItnetServ) Pon 

func (this *ItnetServ) Pon(ctx context.Context, ponBeanBytes []byte, id int64) (err error)

Parameters:

  • Pb

func (*ItnetServ) Pon2 

func (this *ItnetServ) Pon2(ctx context.Context, pb *PonBean, id int64) (_err error)

func (*ItnetServ) Pon3 

func (this *ItnetServ) Pon3(ctx context.Context, ponBeanBytes []byte, id int64, ack bool) (_err error)

func (*ItnetServ) PonMerge 

func (this *ItnetServ) PonMerge(ctx context.Context, pblist []*PonBean, id int64) (_err error)

func (*ItnetServ) Pong 

func (this *ItnetServ) Pong(ctx context.Context, pongBs []byte) (_err error)

func (*ItnetServ) ProxyCall 

func (this *ItnetServ) ProxyCall(ctx context.Context, syncId int64, paramData []byte, pType int8, ctype int8) (_err error)

func (*ItnetServ) PubMq 

func (this *ItnetServ) PubMq(ctx context.Context, syncId int64, mqType int8, bs []byte) (_err error)

func (*ItnetServ) PullData 

func (this *ItnetServ) PullData(ctx context.Context, syncId int64, ldb *LogDataBean) (_err error)

func (*ItnetServ) ReInit 

func (this *ItnetServ) ReInit(ctx context.Context, syncId int64, sbean *SysBean) (_err error)

func (*ItnetServ) SyncNode 

func (this *ItnetServ) SyncNode(ctx context.Context, node *Node, ir bool) (_err error)

func (*ItnetServ) SyncTx 

func (this *ItnetServ) SyncTx(ctx context.Context, syncId int64, result int8) (_err error)

func (*ItnetServ) SyncTxMerge 

func (this *ItnetServ) SyncTxMerge(ctx context.Context, syncList map[int64]int8) (_err error)

func (*ItnetServ) Time 

func (this *ItnetServ) Time(ctx context.Context, pretimenano, timenano int64, num int16, ir bool) (_err error)

Parameters:

  • Timenano
  • Num
  • Ir

type ItnetSyncNodeArgs 

type ItnetSyncNodeArgs struct {
	Node *Node `thrift:"node,1" db:"node" json:"node"`
	Ir   bool  `thrift:"ir,2" db:"ir" json:"ir"`
}

Attributes:

  • Node
  • Ir

func NewItnetSyncNodeArgs 

func NewItnetSyncNodeArgs() *ItnetSyncNodeArgs

func (*ItnetSyncNodeArgs) GetIr 

func (p *ItnetSyncNodeArgs) GetIr() bool

func (*ItnetSyncNodeArgs) GetNode 

func (p *ItnetSyncNodeArgs) GetNode() *Node

func (*ItnetSyncNodeArgs) IsSetNode 

func (p *ItnetSyncNodeArgs) IsSetNode() bool

func (*ItnetSyncNodeArgs) Read 

func (p *ItnetSyncNodeArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetSyncNodeArgs) ReadField1 

func (p *ItnetSyncNodeArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetSyncNodeArgs) ReadField2 

func (p *ItnetSyncNodeArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetSyncNodeArgs) String 

func (p *ItnetSyncNodeArgs) String() string

func (*ItnetSyncNodeArgs) Write 

func (p *ItnetSyncNodeArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetSyncTxArgs 

type ItnetSyncTxArgs struct {
	SyncId  int64 `thrift:"syncId,1" db:"syncId" json:"syncId"`
	Result_ int8  `thrift:"result,2" db:"result" json:"result"`
}

Attributes:

  • SyncId
  • Result_

func NewItnetSyncTxArgs 

func NewItnetSyncTxArgs() *ItnetSyncTxArgs

func (*ItnetSyncTxArgs) GetResult_ 

func (p *ItnetSyncTxArgs) GetResult_() int8

func (*ItnetSyncTxArgs) GetSyncId 

func (p *ItnetSyncTxArgs) GetSyncId() int64

func (*ItnetSyncTxArgs) Read 

func (p *ItnetSyncTxArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetSyncTxArgs) ReadField1 

func (p *ItnetSyncTxArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetSyncTxArgs) ReadField2 

func (p *ItnetSyncTxArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetSyncTxArgs) String 

func (p *ItnetSyncTxArgs) String() string

func (*ItnetSyncTxArgs) Write 

func (p *ItnetSyncTxArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetSyncTxMergeArgs 

type ItnetSyncTxMergeArgs struct {
	SyncList map[int64]int8 `thrift:"syncList,1" db:"syncList" json:"syncList"`
}

Attributes:

  • SyncList

func NewItnetSyncTxMergeArgs 

func NewItnetSyncTxMergeArgs() *ItnetSyncTxMergeArgs

func (*ItnetSyncTxMergeArgs) GetSyncList 

func (p *ItnetSyncTxMergeArgs) GetSyncList() map[int64]int8

func (*ItnetSyncTxMergeArgs) Read 

func (p *ItnetSyncTxMergeArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetSyncTxMergeArgs) ReadField1 

func (p *ItnetSyncTxMergeArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetSyncTxMergeArgs) String 

func (p *ItnetSyncTxMergeArgs) String() string

func (*ItnetSyncTxMergeArgs) Write 

func (p *ItnetSyncTxMergeArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetTimeArgs 

type ItnetTimeArgs struct {
	Pretimenano int64 `thrift:"pretimenano,1" db:"pretimenano" json:"pretimenano"`
	Timenano    int64 `thrift:"timenano,2" db:"timenano" json:"timenano"`
	Num         int16 `thrift:"num,3" db:"num" json:"num"`
	Ir          bool  `thrift:"ir,4" db:"ir" json:"ir"`
}

Attributes:

  • Pretimenano
  • Timenano
  • Num
  • Ir

func NewItnetTimeArgs 

func NewItnetTimeArgs() *ItnetTimeArgs

func (*ItnetTimeArgs) GetIr 

func (p *ItnetTimeArgs) GetIr() bool

func (*ItnetTimeArgs) GetNum 

func (p *ItnetTimeArgs) GetNum() int16

func (*ItnetTimeArgs) GetPretimenano 

func (p *ItnetTimeArgs) GetPretimenano() int64

func (*ItnetTimeArgs) GetTimenano 

func (p *ItnetTimeArgs) GetTimenano() int64

func (*ItnetTimeArgs) Read 

func (p *ItnetTimeArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetTimeArgs) ReadField1 

func (p *ItnetTimeArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetTimeArgs) ReadField2 

func (p *ItnetTimeArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetTimeArgs) ReadField3 

func (p *ItnetTimeArgs) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetTimeArgs) ReadField4 

func (p *ItnetTimeArgs) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*ItnetTimeArgs) String 

func (p *ItnetTimeArgs) String() string

func (*ItnetTimeArgs) Write 

func (p *ItnetTimeArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ItnetWrite 

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

func (*ItnetWrite) Auth 

func (this *ItnetWrite) Auth(ctx context.Context, authKey []byte) (_err error)

Parameters:

  • AuthKey

func (*ItnetWrite) Auth2 

func (this *ItnetWrite) Auth2(ctx context.Context, authKey []byte) (_err error)

Parameters:

  • AuthKey

func (*ItnetWrite) BroadToken 

func (this *ItnetWrite) BroadToken(ctx context.Context, syncId int64, tt *TokenTrans, ack bool) (_err error)

func (*ItnetWrite) CommitTx 

func (this *ItnetWrite) CommitTx(ctx context.Context, syncId int64, txid int64) (_err error)

Parameters:

  • SyncId
  • Txid

func (*ItnetWrite) CommitTx2 

func (this *ItnetWrite) CommitTx2(ctx context.Context, syncId int64, txid int64, commit bool) (_err error)

Parameters:

  • SyncId
  • Commit

func (*ItnetWrite) Ping 

func (this *ItnetWrite) Ping(ctx context.Context, pingstr int64) (_err error)

func (*ItnetWrite) Pon 

func (this *ItnetWrite) Pon(ctx context.Context, ponBeanBytes []byte, id int64) (_err error)

Parameters:

  • Pb

func (*ItnetWrite) Pon2 

func (this *ItnetWrite) Pon2(ctx context.Context, pb *PonBean, id int64) (_err error)

Parameters:

  • Pb

func (*ItnetWrite) Pon3 

func (this *ItnetWrite) Pon3(ctx context.Context, ponBeanBytes []byte, id int64, ack bool) (_err error)

Parameters:

  • Pb

func (*ItnetWrite) PonMerge 

func (this *ItnetWrite) PonMerge(ctx context.Context, pblist []*PonBean, id int64) (_err error)

func (*ItnetWrite) Pong 

func (this *ItnetWrite) Pong(ctx context.Context, pongBs []byte) (_err error)

func (*ItnetWrite) ProxyCall 

func (this *ItnetWrite) ProxyCall(ctx context.Context, syncId int64, paramData []byte, pType int8, ctype int8) (_err error)

func (*ItnetWrite) PubMq 

func (this *ItnetWrite) PubMq(ctx context.Context, syncId int64, mqType int8, bs []byte) (_err error)

func (*ItnetWrite) PullData 

func (this *ItnetWrite) PullData(ctx context.Context, syncId int64, ldb *LogDataBean) (_err error)

func (*ItnetWrite) ReInit 

func (this *ItnetWrite) ReInit(ctx context.Context, syncId int64, sbean *SysBean) (_err error)

func (*ItnetWrite) SyncNode 

func (this *ItnetWrite) SyncNode(ctx context.Context, node *Node, ir bool) (_err error)

Parameters:

  • Node
  • Ir

func (*ItnetWrite) SyncTx 

func (this *ItnetWrite) SyncTx(ctx context.Context, syncId int64, result int8) (_err error)

func (*ItnetWrite) SyncTxMerge 

func (this *ItnetWrite) SyncTxMerge(ctx context.Context, syncList map[int64]int8) (_err error)

func (*ItnetWrite) Time 

func (this *ItnetWrite) Time(ctx context.Context, pretimenano int64, timenano int64, num int16, ir bool) (_err error)

Parameters:

  • Pretimenano
  • Timenano
  • Num
  • Ir

type LoadBean 

type LoadBean struct {
	S    int64            `thrift:"s,1,required" db:"s" json:"s"`
	T    int64            `thrift:"t,2,required" db:"t" json:"t"`
	Logm map[int64]*LogKV `thrift:"logm,3" db:"logm" json:"logm,omitempty"`
}

Attributes:

  • S
  • T
  • Logm
var PonBean_LoadBean_DEFAULT *LoadBean

func NewLoadBean 

func NewLoadBean() *LoadBean

func (*LoadBean) Equals 

func (p *LoadBean) Equals(other *LoadBean) bool

func (*LoadBean) GetLogm 

func (p *LoadBean) GetLogm() map[int64]*LogKV

func (*LoadBean) GetS 

func (p *LoadBean) GetS() int64

func (*LoadBean) GetT 

func (p *LoadBean) GetT() int64

func (*LoadBean) IsSetLogm 

func (p *LoadBean) IsSetLogm() bool

func (*LoadBean) Read 

func (p *LoadBean) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*LoadBean) ReadField1 

func (p *LoadBean) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*LoadBean) ReadField2 

func (p *LoadBean) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*LoadBean) ReadField3 

func (p *LoadBean) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*LoadBean) String 

func (p *LoadBean) String() string

func (*LoadBean) Validate 

func (p *LoadBean) Validate() error

func (*LoadBean) Write 

func (p *LoadBean) Write(ctx context.Context, oprot thrift.TProtocol) error

type LogDataBean 

type LogDataBean struct {
	Type     int8      `thrift:"type,1,required" db:"type" json:"type"`
	LastTime int64     `thrift:"lastTime,2,required" db:"lastTime" json:"lastTime"`
	Txid     int64     `thrift:"txid,3,required" db:"txid" json:"txid"`
	FBean    *FileBean `thrift:"fBean,4" db:"fBean" json:"fBean,omitempty"`
	HasNext  bool      `thrift:"hasNext,5,required" db:"hasNext" json:"hasNext"`
	NotNull  bool      `thrift:"notNull,6,required" db:"notNull" json:"notNull"`
}

Attributes:

  • Type
  • LastTime
  • Txid
  • FBean
  • HasNext
  • NotNull
var ItnetPullDataArgs_Ldb_DEFAULT *LogDataBean

func NewLogDataBean 

func NewLogDataBean() *LogDataBean

func (*LogDataBean) Equals 

func (p *LogDataBean) Equals(other *LogDataBean) bool

func (*LogDataBean) GetFBean 

func (p *LogDataBean) GetFBean() *FileBean

func (*LogDataBean) GetHasNext 

func (p *LogDataBean) GetHasNext() bool

func (*LogDataBean) GetLastTime 

func (p *LogDataBean) GetLastTime() int64

func (*LogDataBean) GetNotNull 

func (p *LogDataBean) GetNotNull() bool

func (*LogDataBean) GetTxid 

func (p *LogDataBean) GetTxid() int64

func (*LogDataBean) GetType 

func (p *LogDataBean) GetType() int8

func (*LogDataBean) IsSetFBean 

func (p *LogDataBean) IsSetFBean() bool

func (*LogDataBean) Read 

func (p *LogDataBean) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*LogDataBean) ReadField1 

func (p *LogDataBean) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*LogDataBean) ReadField2 

func (p *LogDataBean) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*LogDataBean) ReadField3 

func (p *LogDataBean) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*LogDataBean) ReadField4 

func (p *LogDataBean) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*LogDataBean) ReadField5 

func (p *LogDataBean) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*LogDataBean) ReadField6 

func (p *LogDataBean) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*LogDataBean) String 

func (p *LogDataBean) String() string

func (*LogDataBean) Validate 

func (p *LogDataBean) Validate() error

func (*LogDataBean) Write 

func (p *LogDataBean) Write(ctx context.Context, oprot thrift.TProtocol) error

type LogKV 

type LogKV struct {
	Seq   int64  `thrift:"seq,1,required" db:"seq" json:"seq"`
	Key   string `thrift:"key,2,required" db:"key" json:"key"`
	Value []byte `thrift:"value,3" db:"value" json:"value,omitempty"`
}

Attributes:

  • Seq
  • Key
  • Value

func NewLogKV 

func NewLogKV() *LogKV

func (*LogKV) Equals 

func (p *LogKV) Equals(other *LogKV) bool

func (*LogKV) GetKey 

func (p *LogKV) GetKey() string

func (*LogKV) GetSeq 

func (p *LogKV) GetSeq() int64

func (*LogKV) GetValue 

func (p *LogKV) GetValue() []byte

func (*LogKV) IsSetValue 

func (p *LogKV) IsSetValue() bool

func (*LogKV) Read 

func (p *LogKV) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*LogKV) ReadField1 

func (p *LogKV) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*LogKV) ReadField2 

func (p *LogKV) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*LogKV) ReadField3 

func (p *LogKV) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*LogKV) String 

func (p *LogKV) String() string

func (*LogKV) Validate 

func (p *LogKV) Validate() error

func (*LogKV) Write 

func (p *LogKV) Write(ctx context.Context, oprot thrift.TProtocol) error

type LogSeqBean 

type LogSeqBean struct {
	Seq int64 `thrift:"seq,1,required" db:"seq" json:"seq"`
}

Attributes:

  • Seq
var PonBean_SeqBean_DEFAULT *LogSeqBean

func NewLogSeqBean 

func NewLogSeqBean() *LogSeqBean

func (*LogSeqBean) Equals 

func (p *LogSeqBean) Equals(other *LogSeqBean) bool

func (*LogSeqBean) GetSeq 

func (p *LogSeqBean) GetSeq() int64

func (*LogSeqBean) Read 

func (p *LogSeqBean) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*LogSeqBean) ReadField1 

func (p *LogSeqBean) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*LogSeqBean) String 

func (p *LogSeqBean) String() string

func (*LogSeqBean) Validate 

func (p *LogSeqBean) Validate() error

func (*LogSeqBean) Write 

func (p *LogSeqBean) Write(ctx context.Context, oprot thrift.TProtocol) error

type Node 

type Node struct {
	Addr      string           `thrift:"addr,1,required" db:"addr" json:"addr"`
	UUID      int64            `thrift:"uuid,2,required" db:"uuid" json:"uuid"`
	Stat      int8             `thrift:"stat,3,required" db:"stat" json:"stat"`
	MqAddr    string           `thrift:"mqAddr,4,required" db:"mqAddr" json:"mqAddr"`
	CliAddr   string           `thrift:"cliAddr,5,required" db:"cliAddr" json:"cliAddr"`
	AdminAddr string           `thrift:"adminAddr,6,required" db:"adminAddr" json:"adminAddr"`
	Nodekv    map[int64]string `thrift:"nodekv,7" db:"nodekv" json:"nodekv,omitempty"`
	Ns        string           `thrift:"ns,8,required" db:"ns" json:"ns"`
}

Attributes:

  • Addr
  • UUID
  • Stat
  • MqAddr
  • CliAddr
  • AdminAddr
  • Nodekv
  • Ns
var ItnetSyncNodeArgs_Node_DEFAULT *Node

func NewNode 

func NewNode() *Node

func (*Node) Equals 

func (p *Node) Equals(other *Node) bool

func (*Node) GetAddr 

func (p *Node) GetAddr() string

func (*Node) GetAdminAddr 

func (p *Node) GetAdminAddr() string

func (*Node) GetCliAddr 

func (p *Node) GetCliAddr() string

func (*Node) GetMqAddr 

func (p *Node) GetMqAddr() string

func (*Node) GetNodekv 

func (p *Node) GetNodekv() map[int64]string

func (*Node) GetNs 

func (p *Node) GetNs() string

func (*Node) GetStat 

func (p *Node) GetStat() int8

func (*Node) GetUUID 

func (p *Node) GetUUID() int64

func (*Node) IsSetNodekv 

func (p *Node) IsSetNodekv() bool

func (*Node) Read 

func (p *Node) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Node) ReadField1 

func (p *Node) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Node) ReadField2 

func (p *Node) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Node) ReadField3 

func (p *Node) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Node) ReadField4 

func (p *Node) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*Node) ReadField5 

func (p *Node) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*Node) ReadField6 

func (p *Node) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*Node) ReadField7 

func (p *Node) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*Node) ReadField8 

func (p *Node) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*Node) String 

func (p *Node) String() string

func (*Node) Validate 

func (p *Node) Validate() error

func (*Node) Write 

func (p *Node) Write(ctx context.Context, oprot thrift.TProtocol) error

type PON_TYPE 

type PON_TYPE int8

****************************************** 

const (
	PON  PON_TYPE = 1
	PON2 PON_TYPE = 2
)

type PonBean 

type PonBean struct {
	Ptype       int16        `thrift:"ptype,1,required" db:"ptype" json:"ptype"`
	OpType      int16        `thrift:"opType,2,required" db:"opType" json:"opType"`
	Txid        int64        `thrift:"txid,3,required" db:"txid" json:"txid"`
	Fromuuid    int64        `thrift:"fromuuid,4,required" db:"fromuuid" json:"fromuuid"`
	IsPass      bool         `thrift:"isPass,5,required" db:"isPass" json:"isPass"`
	IsFirst     bool         `thrift:"isFirst,6,required" db:"isFirst" json:"isFirst"`
	IsExcu      bool         `thrift:"isExcu,7,required" db:"isExcu" json:"isExcu"`
	IsVerify    bool         `thrift:"isVerify,8,required" db:"isVerify" json:"isVerify"`
	DoCommit    bool         `thrift:"doCommit,9,required" db:"doCommit" json:"doCommit"`
	Mode        int8         `thrift:"mode,10,required" db:"mode" json:"mode"`
	ExecNode    []int64      `thrift:"execNode,11" db:"execNode" json:"execNode,omitempty"`
	ClusterNode []int64      `thrift:"clusterNode,12" db:"clusterNode" json:"clusterNode,omitempty"`
	Key         []byte       `thrift:"key,13" db:"key" json:"key,omitempty"`
	Value       []byte       `thrift:"value,14" db:"value" json:"value,omitempty"`
	Batch       *BatchPacket `thrift:"batch,15" db:"batch" json:"batch,omitempty"`
	Stat        *Stat        `thrift:"stat,16" db:"stat" json:"stat,omitempty"`
	LoadBean    *LoadBean    `thrift:"loadBean,17" db:"loadBean" json:"loadBean,omitempty"`
	TimeBean    *TimeBean    `thrift:"timeBean,18" db:"timeBean" json:"timeBean,omitempty"`
	SeqBean     *LogSeqBean  `thrift:"seqBean,19" db:"seqBean" json:"seqBean,omitempty"`
	RunUUID     []int64      `thrift:"runUUID,20" db:"runUUID" json:"runUUID,omitempty"`
	SyncId      *int64       `thrift:"syncId,21" db:"syncId" json:"syncId,omitempty"`
	Pbtime      []byte       `thrift:"pbtime,22" db:"pbtime" json:"pbtime,omitempty"`
}

Attributes:

  • Ptype
  • OpType
  • Txid
  • Fromuuid
  • IsPass
  • IsFirst
  • IsExcu
  • IsVerify
  • DoCommit
  • Mode
  • ExecNode
  • ClusterNode
  • Key
  • Value
  • Batch
  • Stat
  • LoadBean
  • TimeBean
  • SeqBean
  • RunUUID
  • SyncId
  • Pbtime
var ItnetPon2Args_Pb_DEFAULT *PonBean

func DecodePonBean 

func DecodePonBean(bs []byte) (pb *PonBean)

func NewPonBean 

func NewPonBean() *PonBean

func (*PonBean) Equals 

func (p *PonBean) Equals(other *PonBean) bool

func (*PonBean) GetBatch 

func (p *PonBean) GetBatch() *BatchPacket

func (*PonBean) GetClusterNode 

func (p *PonBean) GetClusterNode() []int64

func (*PonBean) GetDoCommit 

func (p *PonBean) GetDoCommit() bool

func (*PonBean) GetExecNode 

func (p *PonBean) GetExecNode() []int64

func (*PonBean) GetFromuuid 

func (p *PonBean) GetFromuuid() int64

func (*PonBean) GetIsExcu 

func (p *PonBean) GetIsExcu() bool

func (*PonBean) GetIsFirst 

func (p *PonBean) GetIsFirst() bool

func (*PonBean) GetIsPass 

func (p *PonBean) GetIsPass() bool

func (*PonBean) GetIsVerify 

func (p *PonBean) GetIsVerify() bool

func (*PonBean) GetKey 

func (p *PonBean) GetKey() []byte

func (*PonBean) GetLoadBean 

func (p *PonBean) GetLoadBean() *LoadBean

func (*PonBean) GetMode 

func (p *PonBean) GetMode() int8

func (*PonBean) GetOpType 

func (p *PonBean) GetOpType() int16

func (*PonBean) GetPbtime 

func (p *PonBean) GetPbtime() []byte

func (*PonBean) GetPtype 

func (p *PonBean) GetPtype() int16

func (*PonBean) GetRunUUID 

func (p *PonBean) GetRunUUID() []int64

func (*PonBean) GetSeqBean 

func (p *PonBean) GetSeqBean() *LogSeqBean

func (*PonBean) GetStat 

func (p *PonBean) GetStat() *Stat

func (*PonBean) GetSyncId 

func (p *PonBean) GetSyncId() int64

func (*PonBean) GetTimeBean 

func (p *PonBean) GetTimeBean() *TimeBean

func (*PonBean) GetTxid 

func (p *PonBean) GetTxid() int64

func (*PonBean) GetValue 

func (p *PonBean) GetValue() []byte

func (*PonBean) IsSetBatch 

func (p *PonBean) IsSetBatch() bool

func (*PonBean) IsSetClusterNode 

func (p *PonBean) IsSetClusterNode() bool

func (*PonBean) IsSetExecNode 

func (p *PonBean) IsSetExecNode() bool

func (*PonBean) IsSetKey 

func (p *PonBean) IsSetKey() bool

func (*PonBean) IsSetLoadBean 

func (p *PonBean) IsSetLoadBean() bool

func (*PonBean) IsSetPbtime 

func (p *PonBean) IsSetPbtime() bool

func (*PonBean) IsSetRunUUID 

func (p *PonBean) IsSetRunUUID() bool

func (*PonBean) IsSetSeqBean 

func (p *PonBean) IsSetSeqBean() bool

func (*PonBean) IsSetStat 

func (p *PonBean) IsSetStat() bool

func (*PonBean) IsSetSyncId 

func (p *PonBean) IsSetSyncId() bool

func (*PonBean) IsSetTimeBean 

func (p *PonBean) IsSetTimeBean() bool

func (*PonBean) IsSetValue 

func (p *PonBean) IsSetValue() bool

func (*PonBean) Read 

func (p *PonBean) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField1 

func (p *PonBean) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField10 

func (p *PonBean) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField11 

func (p *PonBean) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField12 

func (p *PonBean) ReadField12(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField13 

func (p *PonBean) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField14 

func (p *PonBean) ReadField14(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField15 

func (p *PonBean) ReadField15(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField16 

func (p *PonBean) ReadField16(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField17 

func (p *PonBean) ReadField17(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField18 

func (p *PonBean) ReadField18(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField19 

func (p *PonBean) ReadField19(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField2 

func (p *PonBean) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField20 

func (p *PonBean) ReadField20(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField21 

func (p *PonBean) ReadField21(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField22 

func (p *PonBean) ReadField22(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField3 

func (p *PonBean) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField4 

func (p *PonBean) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField5 

func (p *PonBean) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField6 

func (p *PonBean) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField7 

func (p *PonBean) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField8 

func (p *PonBean) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) ReadField9 

func (p *PonBean) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*PonBean) String 

func (p *PonBean) String() string

func (*PonBean) Validate 

func (p *PonBean) Validate() error

func (*PonBean) Write 

func (p *PonBean) Write(ctx context.Context, oprot thrift.TProtocol) error

type Stat 

type Stat struct {
	Stat     int8  `thrift:"stat,1,required" db:"stat" json:"stat"`
	Timenano int64 `thrift:"timenano,2,required" db:"timenano" json:"timenano"`
}

Attributes:

  • Stat
  • Timenano
var PonBean_Stat_DEFAULT *Stat

func NewStat 

func NewStat() *Stat

func (*Stat) Equals 

func (p *Stat) Equals(other *Stat) bool

func (*Stat) GetStat 

func (p *Stat) GetStat() int8

func (*Stat) GetTimenano 

func (p *Stat) GetTimenano() int64

func (*Stat) Read 

func (p *Stat) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Stat) ReadField1 

func (p *Stat) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Stat) ReadField2 

func (p *Stat) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Stat) String 

func (p *Stat) String() string

func (*Stat) Validate 

func (p *Stat) Validate() error

func (*Stat) Write 

func (p *Stat) Write(ctx context.Context, oprot thrift.TProtocol) error

type SysBean 

type SysBean struct {
	DBMode       int8  `thrift:"DBMode,1,required" db:"DBMode" json:"DBMode"`
	STORENODENUM int32 `thrift:"STORENODENUM,2,required" db:"STORENODENUM" json:"STORENODENUM"`
	REMOVEUUID   int64 `thrift:"REMOVEUUID,3,required" db:"REMOVEUUID" json:"REMOVEUUID"`
}

Attributes:

  • DBMode
  • STORENODENUM
  • REMOVEUUID
var ItnetReInitArgs_Sbean_DEFAULT *SysBean

func NewSysBean 

func NewSysBean() *SysBean

func (*SysBean) Equals 

func (p *SysBean) Equals(other *SysBean) bool

func (*SysBean) GetDBMode 

func (p *SysBean) GetDBMode() int8

func (*SysBean) GetREMOVEUUID 

func (p *SysBean) GetREMOVEUUID() int64

func (*SysBean) GetSTORENODENUM 

func (p *SysBean) GetSTORENODENUM() int32

func (*SysBean) Read 

func (p *SysBean) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*SysBean) ReadField1 

func (p *SysBean) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*SysBean) ReadField2 

func (p *SysBean) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*SysBean) ReadField3 

func (p *SysBean) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*SysBean) String 

func (p *SysBean) String() string

func (*SysBean) Validate 

func (p *SysBean) Validate() error

func (*SysBean) Write 

func (p *SysBean) Write(ctx context.Context, oprot thrift.TProtocol) error

type TimeBean 

type TimeBean struct {
	IsPass  bool  `thrift:"isPass,1,required" db:"isPass" json:"isPass"`
	RunUUID int64 `thrift:"runUUID,2,required" db:"runUUID" json:"runUUID"`
}

Attributes:

  • IsPass
  • RunUUID
var PonBean_TimeBean_DEFAULT *TimeBean

func NewTimeBean 

func NewTimeBean() *TimeBean

func (*TimeBean) Equals 

func (p *TimeBean) Equals(other *TimeBean) bool

func (*TimeBean) GetIsPass 

func (p *TimeBean) GetIsPass() bool

func (*TimeBean) GetRunUUID 

func (p *TimeBean) GetRunUUID() int64

func (*TimeBean) Read 

func (p *TimeBean) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TimeBean) ReadField1 

func (p *TimeBean) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TimeBean) ReadField2 

func (p *TimeBean) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TimeBean) String 

func (p *TimeBean) String() string

func (*TimeBean) Validate 

func (p *TimeBean) Validate() error

func (*TimeBean) Write 

func (p *TimeBean) Write(ctx context.Context, oprot thrift.TProtocol) error

type TokenTrans 

type TokenTrans struct {
	ReqType   int8              `thrift:"ReqType,1,required" db:"ReqType" json:"ReqType"`
	Str       string            `thrift:"Str,2,required" db:"Str" json:"Str"`
	TokenFlag int64             `thrift:"TokenFlag,3,required" db:"TokenFlag" json:"TokenFlag"`
	Status    int8              `thrift:"Status,4,required" db:"Status" json:"Status"`
	Token     string            `thrift:"Token,5,required" db:"Token" json:"Token"`
	SyncId    *int64            `thrift:"SyncId,6" db:"SyncId" json:"SyncId,omitempty"`
	Bs        []byte            `thrift:"bs,7" db:"bs" json:"bs,omitempty"`
	Extra     map[string][]byte `thrift:"Extra,8" db:"Extra" json:"Extra,omitempty"`
	List      []*TokenTrans     `thrift:"List,9" db:"List" json:"List,omitempty"`
	BackOk    *bool             `thrift:"BackOk,10" db:"BackOk" json:"BackOk,omitempty"`
	ForceBack *bool             `thrift:"ForceBack,11" db:"ForceBack" json:"ForceBack,omitempty"`
}

Attributes:

  • ReqType
  • Str
  • TokenFlag
  • Status
  • Token
  • SyncId
  • Bs
  • Extra
  • List
  • BackOk
  • ForceBack
var ItnetBroadTokenArgs_Tt_DEFAULT *TokenTrans

func NewTokenTrans 

func NewTokenTrans() *TokenTrans

func (*TokenTrans) Equals 

func (p *TokenTrans) Equals(other *TokenTrans) bool

func (*TokenTrans) GetBackOk 

func (p *TokenTrans) GetBackOk() bool

func (*TokenTrans) GetBs 

func (p *TokenTrans) GetBs() []byte

func (*TokenTrans) GetExtra 

func (p *TokenTrans) GetExtra() map[string][]byte

func (*TokenTrans) GetForceBack 

func (p *TokenTrans) GetForceBack() bool

func (*TokenTrans) GetList 

func (p *TokenTrans) GetList() []*TokenTrans

func (*TokenTrans) GetReqType 

func (p *TokenTrans) GetReqType() int8

func (*TokenTrans) GetStatus 

func (p *TokenTrans) GetStatus() int8

func (*TokenTrans) GetStr 

func (p *TokenTrans) GetStr() string

func (*TokenTrans) GetSyncId 

func (p *TokenTrans) GetSyncId() int64

func (*TokenTrans) GetToken 

func (p *TokenTrans) GetToken() string

func (*TokenTrans) GetTokenFlag 

func (p *TokenTrans) GetTokenFlag() int64

func (*TokenTrans) IsSetBackOk 

func (p *TokenTrans) IsSetBackOk() bool

func (*TokenTrans) IsSetBs 

func (p *TokenTrans) IsSetBs() bool

func (*TokenTrans) IsSetExtra 

func (p *TokenTrans) IsSetExtra() bool

func (*TokenTrans) IsSetForceBack 

func (p *TokenTrans) IsSetForceBack() bool

func (*TokenTrans) IsSetList 

func (p *TokenTrans) IsSetList() bool

func (*TokenTrans) IsSetSyncId 

func (p *TokenTrans) IsSetSyncId() bool

func (*TokenTrans) Read 

func (p *TokenTrans) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField1 

func (p *TokenTrans) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField10 

func (p *TokenTrans) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField11 

func (p *TokenTrans) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField2 

func (p *TokenTrans) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField3 

func (p *TokenTrans) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField4 

func (p *TokenTrans) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField5 

func (p *TokenTrans) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField6 

func (p *TokenTrans) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField7 

func (p *TokenTrans) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField8 

func (p *TokenTrans) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) ReadField9 

func (p *TokenTrans) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TokenTrans) String 

func (p *TokenTrans) String() string

func (*TokenTrans) Validate 

func (p *TokenTrans) Validate() error

func (*TokenTrans) Write 

func (p *TokenTrans) Write(ctx context.Context, oprot thrift.TProtocol) error

type UUID 

type UUID int64

Source Files

View all Source files

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.