m3db

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Sep 25, 2026 License: Apache-2.0 Imports: 14 Imported by: 16

Documentation

Overview

Package m3db is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockNode added in v1.6.0 

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

MockNode is a mock of Node interface.

func NewMockNode added in v1.6.0 

func NewMockNode(ctrl *gomock.Controller) *MockNode

NewMockNode creates a new mock instance.

func (*MockNode) Bootstrapped added in v1.6.0 

func (m *MockNode) Bootstrapped() bool

Bootstrapped mocks base method.

func (*MockNode) Clone added in v1.6.0 

func (m *MockNode) Clone() placement.Instance

Clone mocks base method.

func (*MockNode) Close added in v1.6.0 

func (m *MockNode) Close() error

Close mocks base method.

func (*MockNode) DeregisterListener added in v1.6.0 

func (m *MockNode) DeregisterListener(arg0 node.ListenerID)

DeregisterListener mocks base method.

func (*MockNode) EXPECT added in v1.6.0 

func (m *MockNode) EXPECT() *MockNodeMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNode) Endpoint added in v1.6.0 

func (m *MockNode) Endpoint() string

Endpoint mocks base method.

func (*MockNode) GetRemoteOutput added in v1.6.0 

func (m *MockNode) GetRemoteOutput(t node.RemoteOutputType, localDest string) (bool, error)

GetRemoteOutput mocks base method.

func (*MockNode) Health added in v1.6.0 

func (m *MockNode) Health() (NodeHealth, error)

Health mocks base method.

func (*MockNode) Hostname added in v1.6.0 

func (m *MockNode) Hostname() string

Hostname mocks base method.

func (*MockNode) ID added in v1.6.0 

func (m *MockNode) ID() string

ID mocks base method.

func (*MockNode) IsAvailable added in v1.6.0 

func (m *MockNode) IsAvailable() bool

IsAvailable mocks base method.

func (*MockNode) IsInitializing added in v1.6.0 

func (m *MockNode) IsInitializing() bool

IsInitializing mocks base method.

func (*MockNode) IsLeaving added in v1.6.0 

func (m *MockNode) IsLeaving() bool

IsLeaving mocks base method.

func (*MockNode) IsolationGroup added in v1.6.0 

func (m *MockNode) IsolationGroup() string

IsolationGroup mocks base method.

func (*MockNode) Metadata added in v1.6.0 

func (m *MockNode) Metadata() placement.InstanceMetadata

Metadata mocks base method.

func (*MockNode) Port added in v1.6.0 

func (m *MockNode) Port() uint32

Port mocks base method.

func (*MockNode) Proto added in v1.6.0 

func (m *MockNode) Proto() (*placementpb.Instance, error)

Proto mocks base method.

func (*MockNode) RegisterListener added in v1.6.0 

func (m *MockNode) RegisterListener(arg0 node.Listener) node.ListenerID

RegisterListener mocks base method.

func (*MockNode) SetEndpoint added in v1.6.0 

func (m *MockNode) SetEndpoint(ip string) placement.Instance

SetEndpoint mocks base method.

func (*MockNode) SetHostname added in v1.6.0 

func (m *MockNode) SetHostname(value string) placement.Instance

SetHostname mocks base method.

func (*MockNode) SetID added in v1.6.0 

func (m *MockNode) SetID(id string) placement.Instance

SetID mocks base method.

func (*MockNode) SetIsolationGroup added in v1.6.0 

func (m *MockNode) SetIsolationGroup(r string) placement.Instance

SetIsolationGroup mocks base method.

func (*MockNode) SetMetadata added in v1.6.0 

func (m *MockNode) SetMetadata(value placement.InstanceMetadata) placement.Instance

SetMetadata mocks base method.

func (*MockNode) SetPort added in v1.6.0 

func (m *MockNode) SetPort(value uint32) placement.Instance

SetPort mocks base method.

func (*MockNode) SetShardSetID added in v1.6.0 

func (m *MockNode) SetShardSetID(value uint32) placement.Instance

SetShardSetID mocks base method.

func (*MockNode) SetShards added in v1.6.0 

func (m *MockNode) SetShards(s shard.Shards) placement.Instance

SetShards mocks base method.

func (*MockNode) SetSubClusterID added in v1.6.0 

func (m *MockNode) SetSubClusterID(value uint32) placement.Instance

SetSubClusterID mocks base method.

func (*MockNode) SetWeight added in v1.6.0 

func (m *MockNode) SetWeight(w uint32) placement.Instance

