stanfakes

package
v1.16.0 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2023 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeConn 

type FakeConn struct {
	CloseStub func() error

	NatsConnStub func() *nats.Conn

	PublishStub func(string, []byte) error

	PublishAsyncStub func(string, []byte, stan.AckHandler) (string, error)

	QueueSubscribeStub func(string, string, stan.MsgHandler, ...stan.SubscriptionOption) (stan.Subscription, error)

	SubscribeStub func(string, stan.MsgHandler, ...stan.SubscriptionOption) (stan.Subscription, error)
	// contains filtered or unexported fields
}

func (*FakeConn) Close 

func (fake *FakeConn) Close() error

func (*FakeConn) CloseCallCount 

func (fake *FakeConn) CloseCallCount() int

func (*FakeConn) CloseCalls 

func (fake *FakeConn) CloseCalls(stub func() error)

func (*FakeConn) CloseReturns 

func (fake *FakeConn) CloseReturns(result1 error)

func (*FakeConn) CloseReturnsOnCall 

func (fake *FakeConn) CloseReturnsOnCall(i int, result1 error)

func (*FakeConn) Invocations 

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

func (*FakeConn) NatsConn 

func (fake *FakeConn) NatsConn() *nats.Conn

func (*FakeConn) NatsConnCallCount 

func (fake *FakeConn) NatsConnCallCount() int

func (*FakeConn) NatsConnCalls 

func (fake *FakeConn) NatsConnCalls(stub func() *nats.Conn)

func (*FakeConn) NatsConnReturns 

func (fake *FakeConn) NatsConnReturns(result1 *nats.Conn)

func (*FakeConn) NatsConnReturnsOnCall 

func (fake *FakeConn) NatsConnReturnsOnCall(i int, result1 *nats.Conn)

func (*FakeConn) Publish 

func (fake *FakeConn) Publish(arg1 string, arg2 []byte) error

func (*FakeConn) PublishArgsForCall 

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

func (*FakeConn) PublishAsync 

func (fake *FakeConn) PublishAsync(arg1 string, arg2 []byte, arg3 stan.AckHandler) (string, error)

func (*FakeConn) PublishAsyncArgsForCall 

func (fake *FakeConn) PublishAsyncArgsForCall(i int) (string, []byte, stan.AckHandler)

func (*FakeConn) PublishAsyncCallCount 

func (fake *FakeConn) PublishAsyncCallCount() int

func (*FakeConn) PublishAsyncCalls 

func (fake *FakeConn) PublishAsyncCalls(stub func(string, []byte, stan.AckHandler) (string, error))

func (*FakeConn) PublishAsyncReturns 

func (fake *FakeConn) PublishAsyncReturns(result1 string, result2 error)

func (*FakeConn) PublishAsyncReturnsOnCall 

func (fake *FakeConn) PublishAsyncReturnsOnCall(i int, result1 string, result2 error)

func (*FakeConn) PublishCallCount 

func (fake *FakeConn) PublishCallCount() int

func (*FakeConn) PublishCalls 

func (fake *FakeConn) PublishCalls(stub func(string, []byte) error)

func (*FakeConn) PublishReturns 

func (fake *FakeConn) PublishReturns(result1 error)

func (*FakeConn) PublishReturnsOnCall 

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

func (*FakeConn) QueueSubscribe 

func (fake *FakeConn) QueueSubscribe(arg1 string, arg2 string, arg3 stan.MsgHandler, arg4 ...stan.SubscriptionOption) (stan.Subscription, error)

func (*FakeConn) QueueSubscribeArgsForCall 

func (fake *FakeConn) QueueSubscribeArgsForCall(i int) (string, string, stan.MsgHandler, []stan.SubscriptionOption)

func (*FakeConn) QueueSubscribeCallCount 

func (fake *FakeConn) QueueSubscribeCallCount() int

func (*FakeConn) QueueSubscribeCalls 

func (fake *FakeConn) QueueSubscribeCalls(stub func(string, string, stan.MsgHandler, ...stan.SubscriptionOption) (stan.Subscription, error))

func (*FakeConn) QueueSubscribeReturns 

func (fake *FakeConn) QueueSubscribeReturns(result1 stan.Subscription, result2 error)

func (*FakeConn) QueueSubscribeReturnsOnCall 

