fake

Documentation

Index

• type M3ClusterClient
  • func NewM3ClusterClient(services M3ClusterServices, kvStore M3ClusterKVStore) M3ClusterClient
• type M3ClusterKVStore
• type M3ClusterPlacementService
  • func NewM3ClusterPlacementService() M3ClusterPlacementService
• type M3ClusterService
  • func NewM3ClusterService() M3ClusterService
• type M3ClusterServices
  • func NewM3ClusterServices() M3ClusterServices
  • func NewM3ClusterServicesWithPlacementService(placementSvc M3ClusterPlacementService) M3ClusterServices
• type M3ClusterTxnStore

Types

type M3ClusterClient

type M3ClusterClient interface {
	client.Client
}

M3ClusterClient is a fake m3cluster client

func NewM3ClusterClient

func NewM3ClusterClient(
	services M3ClusterServices,
	kvStore M3ClusterKVStore,
) M3ClusterClient

NewM3ClusterClient creates a new fake m3cluster client

type M3ClusterKVStore

type M3ClusterKVStore interface {
	kv.Store
}

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

type M3ClusterService

type M3ClusterService interface {
	services.Service
}

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

func NewM3ClusterServicesWithPlacementService(placementSvc M3ClusterPlacementService) M3ClusterServices

NewM3ClusterServicesWithPlacementService creates a new fake m3cluster services with given placement service.

type M3ClusterTxnStore

type M3ClusterTxnStore interface {
	kv.TxnStore
}

M3ClusterTxnStore is a fake m3cluster txn store