mocks

Documentation

Index

• func ClientWithError(err error) *http.Client
• func ClientWithResponseCode(responseCode int) *http.Client
• type Dispatcher
  • func (m *Dispatcher) Send(notification dispatch.Notification)
  • func (m *Dispatcher) Start()
  • func (m *Dispatcher) Stop()
  • func (m *Dispatcher) Subscribe(address string, subType string, monitoring bool) dispatch.Subscriber
  • func (m *Dispatcher) Subscribers() []dispatch.Subscriber
  • func (m *Dispatcher) Unsubscribe(s dispatch.Subscriber)
• type KafkaConsumer
  • func (c *KafkaConsumer) ConnectivityCheck() error
• type KeyValidator
  • func (m *KeyValidator) Validate(ctx context.Context, key string) error
• type ShutdownReg
  • func NewShutdownReg() *ShutdownReg
  • func (r *ShutdownReg) RegisterOnShutdown(f func())
  • func (r *ShutdownReg) Shutdown()

Functions

func ClientWithError

func ClientWithError(err error) *http.Client

func ClientWithResponseCode

func ClientWithResponseCode(responseCode int) *http.Client

Types

type Dispatcher

type Dispatcher struct {
	mock.Mock
}

func (*Dispatcher) Send

func (m *Dispatcher) Send(notification dispatch.Notification)

func (*Dispatcher) Start

func (m *Dispatcher) Start()

func (*Dispatcher) Stop

func (m *Dispatcher) Stop()

func (*Dispatcher) Subscribe

func (m *Dispatcher) Subscribe(address string, subType string, monitoring bool) dispatch.Subscriber

func (*Dispatcher) Subscribers

func (m *Dispatcher) Subscribers() []dispatch.Subscriber

func (*Dispatcher) Unsubscribe

func (m *Dispatcher) Unsubscribe(s dispatch.Subscriber)

type KafkaConsumer

type KafkaConsumer struct {
	ConnectivityCheckF func() error
}

func (*KafkaConsumer) ConnectivityCheck

func (c *KafkaConsumer) ConnectivityCheck() error

type KeyValidator

type KeyValidator struct {
	mock.Mock
}

func (*KeyValidator) Validate

func (m *KeyValidator) Validate(ctx context.Context, key string) error

type ShutdownReg

type ShutdownReg struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewShutdownReg

func NewShutdownReg() *ShutdownReg

func (*ShutdownReg) RegisterOnShutdown

func (r *ShutdownReg) RegisterOnShutdown(f func())

func (*ShutdownReg) Shutdown

func (r *ShutdownReg) Shutdown()