SetWeight mocks base method.

func (*MockNode) SetZone added in v1.6.0 

func (m *MockNode) SetZone(z string) placement.Instance

SetZone mocks base method.

func (*MockNode) Setup added in v1.6.0 

func (m *MockNode) Setup(build build.ServiceBuild, config build.ServiceConfiguration, token string, force bool) error

Setup mocks base method.

func (*MockNode) ShardSetID added in v1.6.0 

func (m *MockNode) ShardSetID() uint32

ShardSetID mocks base method.

func (*MockNode) Shards added in v1.6.0 

func (m *MockNode) Shards() shard.Shards

Shards mocks base method.

func (*MockNode) Start added in v1.6.0 

func (m *MockNode) Start() error

Start mocks base method.

func (*MockNode) Status added in v1.6.0 

func (m *MockNode) Status() node.Status

Status mocks base method.

func (*MockNode) Stop added in v1.6.0 

func (m *MockNode) Stop() error

Stop mocks base method.

func (*MockNode) String added in v1.6.0 

func (m *MockNode) String() string

String mocks base method.

func (*MockNode) SubClusterID added in v1.6.0 

func (m *MockNode) SubClusterID() uint32

SubClusterID mocks base method.

func (*MockNode) Teardown added in v1.6.0 

func (m *MockNode) Teardown() error

Teardown mocks base method.

func (*MockNode) TransferLocalFile added in v1.6.0 

func (m *MockNode) TransferLocalFile(localSrc string, destPaths []string, overwrite bool) error

TransferLocalFile mocks base method.

func (*MockNode) Weight added in v1.6.0 

func (m *MockNode) Weight() uint32

Weight mocks base method.

func (*MockNode) Zone added in v1.6.0 

func (m *MockNode) Zone() string

Zone mocks base method.

type MockNodeMockRecorder added in v1.6.0 

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

MockNodeMockRecorder is the mock recorder for MockNode.

func (*MockNodeMockRecorder) Bootstrapped added in v1.6.0 

func (mr *MockNodeMockRecorder) Bootstrapped() *gomock.Call

Bootstrapped indicates an expected call of Bootstrapped.

func (*MockNodeMockRecorder) Clone added in v1.6.0 

func (mr *MockNodeMockRecorder) Clone() *gomock.Call

Clone indicates an expected call of Clone.

func (*MockNodeMockRecorder) Close added in v1.6.0 

func (mr *MockNodeMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockNodeMockRecorder) DeregisterListener added in v1.6.0 

func (mr *MockNodeMockRecorder) DeregisterListener(arg0 interface{}) *gomock.Call

DeregisterListener indicates an expected call of DeregisterListener.

func (*MockNodeMockRecorder) Endpoint added in v1.6.0 

func (mr *MockNodeMockRecorder) Endpoint() *gomock.Call

Endpoint indicates an expected call of Endpoint.

func (*MockNodeMockRecorder) GetRemoteOutput added in v1.6.0 

func (mr *MockNodeMockRecorder) GetRemoteOutput(t, localDest interface{}) *gomock.Call

GetRemoteOutput indicates an expected call of GetRemoteOutput.

func (*MockNodeMockRecorder) Health added in v1.6.0 

func (mr *MockNodeMockRecorder) Health() *gomock.Call

Health indicates an expected call of Health.

func (*MockNodeMockRecorder) Hostname added in v1.6.0 

func (mr *MockNodeMockRecorder) Hostname() *gomock.Call

Hostname indicates an expected call of Hostname.

func (*MockNodeMockRecorder) ID added in v1.6.0 

func (mr *MockNodeMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockNodeMockRecorder) IsAvailable added in v1.6.0 

func (mr *MockNodeMockRecorder) IsAvailable() *gomock.Call

IsAvailable indicates an expected call of IsAvailable.

func (*MockNodeMockRecorder) IsInitializing added in v1.6.0 

func (mr *MockNodeMockRecorder) IsInitializing() *gomock.Call

IsInitializing indicates an expected call of IsInitializing.

func (*MockNodeMockRecorder) IsLeaving added in v1.6.0 

func (mr *MockNodeMockRecorder) IsLeaving() *gomock.Call

IsLeaving indicates an expected call of IsLeaving.

func (*MockNodeMockRecorder) IsolationGroup added in v1.6.0 

func (mr *MockNodeMockRecorder) IsolationGroup() *gomock.Call

IsolationGroup indicates an expected call of IsolationGroup.

func (*MockNodeMockRecorder) Metadata added in v1.6.0 

