replication

package
v0.0.0-...-ba0e684 Latest Latest
Warning

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

 Go to latest Published: May 19, 2022 License: Apache-2.0 Imports: 6 Imported by: 14

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var PartitionConfiguration_Pid_DEFAULT *base.Gpid
View Source 
var PartitionConfiguration_Primary_DEFAULT *base.RPCAddress
View Source 
var QueryCfgResponse_Err_DEFAULT *base.ErrorCode

Functions

This section is empty.

Types

type PartitionConfiguration 

type PartitionConfiguration struct {
	Pid                 *base.Gpid         `thrift:"pid,1" db:"pid" json:"pid"`
	Ballot              int64              `thrift:"ballot,2" db:"ballot" json:"ballot"`
	MaxReplicaCount     int32              `thrift:"max_replica_count,3" db:"max_replica_count" json:"max_replica_count"`
	Primary             *base.RPCAddress   `thrift:"primary,4" db:"primary" json:"primary"`
	Secondaries         []*base.RPCAddress `thrift:"secondaries,5" db:"secondaries" json:"secondaries"`
	LastDrops           []*base.RPCAddress `thrift:"last_drops,6" db:"last_drops" json:"last_drops"`
	LastCommittedDecree int64              `thrift:"last_committed_decree,7" db:"last_committed_decree" json:"last_committed_decree"`
}

Attributes:

  • Pid
  • Ballot
  • MaxReplicaCount
  • Primary
  • Secondaries
  • LastDrops
  • LastCommittedDecree

func NewPartitionConfiguration 

func NewPartitionConfiguration() *PartitionConfiguration

func (*PartitionConfiguration) GetBallot 

func (p *PartitionConfiguration) GetBallot() int64

func (*PartitionConfiguration) GetLastCommittedDecree 

func (p *PartitionConfiguration) GetLastCommittedDecree() int64

func (*PartitionConfiguration) GetLastDrops 

func (p *PartitionConfiguration) GetLastDrops() []*base.RPCAddress

func (*PartitionConfiguration) GetMaxReplicaCount 

func (p *PartitionConfiguration) GetMaxReplicaCount() int32

func (*PartitionConfiguration) GetPid 

func (p *PartitionConfiguration) GetPid() *base.Gpid

func (*PartitionConfiguration) GetPrimary 

func (p *PartitionConfiguration) GetPrimary() *base.RPCAddress

func (*PartitionConfiguration) GetSecondaries 

func (p *PartitionConfiguration) GetSecondaries() []*base.RPCAddress

func (*PartitionConfiguration) IsSetPid 

func (p *PartitionConfiguration) IsSetPid() bool

func (*PartitionConfiguration) IsSetPrimary 

func (p *PartitionConfiguration) IsSetPrimary() bool

func (*PartitionConfiguration) Read 

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

func (*PartitionConfiguration) ReadField1 

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

func (*PartitionConfiguration) ReadField2 

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

func (*PartitionConfiguration) ReadField3 

func (p *PartitionConfiguration) ReadField3(iprot thrift.TProtocol) error

func (*PartitionConfiguration) ReadField4 

func (p *PartitionConfiguration) ReadField4(iprot thrift.TProtocol) error

func (*PartitionConfiguration) ReadField5 

func (p *PartitionConfiguration) ReadField5(iprot thrift.TProtocol) error

func (*PartitionConfiguration) ReadField6 

func (p *PartitionConfiguration) ReadField6(iprot thrift.TProtocol) error

func (*PartitionConfiguration) ReadField7 

func (p *PartitionConfiguration) ReadField7(iprot thrift.TProtocol) error

func (*PartitionConfiguration) String 

func (p *PartitionConfiguration) String() string

func (*PartitionConfiguration) Write 

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

type QueryCfgRequest 

type QueryCfgRequest struct {
	AppName          string  `thrift:"app_name,1" db:"app_name" json:"app_name"`
	PartitionIndices []int32 `thrift:"partition_indices,2" db:"partition_indices" json:"partition_indices"`
}

Attributes:

  • AppName
  • PartitionIndices

func NewQueryCfgRequest 

func NewQueryCfgRequest() *QueryCfgRequest

func (*QueryCfgRequest) GetAppName 

func (p *QueryCfgRequest) GetAppName() string

func (*QueryCfgRequest) GetPartitionIndices 

func (p *QueryCfgRequest) GetPartitionIndices() []int32

func (*QueryCfgRequest) Read 

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

