fakes

package
v2.295.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Jan 18, 2020 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Overview

This file was generated by counterfeiter

This file was generated by counterfeiter

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeConnectionProvider

type FakeConnectionProvider struct {
	ProvideConnectionStub func() (*yagnats.Connection, error)
	// contains filtered or unexported fields
}

func (*FakeConnectionProvider) Invocations

func (fake *FakeConnectionProvider) Invocations() map[string][][]interface{}

func (*FakeConnectionProvider) ProvideConnection

func (fake *FakeConnectionProvider) ProvideConnection() (*yagnats.Connection, error)

func (*FakeConnectionProvider) ProvideConnectionCallCount

func (fake *FakeConnectionProvider) ProvideConnectionCallCount() int

func (*FakeConnectionProvider) ProvideConnectionReturns

func (fake *FakeConnectionProvider) ProvideConnectionReturns(result1 *yagnats.Connection, result2 error)

func (*FakeConnectionProvider) ProvideConnectionReturnsOnCall

func (fake *FakeConnectionProvider) ProvideConnectionReturnsOnCall(i int, result1 *yagnats.Connection, result2 error)

type FakeHandler

type FakeHandler struct {
	RunFunc     boshhandler.Func
	RunCallBack func()
	RunErr      error

	ReceivedRun   bool
	ReceivedStart bool
	ReceivedStop  bool

	RegisteredAdditionalFunc boshhandler.Func

	SendCallback func(SendInput)
	SendErr      error
	// contains filtered or unexported fields
}

func NewFakeHandler

func NewFakeHandler() *FakeHandler

func (*FakeHandler) KeepOnRunning

func (h *FakeHandler) KeepOnRunning()

func (*FakeHandler) RegisterAdditionalFunc

func (h *FakeHandler) RegisterAdditionalFunc(handlerFunc boshhandler.Func)

func (*FakeHandler) Run

func (h *FakeHandler) Run(handlerFunc boshhandler.Func) error

func (*FakeHandler) Send

func (h *FakeHandler) Send(target boshhandler.Target, topic boshhandler.Topic, message interface{}) error

func (*FakeHandler) SendInputs

func (h *FakeHandler) SendInputs() []SendInput

func (*FakeHandler) Start

func (h *FakeHandler) Start(handlerFunc boshhandler.Func) error

func (*FakeHandler) Stop

func (h *FakeHandler) Stop()

type FakeNATSClient

type FakeNATSClient struct {
	PingStub func() bool

	ConnectStub func(connectionProvider yagnats.ConnectionProvider) error

	DisconnectStub func()

	PublishStub func(subject string, payload []byte) error

	PublishWithReplyToStub func(subject, reply string, payload []byte) error

	SubscribeStub func(subject string, callback yagnats.Callback) (int64, error)

	SubscribeWithQueueStub func(subject, queue string, callback yagnats.Callback) (int64, error)

	UnsubscribeStub func(subscription int64) error

	UnsubscribeAllStub func(subject string)

	BeforeConnectCallbackStub func(callback func())
	// contains filtered or unexported fields
}

func (*FakeNATSClient) BeforeConnectCallback

func (fake *FakeNATSClient) BeforeConnectCallback(callback func())

func (*FakeNATSClient) BeforeConnectCallbackArgsForCall

func (fake *FakeNATSClient) BeforeConnectCallbackArgsForCall(i int) func()

func (*FakeNATSClient) BeforeConnectCallbackCallCount

func (fake *FakeNATSClient) BeforeConnectCallbackCallCount() int

func (*FakeNATSClient) Connect

func (fake *FakeNATSClient) Connect(connectionProvider yagnats.ConnectionProvider) error

func (*FakeNATSClient) ConnectArgsForCall

func (fake *FakeNATSClient) ConnectArgsForCall(i int) yagnats.ConnectionProvider

func (*FakeNATSClient) ConnectCallCount

func (fake *FakeNATSClient) ConnectCallCount() int

func (*FakeNATSClient) ConnectReturns

func (fake *FakeNATSClient) ConnectReturns(result1 error)

func (*FakeNATSClient) ConnectReturnsOnCall

func (fake *FakeNATSClient) ConnectReturnsOnCall(i int, result1 error)

func (*FakeNATSClient) Disconnect

func (fake *FakeNATSClient) Disconnect()

func (*FakeNATSClient) DisconnectCallCount

func (fake *FakeNATSClient) DisconnectCallCount() int

func (*FakeNATSClient) Invocations

func (fake *FakeNATSClient) Invocations() map[string][][]interface{}

func (*FakeNATSClient) Ping

func (fake *FakeNATSClient) Ping() bool

func (*FakeNATSClient) PingCallCount

