fakes

package
v2.367.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2021 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{}
}

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.