replication

package
v0.0.0-...-7ceef5d Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 2 more Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AppInfo_Duplicating_DEFAULT bool = false
View Source 
var AppInfo_IsBulkLoading_DEFAULT bool = false
View Source 
var GoUnusedProtection__ int
View Source 
var PartitionConfiguration_HpLastDrops_DEFAULT []*base.HostPort
View Source 
var PartitionConfiguration_HpPrimary_DEFAULT *base.HostPort
View Source 
var PartitionConfiguration_HpSecondaries_DEFAULT []*base.HostPort
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 AppInfo 

type AppInfo struct {
	Status             AppStatus         `thrift:"status,1" db:"status" json:"status"`
	AppType            string            `thrift:"app_type,2" db:"app_type" json:"app_type"`
	AppName            string            `thrift:"app_name,3" db:"app_name" json:"app_name"`
	AppID              int32             `thrift:"app_id,4" db:"app_id" json:"app_id"`
	PartitionCount     int32             `thrift:"partition_count,5" db:"partition_count" json:"partition_count"`
	Envs               map[string]string `thrift:"envs,6" db:"envs" json:"envs"`
	IsStateful         bool              `thrift:"is_stateful,7" db:"is_stateful" json:"is_stateful"`
	MaxReplicaCount    int32             `thrift:"max_replica_count,8" db:"max_replica_count" json:"max_replica_count"`
	ExpireSecond       int64             `thrift:"expire_second,9" db:"expire_second" json:"expire_second"`
	CreateSecond       int64             `thrift:"create_second,10" db:"create_second" json:"create_second"`
	DropSecond         int64             `thrift:"drop_second,11" db:"drop_second" json:"drop_second"`
	Duplicating        bool              `thrift:"duplicating,12" db:"duplicating" json:"duplicating"`
	InitPartitionCount int32             `thrift:"init_partition_count,13" db:"init_partition_count" json:"init_partition_count"`
	IsBulkLoading      bool              `thrift:"is_bulk_loading,14" db:"is_bulk_loading" json:"is_bulk_loading"`
}

Attributes:

  • Status
  • AppType
  • AppName
  • AppID
  • PartitionCount
  • Envs
  • IsStateful
  • MaxReplicaCount
  • ExpireSecond
  • CreateSecond
  • DropSecond
  • Duplicating
  • InitPartitionCount
  • IsBulkLoading

func NewAppInfo 

func NewAppInfo() *AppInfo

func (*AppInfo) GetAppID 

func (p *AppInfo) GetAppID() int32

func (*AppInfo) GetAppName 

func (p *AppInfo) GetAppName() string

func (*AppInfo) GetAppType 

func (p *AppInfo) GetAppType() string

func (*AppInfo) GetCreateSecond 

func (p *AppInfo) GetCreateSecond() int64

func (*AppInfo) GetDropSecond 

func (p *AppInfo) GetDropSecond() int64

func (*AppInfo) GetDuplicating 

func (p *AppInfo) GetDuplicating() bool

func (*AppInfo) GetEnvs 

func (p *AppInfo) GetEnvs() map[string]string

func (*AppInfo) GetExpireSecond 

func (p *AppInfo) GetExpireSecond() int64

func (*AppInfo) GetInitPartitionCount 

func (p *AppInfo) GetInitPartitionCount() int32

func (*AppInfo) GetIsBulkLoading 

func (p *AppInfo) GetIsBulkLoading() bool

func (*AppInfo) GetIsStateful 

func (p *AppInfo) GetIsStateful() bool

func (*AppInfo) GetMaxReplicaCount 

func (p *AppInfo) GetMaxReplicaCount() int32

func (*AppInfo) GetPartitionCount 

func (p *AppInfo) GetPartitionCount() int32

func (*AppInfo) GetStatus 

func (p *AppInfo) GetStatus() AppStatus

func (*AppInfo) IsSetDuplicating 

func (p *AppInfo) IsSetDuplicating() bool

func (*AppInfo) IsSetIsBulkLoading 

func (p *AppInfo) IsSetIsBulkLoading() bool

func (*AppInfo) Read 

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

func (*AppInfo) ReadField1 

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

func (*AppInfo) ReadField10 

func (p *AppInfo) ReadField10(iprot thrift.TProtocol) error

func (*AppInfo) ReadField11 