func (fake *FakeNATSClient) PingCallCount() int

func (*FakeNATSClient) PingReturns

func (fake *FakeNATSClient) PingReturns(result1 bool)

func (*FakeNATSClient) PingReturnsOnCall

func (fake *FakeNATSClient) PingReturnsOnCall(i int, result1 bool)

func (*FakeNATSClient) Publish

func (fake *FakeNATSClient) Publish(subject string, payload []byte) error

func (*FakeNATSClient) PublishArgsForCall

func (fake *FakeNATSClient) PublishArgsForCall(i int) (string, []byte)

func (*FakeNATSClient) PublishCallCount

func (fake *FakeNATSClient) PublishCallCount() int

func (*FakeNATSClient) PublishReturns

func (fake *FakeNATSClient) PublishReturns(result1 error)

func (*FakeNATSClient) PublishReturnsOnCall

func (fake *FakeNATSClient) PublishReturnsOnCall(i int, result1 error)

func (*FakeNATSClient) PublishWithReplyTo

func (fake *FakeNATSClient) PublishWithReplyTo(subject string, reply string, payload []byte) error

func (*FakeNATSClient) PublishWithReplyToArgsForCall

func (fake *FakeNATSClient) PublishWithReplyToArgsForCall(i int) (string, string, []byte)

func (*FakeNATSClient) PublishWithReplyToCallCount

func (fake *FakeNATSClient) PublishWithReplyToCallCount() int

func (*FakeNATSClient) PublishWithReplyToReturns

func (fake *FakeNATSClient) PublishWithReplyToReturns(result1 error)

func (*FakeNATSClient) PublishWithReplyToReturnsOnCall

func (fake *FakeNATSClient) PublishWithReplyToReturnsOnCall(i int, result1 error)

func (*FakeNATSClient) Subscribe

func (fake *FakeNATSClient) Subscribe(subject string, callback yagnats.Callback) (int64, error)

func (*FakeNATSClient) SubscribeArgsForCall

func (fake *FakeNATSClient) SubscribeArgsForCall(i int) (string, yagnats.Callback)

func (*FakeNATSClient) SubscribeCallCount

func (fake *FakeNATSClient) SubscribeCallCount() int

func (*FakeNATSClient) SubscribeReturns

func (fake *FakeNATSClient) SubscribeReturns(result1 int64, result2 error)

func (*FakeNATSClient) SubscribeReturnsOnCall

func (fake *FakeNATSClient) SubscribeReturnsOnCall(i int, result1 int64, result2 error)

func (*FakeNATSClient) SubscribeWithQueue

func (fake *FakeNATSClient) SubscribeWithQueue(subject string, queue string, callback yagnats.Callback) (int64, error)

func (*FakeNATSClient) SubscribeWithQueueArgsForCall

func (fake *FakeNATSClient) SubscribeWithQueueArgsForCall(i int) (string, string, yagnats.Callback)

func (*FakeNATSClient) SubscribeWithQueueCallCount

func (fake *FakeNATSClient) SubscribeWithQueueCallCount() int

func (*FakeNATSClient) SubscribeWithQueueReturns

func (fake *FakeNATSClient) SubscribeWithQueueReturns(result1 int64, result2 error)

func (*FakeNATSClient) SubscribeWithQueueReturnsOnCall

func (fake *FakeNATSClient) SubscribeWithQueueReturnsOnCall(i int, result1 int64, result2 error)

func (*FakeNATSClient) Unsubscribe

func (fake *FakeNATSClient) Unsubscribe(subscription int64) error

func (*FakeNATSClient) UnsubscribeAll

func (fake *FakeNATSClient) UnsubscribeAll(subject string)

func (*FakeNATSClient) UnsubscribeAllArgsForCall

func (fake *FakeNATSClient) UnsubscribeAllArgsForCall(i int) string

func (*FakeNATSClient) UnsubscribeAllCallCount

func (fake *FakeNATSClient) UnsubscribeAllCallCount() int

func (*FakeNATSClient) UnsubscribeArgsForCall

func (fake *FakeNATSClient) UnsubscribeArgsForCall(i int) int64

func (*FakeNATSClient) UnsubscribeCallCount

func (fake *FakeNATSClient) UnsubscribeCallCount() int

func (*FakeNATSClient) UnsubscribeReturns

func (fake *FakeNATSClient) UnsubscribeReturns(result1 error)

func (*FakeNATSClient) UnsubscribeReturnsOnCall

func (fake *FakeNATSClient) UnsubscribeReturnsOnCall(i int, result1 error)

type SendInput

type SendInput struct {
	Target  boshhandler.Target
	Topic   boshhandler.Topic
	Message interface{}
}

Jump to

Keyboard shortcuts

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