node

package
v0.0.0-...-c39c2fe Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockOptions 

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

MockOptions is a mock of Options interface

func NewMockOptions 

func NewMockOptions(ctrl *gomock.Controller) *MockOptions

NewMockOptions creates a new mock instance

func (*MockOptions) EXPECT 

func (_m *MockOptions) EXPECT() *MockOptionsMockRecorder

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

func (*MockOptions) HeartbeatOptions 

func (_m *MockOptions) HeartbeatOptions() node.HeartbeatOptions

HeartbeatOptions mocks base method

func (*MockOptions) InstrumentOptions 

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

InstrumentOptions mocks base method

func (*MockOptions) MaxPullSize 

func (_m *MockOptions) MaxPullSize() int64

MaxPullSize mocks base method

func (*MockOptions) OperationTimeout 

func (_m *MockOptions) OperationTimeout() time.Duration

OperationTimeout mocks base method

func (*MockOptions) OperatorClientFn 

func (_m *MockOptions) OperatorClientFn() node.OperatorClientFn

OperatorClientFn mocks base method

func (*MockOptions) Retrier 

func (_m *MockOptions) Retrier() retry.Retrier

Retrier mocks base method

func (*MockOptions) SetHeartbeatOptions 

func (_m *MockOptions) SetHeartbeatOptions(_param0 node.HeartbeatOptions) node.Options

SetHeartbeatOptions mocks base method

func (*MockOptions) SetInstrumentOptions 

func (_m *MockOptions) SetInstrumentOptions(_param0 instrument.Options) node.Options

SetInstrumentOptions mocks base method

func (*MockOptions) SetMaxPullSize 

func (_m *MockOptions) SetMaxPullSize(_param0 int64) node.Options

SetMaxPullSize mocks base method

func (*MockOptions) SetOperationTimeout 

func (_m *MockOptions) SetOperationTimeout(_param0 time.Duration) node.Options

SetOperationTimeout mocks base method

func (*MockOptions) SetOperatorClientFn 

func (_m *MockOptions) SetOperatorClientFn(_param0 node.OperatorClientFn) node.Options

SetOperatorClientFn mocks base method

func (*MockOptions) SetRetrier 

func (_m *MockOptions) SetRetrier(_param0 retry.Retrier) node.Options

SetRetrier mocks base method

func (*MockOptions) SetTransferBufferSize 

func (_m *MockOptions) SetTransferBufferSize(_param0 int) node.Options

SetTransferBufferSize mocks base method

func (*MockOptions) TransferBufferSize 

func (_m *MockOptions) TransferBufferSize() int

TransferBufferSize mocks base method

func (*MockOptions) Validate 

func (_m *MockOptions) Validate() error

Validate mocks base method

type MockOptionsMockRecorder 

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

MockOptionsMockRecorder is the mock recorder for MockOptions

func (*MockOptionsMockRecorder) HeartbeatOptions 

func (_mr *MockOptionsMockRecorder) HeartbeatOptions() *gomock.Call

HeartbeatOptions indicates an expected call of HeartbeatOptions

func (*MockOptionsMockRecorder) InstrumentOptions 

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

InstrumentOptions indicates an expected call of InstrumentOptions

func (*MockOptionsMockRecorder) MaxPullSize 

func (_mr *MockOptionsMockRecorder) MaxPullSize() *gomock.Call

MaxPullSize indicates an expected call of MaxPullSize

func (*MockOptionsMockRecorder) OperationTimeout 

func (_mr *MockOptionsMockRecorder) OperationTimeout() *gomock.Call

OperationTimeout indicates an expected call of OperationTimeout

func (*MockOptionsMockRecorder) OperatorClientFn 

func (_mr *MockOptionsMockRecorder) OperatorClientFn() *gomock.Call

OperatorClientFn indicates an expected call of OperatorClientFn

func (*MockOptionsMockRecorder) Retrier 

func (_mr *MockOptionsMockRecorder) Retrier() *gomock.Call

Retrier indicates an expected call of Retrier

func (*MockOptionsMockRecorder) SetHeartbeatOptions 

func (_mr *MockOptionsMockRecorder) SetHeartbeatOptions(arg0 interface{}) *gomock.Call

SetHeartbeatOptions indicates an expected call of SetHeartbeatOptions

func (*MockOptionsMockRecorder) SetInstrumentOptions 

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

