replication

package
v0.0.0-...-5d3959e Latest Latest
Warning

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

Go to latest
Published: Mar 28, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

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

Jump to

Keyboard shortcuts

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