func (p *AppInfo) ReadField11(iprot thrift.TProtocol) error

func (*AppInfo) ReadField12 

func (p *AppInfo) ReadField12(iprot thrift.TProtocol) error

func (*AppInfo) ReadField13 

func (p *AppInfo) ReadField13(iprot thrift.TProtocol) error

func (*AppInfo) ReadField14 

func (p *AppInfo) ReadField14(iprot thrift.TProtocol) error

func (*AppInfo) ReadField2 

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

func (*AppInfo) ReadField3 

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

func (*AppInfo) ReadField4 

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

func (*AppInfo) ReadField5 

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

func (*AppInfo) ReadField6 

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

func (*AppInfo) ReadField7 

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

func (*AppInfo) ReadField8 

func (p *AppInfo) ReadField8(iprot thrift.TProtocol) error

func (*AppInfo) ReadField9 

func (p *AppInfo) ReadField9(iprot thrift.TProtocol) error

func (*AppInfo) String 

func (p *AppInfo) String() string

func (*AppInfo) Write 

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

type AppStatus 

type AppStatus int64
const (
	AppStatus_AS_INVALID       AppStatus = 0
	AppStatus_AS_AVAILABLE     AppStatus = 1
	AppStatus_AS_CREATING      AppStatus = 2
	AppStatus_AS_CREATE_FAILED AppStatus = 3
	AppStatus_AS_DROPPING      AppStatus = 4
	AppStatus_AS_DROP_FAILED   AppStatus = 5
	AppStatus_AS_DROPPED       AppStatus = 6
	AppStatus_AS_RECALLING     AppStatus = 7
)

func AppStatusFromString 

func AppStatusFromString(s string) (AppStatus, error)

func AppStatusPtr 

func AppStatusPtr(v AppStatus) *AppStatus

func (AppStatus) MarshalText 

func (p AppStatus) MarshalText() ([]byte, error)

func (*AppStatus) Scan 

func (p *AppStatus) Scan(value interface{}) error

func (AppStatus) String 

func (p AppStatus) String() string

func (*AppStatus) UnmarshalText 

func (p *AppStatus) UnmarshalText(text []byte) error

func (*AppStatus) Value 

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

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"`
	PartitionFlags      int32              `thrift:"partition_flags,8" db:"partition_flags" json:"partition_flags"`
	HpPrimary           *base.HostPort     `thrift:"hp_primary,9" db:"hp_primary" json:"hp_primary,omitempty"`
	HpSecondaries       []*base.HostPort   `thrift:"hp_secondaries,10" db:"hp_secondaries" json:"hp_secondaries,omitempty"`
	HpLastDrops         []*base.HostPort   `thrift:"hp_last_drops,11" db:"hp_last_drops" json:"hp_last_drops,omitempty"`
}

Attributes:

  • Pid
  • Ballot
  • MaxReplicaCount
  • Primary
  • Secondaries
  • LastDrops
  • LastCommittedDecree
  • PartitionFlags
  • HpPrimary
  • HpSecondaries
  • HpLastDrops

func NewPartitionConfiguration 

func NewPartitionConfiguration() *PartitionConfiguration

func (*PartitionConfiguration) GetBallot 

func (p *PartitionConfiguration) GetBallot() int64

func (*PartitionConfiguration) GetHpLastDrops 

func (p *PartitionConfiguration) GetHpLastDrops() []*base.HostPort

func (*PartitionConfiguration) GetHpPrimary 

func (p *PartitionConfiguration) GetHpPrimary() *base.HostPort

func (*PartitionConfiguration) GetHpSecondaries 

func (p *PartitionConfiguration) GetHpSecondaries() []*base.HostPort

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

func (p *PartitionConfiguration) GetPartitionFlags() 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) IsSetHpLastDrops 

func (p *PartitionConfiguration) IsSetHpLastDrops() bool

func (*PartitionConfiguration) IsSetHpPrimary 

func (p *PartitionConfiguration) IsSetHpPrimary() bool

func (*PartitionConfiguration) IsSetHpSecondaries 

func (p *PartitionConfiguration) IsSetHpSecondaries() bool

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

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

func (*PartitionConfiguration) ReadField11 

func (p *PartitionConfiguration) ReadField11(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) ReadField8 

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

func (*PartitionConfiguration) ReadField9 

func (p *PartitionConfiguration) ReadField9(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.