SetInstrumentOptions indicates an expected call of SetInstrumentOptions

func (*MockOptionsMockRecorder) SetMaxPullSize 

func (_mr *MockOptionsMockRecorder) SetMaxPullSize(arg0 interface{}) *gomock.Call

SetMaxPullSize indicates an expected call of SetMaxPullSize

func (*MockOptionsMockRecorder) SetOperationTimeout 

func (_mr *MockOptionsMockRecorder) SetOperationTimeout(arg0 interface{}) *gomock.Call

SetOperationTimeout indicates an expected call of SetOperationTimeout

func (*MockOptionsMockRecorder) SetOperatorClientFn 

func (_mr *MockOptionsMockRecorder) SetOperatorClientFn(arg0 interface{}) *gomock.Call

SetOperatorClientFn indicates an expected call of SetOperatorClientFn

func (*MockOptionsMockRecorder) SetRetrier 

func (_mr *MockOptionsMockRecorder) SetRetrier(arg0 interface{}) *gomock.Call

SetRetrier indicates an expected call of SetRetrier

func (*MockOptionsMockRecorder) SetTransferBufferSize 

func (_mr *MockOptionsMockRecorder) SetTransferBufferSize(arg0 interface{}) *gomock.Call

SetTransferBufferSize indicates an expected call of SetTransferBufferSize

func (*MockOptionsMockRecorder) TransferBufferSize 

func (_mr *MockOptionsMockRecorder) TransferBufferSize() *gomock.Call

TransferBufferSize indicates an expected call of TransferBufferSize

func (*MockOptionsMockRecorder) Validate 

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

Validate indicates an expected call of Validate

type MockServiceNode 

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

MockServiceNode is a mock of ServiceNode interface

func NewMockServiceNode 

func NewMockServiceNode(ctrl *gomock.Controller) *MockServiceNode

NewMockServiceNode creates a new mock instance

func (*MockServiceNode) Clone 

func (_m *MockServiceNode) Clone() placement.Instance

Clone mocks base method

func (*MockServiceNode) Close 

func (_m *MockServiceNode) Close() error

Close mocks base method

func (*MockServiceNode) DeregisterListener 

func (_m *MockServiceNode) DeregisterListener(_param0 node.ListenerID)

DeregisterListener mocks base method

func (*MockServiceNode) EXPECT 

func (_m *MockServiceNode) EXPECT() *MockServiceNodeMockRecorder

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

func (*MockServiceNode) Endpoint 

func (_m *MockServiceNode) Endpoint() string

Endpoint mocks base method

func (*MockServiceNode) GetRemoteOutput 

func (_m *MockServiceNode) GetRemoteOutput(_param0 node.RemoteOutputType, _param1 string) (bool, error)

GetRemoteOutput mocks base method

func (*MockServiceNode) Hostname 

func (_m *MockServiceNode) Hostname() string

Hostname mocks base method

func (*MockServiceNode) ID 

func (_m *MockServiceNode) ID() string

ID mocks base method

func (*MockServiceNode) IsInitializing 

func (_m *MockServiceNode) IsInitializing() bool

IsInitializing mocks base method

func (*MockServiceNode) IsLeaving 

func (_m *MockServiceNode) IsLeaving() bool

IsLeaving mocks base method

func (*MockServiceNode) IsolationGroup 

func (_m *MockServiceNode) IsolationGroup() string

IsolationGroup mocks base method

func (*MockServiceNode) Port 

func (_m *MockServiceNode) Port() uint32

Port mocks base method

func (*MockServiceNode) Proto 

func (_m *MockServiceNode) Proto() (*placementpb.Instance, error)

Proto mocks base method

func (*MockServiceNode) RegisterListener 

func (_m *MockServiceNode) RegisterListener(_param0 node.Listener) node.ListenerID

RegisterListener mocks base method

func (*MockServiceNode) SetEndpoint 

func (_m *MockServiceNode) SetEndpoint(_param0 string) placement.Instance

SetEndpoint mocks base method

func (*MockServiceNode) SetHostname 

func (_m *MockServiceNode) SetHostname(_param0 string) placement.Instance

SetHostname mocks base method

func (*MockServiceNode) SetID 

func (_m *MockServiceNode) SetID(_param0 string) placement.Instance

SetID mocks base method

func (*MockServiceNode) SetIsolationGroup 

func (_m *MockServiceNode) SetIsolationGroup(_param0 string) placement.Instance

