Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type M3ClusterClient ¶
M3ClusterClient is a fake m3cluster client
func NewM3ClusterClient ¶
func NewM3ClusterClient( services M3ClusterServices, kvStore M3ClusterKVStore, ) M3ClusterClient
NewM3ClusterClient creates a new fake m3cluster client
type M3ClusterKVStore ¶
M3ClusterKVStore is a fake m3cluster kv store
type M3ClusterPlacementService ¶
type M3ClusterPlacementService interface { placement.Service // InstanceShardsMarkedAvailable returns instance shards marked as available InstanceShardsMarkedAvailable() map[string][]uint32 }
M3ClusterPlacementService is a fake m3cluster placement service
func NewM3ClusterPlacementService ¶
func NewM3ClusterPlacementService() M3ClusterPlacementService
NewM3ClusterPlacementService creates a fake m3cluster placement service
func NewM3ClusterPlacementServiceWithPlacement ¶ added in v1.2.0
func NewM3ClusterPlacementServiceWithPlacement(placement placement.Placement) M3ClusterPlacementService
NewM3ClusterPlacementServiceWithPlacement creates a fake m3cluster placement service with given placement.
type M3ClusterService ¶
M3ClusterService is a fake m3cluster service, mainly used to add synchronization and avoid data races with the default service implementation included in m3cluster
func NewM3ClusterService ¶
func NewM3ClusterService() M3ClusterService
NewM3ClusterService creates a new fake m3cluster service
type M3ClusterServices ¶
type M3ClusterServices interface { services.Services // RegisterService registers a fake m3cluster service RegisterService(name string, svc M3ClusterService) // NotifyServiceUpdate will trigger any watch to fire for a service NotifyServiceUpdate(name string) // FakePlacementService returns the fake m3cluster placement service FakePlacementService() M3ClusterPlacementService }
M3ClusterServices is a fake m3cluster services
func NewM3ClusterServices ¶
func NewM3ClusterServices() M3ClusterServices
NewM3ClusterServices creates a new fake m3cluster services
func NewM3ClusterServicesWithPlacementService ¶ added in v1.2.0
func NewM3ClusterServicesWithPlacementService(placementSvc M3ClusterPlacementService) M3ClusterServices
NewM3ClusterServicesWithPlacementService creates a new fake m3cluster services with given placement service.
type M3ClusterTxnStore ¶
M3ClusterTxnStore is a fake m3cluster txn store