sysflag

Documentation

Index

• Constants
• func BuildSysFlag(commitOffset bool, suspend bool, subscription bool, classFilter bool) int
• func ClearCommitOffsetFlag(sysFlag int) int
• func ClearCompressedFlag(flag int) int
• func ClearUnitFlag(sysFlag int) int
• func ClearUnitSubFlag(sysFlag int) int
• func GetTransactionValue(flag int) int
• func HasClassFilterFlag(sysFlag int) bool
• func HasCommitOffsetFlag(sysFlag int) bool
• func HasSubscriptionFlag(sysFlag int) bool
• func HasSuspendFlag(sysFlag int) bool
• func HasUnitFlag(sysFlag int) bool
• func HasUnitSubFlag(sysFlag int) bool
• func ResetTransactionValue(flag int, ty int) int
• func SetUnitFlag(sysFlag int) int
• func SetUnitSubFlag(sysFlag int) int
• func TopicBuildSysFlag(unit bool, hasUnitSub bool) int

Constants

const (
	// SysFlag
	CompressedFlag = 0x1 << 0
	MultiTagsFlag  = 0x1 << 1

	// 7 6 5 4 3 2 1 0<br>
	// SysFlag 事务相关，从左属，2与3
	TransactionNotType      = 0x0 << 2
	TransactionPreparedType = 0x1 << 2
	TransactionCommitType   = 0x2 << 2
	TransactionRollbackType = 0x3 << 2
)

MessageSysFlag: 消息flag Author: yintongqiang Since: 2017/8/10

const (
	FLAG_COMMIT_OFFSET = 0x1 << 0
	FLAG_SUSPEND       = 0x1 << 1
	FLAG_SUBSCRIPTION  = 0x1 << 2
	FLAG_CLASS_FILTER  = 0x1 << 3
)

PullSysFlag: 拉取消费flag Author: yintongqiang Since: 2017/8/14

const (
	FLAG_UNIT     = 0x1 << 0
	FLAG_UNIT_SUB = 0x1 << 1
)

TopicSysFlag topic 配置标识 Author gaoyanlei Since 2017/8/16

Functions

func BuildSysFlag

func BuildSysFlag(commitOffset bool, suspend bool, subscription bool, classFilter bool) int

func ClearCommitOffsetFlag

func ClearCommitOffsetFlag(sysFlag int) int

func ClearCompressedFlag

func ClearCompressedFlag(flag int) int

func ClearUnitFlag

func ClearUnitFlag(sysFlag int) int

func ClearUnitSubFlag

func ClearUnitSubFlag(sysFlag int) int

func GetTransactionValue

func GetTransactionValue(flag int) int

func HasClassFilterFlag

func HasClassFilterFlag(sysFlag int) bool

func HasCommitOffsetFlag

func HasCommitOffsetFlag(sysFlag int) bool

func HasSubscriptionFlag

func HasSubscriptionFlag(sysFlag int) bool

func HasSuspendFlag

func HasSuspendFlag(sysFlag int) bool

func HasUnitFlag

func HasUnitFlag(sysFlag int) bool

func HasUnitSubFlag

func HasUnitSubFlag(sysFlag int) bool

func ResetTransactionValue

func ResetTransactionValue(flag int, ty int) int

func SetUnitFlag

func SetUnitFlag(sysFlag int) int

func SetUnitSubFlag

func SetUnitSubFlag(sysFlag int) int

func TopicBuildSysFlag

func TopicBuildSysFlag(unit bool, hasUnitSub bool) int