fake

package
v0.0.0-...-9649366 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 21, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

type M3ClusterTxnStore

type M3ClusterTxnStore interface {
	kv.TxnStore
}

M3ClusterTxnStore is a fake m3cluster txn store

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL