rebalance

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
• type LockEntry
  • func NewLockEntry() *LockEntry
  • func (entry *LockEntry) IsExpired() bool
  • func (entry *LockEntry) IsLocked(clientId string) bool
• type LockEntryTable
  • func NewLockEntryTable() *LockEntryTable
  • func (lockTable *LockEntryTable) Foreach(fn func(k *message.MessageQueue, v *LockEntry))
  • func (lockTable *LockEntryTable) Get(key *message.MessageQueue) *LockEntry
  • func (lockTable *LockEntryTable) Put(key *message.MessageQueue, value *LockEntry)
  • func (lockTable *LockEntryTable) Remove(key *message.MessageQueue)
• type MQLockTable
  • func NewMQLockTable() *MQLockTable
  • func (lockTable *MQLockTable) Foreach(fn func(k string, v *LockEntryTable))
  • func (lockTable *MQLockTable) Get(key string) *LockEntryTable
  • func (lockTable *MQLockTable) Put(key string, value *LockEntryTable)
  • func (lockTable *MQLockTable) Remove(key string)

Constants

const (
	BROKER_REBLANCE_LOCKMAXLIVETIME = "boltmq.broker.rebalance.lockMaxLiveTime"
)

Types

type LockEntry

type LockEntry struct {
	ClientId            string
	LastUpdateTimestamp int64
}

LockEntry LockEntry Author: rongzhihong Since: 2017/9/19

func NewLockEntry

func NewLockEntry() *LockEntry

func (*LockEntry) IsExpired

func (entry *LockEntry) IsExpired() bool

func (*LockEntry) IsLocked

func (entry *LockEntry) IsLocked(clientId string) bool

type LockEntryTable

type LockEntryTable struct {
	// contains filtered or unexported fields
}

LockEntryTable.lock.LockEntryTable Author rongzhihong Since 2017/9/20

func NewLockEntryTable

func NewLockEntryTable() *LockEntryTable

func (*LockEntryTable) Foreach

func (lockTable *LockEntryTable) Foreach(fn func(k *message.MessageQueue, v *LockEntry))

func (*LockEntryTable) Get

func (lockTable *LockEntryTable) Get(key *message.MessageQueue) *LockEntry

func (*LockEntryTable) Put

func (lockTable *LockEntryTable) Put(key *message.MessageQueue, value *LockEntry)

func (*LockEntryTable) Remove

func (lockTable *LockEntryTable) Remove(key *message.MessageQueue)

type MQLockTable

type MQLockTable struct {
	// contains filtered or unexported fields
}

MQLockTable MQLockTable Author rongzhihong Since 2017/9/20

func NewMQLockTable

func NewMQLockTable() *MQLockTable

func (*MQLockTable) Foreach

func (lockTable *MQLockTable) Foreach(fn func(k string, v *LockEntryTable))

func (*MQLockTable) Get

func (lockTable *MQLockTable) Get(key string) *LockEntryTable

func (*MQLockTable) Put

func (lockTable *MQLockTable) Put(key string, value *LockEntryTable)

func (*MQLockTable) Remove

func (lockTable *MQLockTable) Remove(key string)