util

Documentation

Index

• Constants
• func ExpiredTick(start uint64, timeout time.Duration) uint64
• type ClusterStores
  • func NewClusterStores() *ClusterStores
  • func (cs *ClusterStores) ExpiredStores() StoreSlice
  • func (cs *ClusterStores) RegisterExpired(store *Store)
  • func (cs *ClusterStores) RegisterWorking(store *Store)
  • func (cs *ClusterStores) WorkingStores() StoreSlice
• type ExcludedFilter
  • func NewExcludedFilter(stores ...string) *ExcludedFilter
  • func (e *ExcludedFilter) Filter(store *Store) bool
• type Filter
  • func (f Filter) Filter(store *Store) bool
• type IDAllocator
• type IFilter
• type Store
  • func FilterStore(stores []*Store, filters []IFilter) (candidates []*Store)
  • func NewStore(storeID string, length int, capacity int) *Store
• type StoreID
• type StoreSlice
  • func (ss StoreSlice) Contains(storeID string) bool
• type TestIDAllocator
  • func NewTestIDAllocator(startFrom uint64) *TestIDAllocator
  • func (a *TestIDAllocator) Next() (uint64, bool)

Constants

const (
	// FIXME: configuration item or some other
	TickPerSecond   = 10
	LogStoreTimeout = 5 * time.Minute
	DnStoreTimeout  = 10 * time.Second
)

const (
	NullStoreID = StoreID("")
)

Functions

func ExpiredTick

func ExpiredTick(start uint64, timeout time.Duration) uint64

Types

type ClusterStores

type ClusterStores struct {
	Working StoreSlice
	Expired StoreSlice
}

ClusterStores collects stores by their status.

func NewClusterStores

func NewClusterStores() *ClusterStores

func (*ClusterStores) ExpiredStores

func (cs *ClusterStores) ExpiredStores() StoreSlice

ExpiredStores returns all recorded expired stores. NB: the returned order isn't deterministic.

func (*ClusterStores) RegisterExpired

func (cs *ClusterStores) RegisterExpired(store *Store)

RegisterExpired collects expired stores.

func (*ClusterStores) RegisterWorking

func (cs *ClusterStores) RegisterWorking(store *Store)

RegisterWorking collects working stores.

func (*ClusterStores) WorkingStores

func (cs *ClusterStores) WorkingStores() StoreSlice

WorkingStores returns all recorded working stores. NB: the returned order isn't deterministic.

type ExcludedFilter

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

func NewExcludedFilter

func NewExcludedFilter(stores ...string) *ExcludedFilter

func (*ExcludedFilter) Filter

func (e *ExcludedFilter) Filter(store *Store) bool

type Filter

type Filter func(store *Store) bool

func (Filter) Filter

func (f Filter) Filter(store *Store) bool

type IDAllocator

type IDAllocator interface {
	// When IDAllocator was exhaused temporarily, return `false`.
	Next() (uint64, bool)
}

IDAllocator is used to fetch new replica ID.

type IFilter

type IFilter interface {
	Filter(store *Store) bool
}

IFilter filter interface

type Store

type Store struct {
	ID       StoreID
	Length   int
	Capacity int
}

Store records metadata for dn store.

func FilterStore

func FilterStore(stores []*Store, filters []IFilter) (candidates []*Store)

FilterStore filters store according to Filters

func NewStore

func NewStore(storeID string, length int, capacity int) *Store

type StoreID

type StoreID string

type StoreSlice

type StoreSlice []*Store

func (StoreSlice) Contains

func (ss StoreSlice) Contains(storeID string) bool

type TestIDAllocator

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

func NewTestIDAllocator

func NewTestIDAllocator(startFrom uint64) *TestIDAllocator

func (*TestIDAllocator) Next

func (a *TestIDAllocator) Next() (uint64, bool)