func (fake *FakeConn) QueueSubscribeReturnsOnCall(i int, result1 stan.Subscription, result2 error)

func (*FakeConn) Subscribe 

func (fake *FakeConn) Subscribe(arg1 string, arg2 stan.MsgHandler, arg3 ...stan.SubscriptionOption) (stan.Subscription, error)

func (*FakeConn) SubscribeArgsForCall 

func (fake *FakeConn) SubscribeArgsForCall(i int) (string, stan.MsgHandler, []stan.SubscriptionOption)

func (*FakeConn) SubscribeCallCount 

func (fake *FakeConn) SubscribeCallCount() int

func (*FakeConn) SubscribeCalls 

func (fake *FakeConn) SubscribeCalls(stub func(string, stan.MsgHandler, ...stan.SubscriptionOption) (stan.Subscription, error))

func (*FakeConn) SubscribeReturns 

func (fake *FakeConn) SubscribeReturns(result1 stan.Subscription, result2 error)

func (*FakeConn) SubscribeReturnsOnCall 

func (fake *FakeConn) SubscribeReturnsOnCall(i int, result1 stan.Subscription, result2 error)

type FakeSubscription 

type FakeSubscription struct {
	ClearMaxPendingStub func() error

	CloseStub func() error

	DeliveredStub func() (int64, error)

	DroppedStub func() (int, error)

	IsValidStub func() bool

	MaxPendingStub func() (int, int, error)

	PendingStub func() (int, int, error)

	PendingLimitsStub func() (int, int, error)

	SetPendingLimitsStub func(int, int) error

	UnsubscribeStub func() error
	// contains filtered or unexported fields
}

func (*FakeSubscription) ClearMaxPending 

func (fake *FakeSubscription) ClearMaxPending() error

func (*FakeSubscription) ClearMaxPendingCallCount 

func (fake *FakeSubscription) ClearMaxPendingCallCount() int

func (*FakeSubscription) ClearMaxPendingCalls 

func (fake *FakeSubscription) ClearMaxPendingCalls(stub func() error)

func (*FakeSubscription) ClearMaxPendingReturns 

func (fake *FakeSubscription) ClearMaxPendingReturns(result1 error)

func (*FakeSubscription) ClearMaxPendingReturnsOnCall 

func (fake *FakeSubscription) ClearMaxPendingReturnsOnCall(i int, result1 error)

func (*FakeSubscription) Close 

func (fake *FakeSubscription) Close() error

func (*FakeSubscription) CloseCallCount 

func (fake *FakeSubscription) CloseCallCount() int

func (*FakeSubscription) CloseCalls 

func (fake *FakeSubscription) CloseCalls(stub func() error)

func (*FakeSubscription) CloseReturns 

func (fake *FakeSubscription) CloseReturns(result1 error)

func (*FakeSubscription) CloseReturnsOnCall 

func (fake *FakeSubscription) CloseReturnsOnCall(i int, result1 error)

func (*FakeSubscription) Delivered 

func (fake *FakeSubscription) Delivered() (int64, error)

func (*FakeSubscription) DeliveredCallCount 

func (fake *FakeSubscription) DeliveredCallCount() int

func (*FakeSubscription) DeliveredCalls 

func (fake *FakeSubscription) DeliveredCalls(stub func() (int64, error))

func (*FakeSubscription) DeliveredReturns 

func (fake *FakeSubscription) DeliveredReturns(result1 int64, result2 error)

func (*FakeSubscription) DeliveredReturnsOnCall 

func (fake *FakeSubscription) DeliveredReturnsOnCall(i int, result1 int64, result2 error)

func (*FakeSubscription) Dropped 

func (fake *FakeSubscription) Dropped() (int, error)

func (*FakeSubscription) DroppedCallCount 

func (fake *FakeSubscription) DroppedCallCount() int

func (*FakeSubscription) DroppedCalls 

func (fake *FakeSubscription) DroppedCalls(stub func() (int, error))

func (*FakeSubscription) DroppedReturns 

func (fake *FakeSubscription) DroppedReturns(result1 int, result2 error)

func (*FakeSubscription) DroppedReturnsOnCall 

func (fake *FakeSubscription) DroppedReturnsOnCall(i int, result1 int, result2 error)

