Documentation ¶
Overview ¶
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
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
Variables ¶
This section is empty.
Functions ¶
func BuildSysFlag ¶
func ClearCommitOffsetFlag ¶
func ClearCompressedFlag ¶
func ClearUnitFlag ¶
func ClearUnitSubFlag ¶
func GetTransactionValue ¶
func HasClassFilterFlag ¶
func HasCommitOffsetFlag ¶
func HasSubscriptionFlag ¶
func HasSuspendFlag ¶
func HasUnitFlag ¶
func HasUnitSubFlag ¶
func ResetTransactionValue ¶
func SetUnitFlag ¶
func SetUnitSubFlag ¶
func TopicBuildSysFlag ¶
Types ¶
This section is empty.