SetIsolationGroup mocks base method

func (*MockServiceNode) SetPort 

func (_m *MockServiceNode) SetPort(_param0 uint32) placement.Instance

SetPort mocks base method

func (*MockServiceNode) SetShardSetID 

func (_m *MockServiceNode) SetShardSetID(_param0 uint32) placement.Instance

SetShardSetID mocks base method

func (*MockServiceNode) SetShards 

func (_m *MockServiceNode) SetShards(_param0 shard.Shards) placement.Instance

SetShards mocks base method

func (*MockServiceNode) SetWeight 

func (_m *MockServiceNode) SetWeight(_param0 uint32) placement.Instance

SetWeight mocks base method

func (*MockServiceNode) SetZone 

func (_m *MockServiceNode) SetZone(_param0 string) placement.Instance

SetZone mocks base method

func (*MockServiceNode) Setup 

func (_m *MockServiceNode) Setup(_param0 build.ServiceBuild, _param1 build.ServiceConfiguration, _param2 string, _param3 bool) error

Setup mocks base method

func (*MockServiceNode) ShardSetID 

func (_m *MockServiceNode) ShardSetID() uint32

ShardSetID mocks base method

func (*MockServiceNode) Shards 

func (_m *MockServiceNode) Shards() shard.Shards

Shards mocks base method

func (*MockServiceNode) Start 

func (_m *MockServiceNode) Start() error

Start mocks base method

func (*MockServiceNode) Status 

func (_m *MockServiceNode) Status() node.Status

Status mocks base method

func (*MockServiceNode) Stop 

func (_m *MockServiceNode) Stop() error

Stop mocks base method

func (*MockServiceNode) String 

func (_m *MockServiceNode) String() string

String mocks base method

func (*MockServiceNode) Teardown 

func (_m *MockServiceNode) Teardown() error

Teardown mocks base method

func (*MockServiceNode) TransferLocalFile 

func (_m *MockServiceNode) TransferLocalFile(_param0 string, _param1 []string, _param2 bool) error

TransferLocalFile mocks base method

func (*MockServiceNode) Weight 

func (_m *MockServiceNode) Weight() uint32

Weight mocks base method

func (*MockServiceNode) Zone 

func (_m *MockServiceNode) Zone() string

Zone mocks base method

type MockServiceNodeMockRecorder 

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

MockServiceNodeMockRecorder is the mock recorder for MockServiceNode

func (*MockServiceNodeMockRecorder) Clone 

func (_mr *MockServiceNodeMockRecorder) Clone() *gomock.Call

Clone indicates an expected call of Clone

func (*MockServiceNodeMockRecorder) Close 

func (_mr *MockServiceNodeMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockServiceNodeMockRecorder) DeregisterListener 

func (_mr *MockServiceNodeMockRecorder) DeregisterListener(arg0 interface{}) *gomock.Call

DeregisterListener indicates an expected call of DeregisterListener

func (*MockServiceNodeMockRecorder) Endpoint 

func (_mr *MockServiceNodeMockRecorder) Endpoint() *gomock.Call

Endpoint indicates an expected call of Endpoint

func (*MockServiceNodeMockRecorder) GetRemoteOutput 

func (_mr *MockServiceNodeMockRecorder) GetRemoteOutput(arg0, arg1 interface{}) *gomock.Call

GetRemoteOutput indicates an expected call of GetRemoteOutput

func (*MockServiceNodeMockRecorder) Hostname 

func (_mr *MockServiceNodeMockRecorder) Hostname() *gomock.Call

Hostname indicates an expected call of Hostname

func (*MockServiceNodeMockRecorder) ID 

func (_mr *MockServiceNodeMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockServiceNodeMockRecorder) IsInitializing 

func (_mr *MockServiceNodeMockRecorder) IsInitializing() *gomock.Call

IsInitializing indicates an expected call of IsInitializing

func (*MockServiceNodeMockRecorder) IsLeaving 

func (_mr *MockServiceNodeMockRecorder) IsLeaving() *gomock.Call

IsLeaving indicates an expected call of IsLeaving

func (*MockServiceNodeMockRecorder) IsolationGroup 

func (_mr *MockServiceNodeMockRecorder) IsolationGroup() *gomock.Call

IsolationGroup indicates an expected call of IsolationGroup

func (*MockServiceNodeMockRecorder) Port 