func (*FakeSubscription) Invocations 

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

func (*FakeSubscription) IsValid 

func (fake *FakeSubscription) IsValid() bool

func (*FakeSubscription) IsValidCallCount 

func (fake *FakeSubscription) IsValidCallCount() int

func (*FakeSubscription) IsValidCalls 

func (fake *FakeSubscription) IsValidCalls(stub func() bool)

func (*FakeSubscription) IsValidReturns 

func (fake *FakeSubscription) IsValidReturns(result1 bool)

func (*FakeSubscription) IsValidReturnsOnCall 

func (fake *FakeSubscription) IsValidReturnsOnCall(i int, result1 bool)

func (*FakeSubscription) MaxPending 

func (fake *FakeSubscription) MaxPending() (int, int, error)

func (*FakeSubscription) MaxPendingCallCount 

func (fake *FakeSubscription) MaxPendingCallCount() int

func (*FakeSubscription) MaxPendingCalls 

func (fake *FakeSubscription) MaxPendingCalls(stub func() (int, int, error))

func (*FakeSubscription) MaxPendingReturns 

func (fake *FakeSubscription) MaxPendingReturns(result1 int, result2 int, result3 error)

func (*FakeSubscription) MaxPendingReturnsOnCall 

func (fake *FakeSubscription) MaxPendingReturnsOnCall(i int, result1 int, result2 int, result3 error)

func (*FakeSubscription) Pending 

func (fake *FakeSubscription) Pending() (int, int, error)

func (*FakeSubscription) PendingCallCount 

func (fake *FakeSubscription) PendingCallCount() int

func (*FakeSubscription) PendingCalls 

func (fake *FakeSubscription) PendingCalls(stub func() (int, int, error))

func (*FakeSubscription) PendingLimits 

func (fake *FakeSubscription) PendingLimits() (int, int, error)

func (*FakeSubscription) PendingLimitsCallCount 

func (fake *FakeSubscription) PendingLimitsCallCount() int

func (*FakeSubscription) PendingLimitsCalls 

func (fake *FakeSubscription) PendingLimitsCalls(stub func() (int, int, error))

func (*FakeSubscription) PendingLimitsReturns 

func (fake *FakeSubscription) PendingLimitsReturns(result1 int, result2 int, result3 error)

func (*FakeSubscription) PendingLimitsReturnsOnCall 

func (fake *FakeSubscription) PendingLimitsReturnsOnCall(i int, result1 int, result2 int, result3 error)

func (*FakeSubscription) PendingReturns 

func (fake *FakeSubscription) PendingReturns(result1 int, result2 int, result3 error)

func (*FakeSubscription) PendingReturnsOnCall 

func (fake *FakeSubscription) PendingReturnsOnCall(i int, result1 int, result2 int, result3 error)

func (*FakeSubscription) SetPendingLimits 

func (fake *FakeSubscription) SetPendingLimits(arg1 int, arg2 int) error

func (*FakeSubscription) SetPendingLimitsArgsForCall 

func (fake *FakeSubscription) SetPendingLimitsArgsForCall(i int) (int, int)

func (*FakeSubscription) SetPendingLimitsCallCount 

func (fake *FakeSubscription) SetPendingLimitsCallCount() int

func (*FakeSubscription) SetPendingLimitsCalls 

func (fake *FakeSubscription) SetPendingLimitsCalls(stub func(int, int) error)

func (*FakeSubscription) SetPendingLimitsReturns 

func (fake *FakeSubscription) SetPendingLimitsReturns(result1 error)

func (*FakeSubscription) SetPendingLimitsReturnsOnCall 

func (fake *FakeSubscription) SetPendingLimitsReturnsOnCall(i int, result1 error)

func (*FakeSubscription) Unsubscribe 

func (fake *FakeSubscription) Unsubscribe() error

func (*FakeSubscription) UnsubscribeCallCount 

func (fake *FakeSubscription) UnsubscribeCallCount() int

func (*FakeSubscription) UnsubscribeCalls 

func (fake *FakeSubscription) UnsubscribeCalls(stub func() error)

func (*FakeSubscription) UnsubscribeReturns 

func (fake *FakeSubscription) UnsubscribeReturns(result1 error)

func (*FakeSubscription) UnsubscribeReturnsOnCall 

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

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.