func (*QueryCfgRequest) ReadField1 

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

func (*QueryCfgRequest) ReadField2 

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

func (*QueryCfgRequest) String 

func (p *QueryCfgRequest) String() string

func (*QueryCfgRequest) Write 

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

type QueryCfgResponse 

type QueryCfgResponse struct {
	Err            *base.ErrorCode           `thrift:"err,1" db:"err" json:"err"`
	AppID          int32                     `thrift:"app_id,2" db:"app_id" json:"app_id"`
	PartitionCount int32                     `thrift:"partition_count,3" db:"partition_count" json:"partition_count"`
	IsStateful     bool                      `thrift:"is_stateful,4" db:"is_stateful" json:"is_stateful"`
	Partitions     []*PartitionConfiguration `thrift:"partitions,5" db:"partitions" json:"partitions"`
}

Attributes:

  • Err
  • AppID
  • PartitionCount
  • IsStateful
  • Partitions

func NewQueryCfgResponse 

func NewQueryCfgResponse() *QueryCfgResponse

func (*QueryCfgResponse) GetAppID 

func (p *QueryCfgResponse) GetAppID() int32

func (*QueryCfgResponse) GetErr 

func (p *QueryCfgResponse) GetErr() *base.ErrorCode

func (*QueryCfgResponse) GetIsStateful 

func (p *QueryCfgResponse) GetIsStateful() bool

func (*QueryCfgResponse) GetPartitionCount 

func (p *QueryCfgResponse) GetPartitionCount() int32

func (*QueryCfgResponse) GetPartitions 

func (p *QueryCfgResponse) GetPartitions() []*PartitionConfiguration

func (*QueryCfgResponse) IsSetErr 

func (p *QueryCfgResponse) IsSetErr() bool

func (*QueryCfgResponse) Read 

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

func (*QueryCfgResponse) ReadField1 

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

func (*QueryCfgResponse) ReadField2 

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

func (*QueryCfgResponse) ReadField3 

func (p *QueryCfgResponse) ReadField3(iprot thrift.TProtocol) error

func (*QueryCfgResponse) ReadField4 

func (p *QueryCfgResponse) ReadField4(iprot thrift.TProtocol) error

func (*QueryCfgResponse) ReadField5 

func (p *QueryCfgResponse) ReadField5(iprot thrift.TProtocol) error

func (*QueryCfgResponse) String 

func (p *QueryCfgResponse) String() string

func (*QueryCfgResponse) Write 

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

type RequestMeta 

type RequestMeta struct {
	AppID           int32 `thrift:"app_id,1" db:"app_id" json:"app_id"`
	PartitionIndex  int32 `thrift:"partition_index,2" db:"partition_index" json:"partition_index"`
	ClientTimeout   int32 `thrift:"client_timeout,3" db:"client_timeout" json:"client_timeout"`
	PartitionHash   int64 `thrift:"partition_hash,4" db:"partition_hash" json:"partition_hash"`
	IsBackupRequest bool  `thrift:"is_backup_request,5" db:"is_backup_request" json:"is_backup_request"`
}

Attributes:

  • AppID
  • PartitionIndex
  • ClientTimeout
  • PartitionHash
  • IsBackupRequest

func NewRequestMeta 

func NewRequestMeta() *RequestMeta

func (*RequestMeta) GetAppID 

func (p *RequestMeta) GetAppID() int32

func (*RequestMeta) GetClientTimeout 

func (p *RequestMeta) GetClientTimeout() int32

func (*RequestMeta) GetIsBackupRequest 

func (p *RequestMeta) GetIsBackupRequest() bool

func (*RequestMeta) GetPartitionHash 

func (p *RequestMeta) GetPartitionHash() int64

func (*RequestMeta) GetPartitionIndex 

func (p *RequestMeta) GetPartitionIndex() int32

func (*RequestMeta) Read 

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

func (*RequestMeta) ReadField1 

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

func (*RequestMeta) ReadField2 

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

func (*RequestMeta) ReadField3 

func (p *RequestMeta) ReadField3(iprot thrift.TProtocol) error

func (*RequestMeta) ReadField4 

func (p *RequestMeta) ReadField4(iprot thrift.TProtocol) error

func (*RequestMeta) ReadField5 

func (p *RequestMeta) ReadField5(iprot thrift.TProtocol) error

func (*RequestMeta) String 

func (p *RequestMeta) String() string

func (*RequestMeta) Write 

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

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.