func (_mr *MockServiceNodeMockRecorder) Port() *gomock.Call

Port indicates an expected call of Port

func (*MockServiceNodeMockRecorder) Proto 

func (_mr *MockServiceNodeMockRecorder) Proto() *gomock.Call

Proto indicates an expected call of Proto

func (*MockServiceNodeMockRecorder) RegisterListener 

func (_mr *MockServiceNodeMockRecorder) RegisterListener(arg0 interface{}) *gomock.Call

RegisterListener indicates an expected call of RegisterListener

func (*MockServiceNodeMockRecorder) SetEndpoint 

func (_mr *MockServiceNodeMockRecorder) SetEndpoint(arg0 interface{}) *gomock.Call

SetEndpoint indicates an expected call of SetEndpoint

func (*MockServiceNodeMockRecorder) SetHostname 

func (_mr *MockServiceNodeMockRecorder) SetHostname(arg0 interface{}) *gomock.Call

SetHostname indicates an expected call of SetHostname

func (*MockServiceNodeMockRecorder) SetID 

func (_mr *MockServiceNodeMockRecorder) SetID(arg0 interface{}) *gomock.Call

SetID indicates an expected call of SetID

func (*MockServiceNodeMockRecorder) SetIsolationGroup 

func (_mr *MockServiceNodeMockRecorder) SetIsolationGroup(arg0 interface{}) *gomock.Call

SetIsolationGroup indicates an expected call of SetIsolationGroup

func (*MockServiceNodeMockRecorder) SetPort 

func (_mr *MockServiceNodeMockRecorder) SetPort(arg0 interface{}) *gomock.Call

SetPort indicates an expected call of SetPort

func (*MockServiceNodeMockRecorder) SetShardSetID 

func (_mr *MockServiceNodeMockRecorder) SetShardSetID(arg0 interface{}) *gomock.Call

SetShardSetID indicates an expected call of SetShardSetID

func (*MockServiceNodeMockRecorder) SetShards 

func (_mr *MockServiceNodeMockRecorder) SetShards(arg0 interface{}) *gomock.Call

SetShards indicates an expected call of SetShards

func (*MockServiceNodeMockRecorder) SetWeight 

func (_mr *MockServiceNodeMockRecorder) SetWeight(arg0 interface{}) *gomock.Call

SetWeight indicates an expected call of SetWeight

func (*MockServiceNodeMockRecorder) SetZone 

func (_mr *MockServiceNodeMockRecorder) SetZone(arg0 interface{}) *gomock.Call

SetZone indicates an expected call of SetZone

func (*MockServiceNodeMockRecorder) Setup 

func (_mr *MockServiceNodeMockRecorder) Setup(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

Setup indicates an expected call of Setup

func (*MockServiceNodeMockRecorder) ShardSetID 

func (_mr *MockServiceNodeMockRecorder) ShardSetID() *gomock.Call

ShardSetID indicates an expected call of ShardSetID

func (*MockServiceNodeMockRecorder) Shards 

func (_mr *MockServiceNodeMockRecorder) Shards() *gomock.Call

Shards indicates an expected call of Shards

func (*MockServiceNodeMockRecorder) Start 

func (_mr *MockServiceNodeMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockServiceNodeMockRecorder) Status 

func (_mr *MockServiceNodeMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status

func (*MockServiceNodeMockRecorder) Stop 

func (_mr *MockServiceNodeMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

func (*MockServiceNodeMockRecorder) String 

func (_mr *MockServiceNodeMockRecorder) String() *gomock.Call

String indicates an expected call of String

func (*MockServiceNodeMockRecorder) Teardown 

func (_mr *MockServiceNodeMockRecorder) Teardown() *gomock.Call

Teardown indicates an expected call of Teardown

func (*MockServiceNodeMockRecorder) TransferLocalFile 

func (_mr *MockServiceNodeMockRecorder) TransferLocalFile(arg0, arg1, arg2 interface{}) *gomock.Call

TransferLocalFile indicates an expected call of TransferLocalFile

func (*MockServiceNodeMockRecorder) Weight 

func (_mr *MockServiceNodeMockRecorder) Weight() *gomock.Call

Weight indicates an expected call of Weight

func (*MockServiceNodeMockRecorder) Zone 

func (_mr *MockServiceNodeMockRecorder) Zone() *gomock.Call

Zone indicates an expected call of Zone

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.