limiter

Documentation

Overview

Copyright 2021 SANGFOR TECHNOLOGIES

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

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

• Variables
• func EnqueueInstanceWrite(instance dtstruct.InstanceAdaptor, instanceWasActuallyFound bool, ...)
• func ExecuteOnTopology(f func())
• func FlushInstanceInBuffer()
• type InstanceUpdateObject

Variables

var ForceFlushInstanceWriteBuffer = make(chan bool)

var InstanceWriteBuffer = make(chan InstanceUpdateObject, config.Config.InstanceWriteBufferSize)

Functions

func EnqueueInstanceWrite

func EnqueueInstanceWrite(instance dtstruct.InstanceAdaptor, instanceWasActuallyFound bool, lastError error)

EnqueueInstanceWrite limit write concurrently

func ExecuteOnTopology

func ExecuteOnTopology(f func())

ExecuteOnTopology will execute given function while maintaining concurrency limit on topology servers. It is safe in the sense that we will not leak tokens.

func FlushInstanceInBuffer

func FlushInstanceInBuffer()

FlushInstanceInBuffer flush all instance in write buffer periodically or force

Types

type InstanceUpdateObject

type InstanceUpdateObject struct {
	Instance                 dtstruct.InstanceAdaptor
	InstanceWasActuallyFound bool
	LastError                error
}