limit

type HandleFunc func(SyncResponse)

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

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

type MakeFunc func() SyncRequest

type NewWindow func() (Window, StopFunc)

type StopFunc func()

type SyncRequest struct {
	Key     string
	Start   int64
	Count   int64
	Changes int64
}

type SyncResponse struct {
	// Whether the synchronization succeeds.
	OK    bool
	Start int64
	// The changes accumulated by the local limiter.
	Changes int64
	// The total changes accumulated by all the other limiters.
	OtherChanges int64
}

type SyncWindow struct {
	LocalWindow
	// contains filtered or unexported fields
}

type Synchronizer interface {
	// Start starts the synchronization goroutine, if any.
	Start()

	// Stop stops the synchronization goroutine, if any, and waits for it to exit.
	Stop()

	// Sync sends a synchronization request.
	Sync(time.Time, MakeFunc, HandleFunc)
}

type Window interface {
	// Start returns the start boundary.
	Start() time.Time

	// Count returns the accumulated count.
	Count() int64

	// AddCount increments the accumulated count by n.
	AddCount(n int64)

	// Reset sets the state of the window with the given settings.
	Reset(s time.Time, c int64)

	// Sync tries to exchange data between the window and the central
	// datastore at time now, to keep the window's count up-to-date.
	Sync(now time.Time)
}

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

type WindowLimitOption func(w *WindowLimit)