func (mr *MockNodeMockRecorder) Metadata() *gomock.Call

Metadata indicates an expected call of Metadata.

func (*MockNodeMockRecorder) Port added in v1.6.0 

func (mr *MockNodeMockRecorder) Port() *gomock.Call

Port indicates an expected call of Port.

func (*MockNodeMockRecorder) Proto added in v1.6.0 

func (mr *MockNodeMockRecorder) Proto() *gomock.Call

Proto indicates an expected call of Proto.

func (*MockNodeMockRecorder) RegisterListener added in v1.6.0 

func (mr *MockNodeMockRecorder) RegisterListener(arg0 interface{}) *gomock.Call

RegisterListener indicates an expected call of RegisterListener.

func (*MockNodeMockRecorder) SetEndpoint added in v1.6.0 

func (mr *MockNodeMockRecorder) SetEndpoint(ip interface{}) *gomock.Call

SetEndpoint indicates an expected call of SetEndpoint.

func (*MockNodeMockRecorder) SetHostname added in v1.6.0 

func (mr *MockNodeMockRecorder) SetHostname(value interface{}) *gomock.Call

SetHostname indicates an expected call of SetHostname.

func (*MockNodeMockRecorder) SetID added in v1.6.0 

func (mr *MockNodeMockRecorder) SetID(id interface{}) *gomock.Call

SetID indicates an expected call of SetID.

func (*MockNodeMockRecorder) SetIsolationGroup added in v1.6.0 

func (mr *MockNodeMockRecorder) SetIsolationGroup(r interface{}) *gomock.Call

SetIsolationGroup indicates an expected call of SetIsolationGroup.

func (*MockNodeMockRecorder) SetMetadata added in v1.6.0 

func (mr *MockNodeMockRecorder) SetMetadata(value interface{}) *gomock.Call

SetMetadata indicates an expected call of SetMetadata.

func (*MockNodeMockRecorder) SetPort added in v1.6.0 

func (mr *MockNodeMockRecorder) SetPort(value interface{}) *gomock.Call

SetPort indicates an expected call of SetPort.

func (*MockNodeMockRecorder) SetShardSetID added in v1.6.0 

func (mr *MockNodeMockRecorder) SetShardSetID(value interface{}) *gomock.Call

SetShardSetID indicates an expected call of SetShardSetID.

func (*MockNodeMockRecorder) SetShards added in v1.6.0 

func (mr *MockNodeMockRecorder) SetShards(s interface{}) *gomock.Call

SetShards indicates an expected call of SetShards.

func (*MockNodeMockRecorder) SetSubClusterID added in v1.6.0 

func (mr *MockNodeMockRecorder) SetSubClusterID(value interface{}) *gomock.Call

SetSubClusterID indicates an expected call of SetSubClusterID.

func (*MockNodeMockRecorder) SetWeight added in v1.6.0 

func (mr *MockNodeMockRecorder) SetWeight(w interface{}) *gomock.Call

SetWeight indicates an expected call of SetWeight.

func (*MockNodeMockRecorder) SetZone added in v1.6.0 

func (mr *MockNodeMockRecorder) SetZone(z interface{}) *gomock.Call

SetZone indicates an expected call of SetZone.

func (*MockNodeMockRecorder) Setup added in v1.6.0 

func (mr *MockNodeMockRecorder) Setup(build, config, token, force interface{}) *gomock.Call

Setup indicates an expected call of Setup.

func (*MockNodeMockRecorder) ShardSetID added in v1.6.0 

func (mr *MockNodeMockRecorder) ShardSetID() *gomock.Call

ShardSetID indicates an expected call of ShardSetID.

func (*MockNodeMockRecorder) Shards added in v1.6.0 

func (mr *MockNodeMockRecorder) Shards() *gomock.Call

Shards indicates an expected call of Shards.

func (*MockNodeMockRecorder) Start added in v1.6.0 

func (mr *MockNodeMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockNodeMockRecorder) Status added in v1.6.0 

func (mr *MockNodeMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status.

func (*MockNodeMockRecorder) Stop added in v1.6.0 

func (mr *MockNodeMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockNodeMockRecorder) String added in v1.6.0 

func (mr *MockNodeMockRecorder) String() *gomock.Call

String indicates an expected call of String.

func (*MockNodeMockRecorder) SubClusterID added in v1.6.0 

func (mr *MockNodeMockRecorder) SubClusterID() *gomock.Call

SubClusterID indicates an expected call of SubClusterID.

func (*MockNodeMockRecorder) Teardown added in v1.6.0 

func (mr *MockNodeMockRecorder) Teardown() *gomock.Call

Teardown indicates an expected call of Teardown.

func (*MockNodeMockRecorder) TransferLocalFile added in v1.6.0 

func (mr *MockNodeMockRecorder) TransferLocalFile(localSrc, destPaths, overwrite interface{}) *gomock.Call

TransferLocalFile indicates an expected call of TransferLocalFile.

func (*MockNodeMockRecorder) Weight added in v1.6.0 

func (mr *MockNodeMockRecorder) Weight() *gomock.Call

Weight indicates an expected call of Weight.

func (*MockNodeMockRecorder) Zone added in v1.6.0 

func (mr *MockNodeMockRecorder) Zone() *gomock.Call

Zone indicates an expected call of Zone.

type MockOptions added in v1.6.0 

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

MockOptions is a mock of Options interface.

func NewMockOptions added in v1.6.0 

func NewMockOptions(ctrl *gomock.Controller) *MockOptions

NewMockOptions creates a new mock instance.

func (*MockOptions) EXPECT added in v1.6.0 

func (m *MockOptions) EXPECT() *MockOptionsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOptions) InstrumentOptions added in v1.6.0 

func (m *MockOptions) InstrumentOptions() instrument.Options

InstrumentOptions mocks base method.

func (*MockOptions) NodeOptions added in v1.6.0 

func (m *MockOptions) NodeOptions() node.Options

NodeOptions mocks base method.

func (*MockOptions) SetInstrumentOptions added in v1.6.0 

func (m *MockOptions) SetInstrumentOptions(arg0 instrument.Options) Options

SetInstrumentOptions mocks base method.

func (*MockOptions) SetNodeOptions added in v1.6.0 

func (m *MockOptions) SetNodeOptions(arg0 node.Options) Options

SetNodeOptions mocks base method.

func (*MockOptions) Validate added in v1.6.0 

func (m *MockOptions) Validate() error

Validate mocks base method.

type MockOptionsMockRecorder added in v1.6.0 

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

MockOptionsMockRecorder is the mock recorder for MockOptions.

func (*MockOptionsMockRecorder) InstrumentOptions added in v1.6.0 

func (mr *MockOptionsMockRecorder) InstrumentOptions() *gomock.Call

InstrumentOptions indicates an expected call of InstrumentOptions.

func (*MockOptionsMockRecorder) NodeOptions added in v1.6.0 

func (mr *MockOptionsMockRecorder) NodeOptions() *gomock.Call

NodeOptions indicates an expected call of NodeOptions.

func (*MockOptionsMockRecorder) SetInstrumentOptions added in v1.6.0 

func (mr *MockOptionsMockRecorder) SetInstrumentOptions(arg0 interface{}) *gomock.Call

SetInstrumentOptions indicates an expected call of SetInstrumentOptions.

func (*MockOptionsMockRecorder) SetNodeOptions added in v1.6.0 

func (mr *MockOptionsMockRecorder) SetNodeOptions(arg0 interface{}) *gomock.Call

SetNodeOptions indicates an expected call of SetNodeOptions.

func (*MockOptionsMockRecorder) Validate added in v1.6.0 

func (mr *MockOptionsMockRecorder) Validate() *gomock.Call

Validate indicates an expected call of Validate.

type Node 

type Node interface {
	node.ServiceNode

	// Health returns the health for this node
	Health() (NodeHealth, error)

	// Bootstrapped returns whether the node is bootstrapped
	Bootstrapped() bool
}

Node represents a ServiceNode pointing to an M3DB process

func New 

func New(svcNode node.ServiceNode, opts Options) (Node, error)

New constructs a new m3emNode

type NodeHealth 

type NodeHealth struct {
	Status       string
	Bootstrapped bool
	OK           bool
}

NodeHealth provides Health information for a M3DB node

type Options 

type Options interface {
	// Validate validates the Options
	Validate() error

	// SetInstrumentOptions sets the instrumentation options
	SetInstrumentOptions(instrument.Options) Options

	// InstrumentOptions returns the instrumentation options
	InstrumentOptions() instrument.Options

	// SetNodeOptions sets the node options
	SetNodeOptions(node.Options) Options

	// NodeOptions returns the node options
	NodeOptions() node.Options
}

Options represent the knobs to control m3db.Node behavior

func NewOptions 

func NewOptions(
	iopts instrument.Options,
) Options

NewOptions returns a new Options construct.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.