testutils

Documentation

Index

• type BrokerProviderMock
  • func (p *BrokerProviderMock) GracefulStop(ctx context.Context) error
  • func (p *BrokerProviderMock) Init(opts *broker.InitOptions)
  • func (p *BrokerProviderMock) Publish(ctx context.Context, topic string, msg *broker.Message) error
  • func (p *BrokerProviderMock) Subscribe(ctx context.Context, topic string, handler broker.SubscribeHandler) error
• type EngineMock
  • func (e *EngineMock) Init() error
  • func (e *EngineMock) Render(w http.ResponseWriter, status int, template string, data *sync.Map) error
• type EngineMockRenderCallArgs
• type PublishCallArgs
• type ResponseMock
  • func NewResponseMock(t *testing.T) *ResponseMock
  • func (r *ResponseMock) Assert(status int, body string)
  • func (r *ResponseMock) Header() http.Header
  • func (r *ResponseMock) Write(body []byte) (int, error)
  • func (r *ResponseMock) WriteHeader(status int)
• type SubscribeCallArgs

Types

type BrokerProviderMock

type BrokerProviderMock struct {
	InitCalled        bool
	PublishCalled     bool
	PublishCallArgs   *PublishCallArgs
	SubscribeCalled   bool
	SubscribeCallArgs *SubscribeCallArgs
}

func (*BrokerProviderMock) GracefulStop

func (p *BrokerProviderMock) GracefulStop(ctx context.Context) error

func (*BrokerProviderMock) Init

func (p *BrokerProviderMock) Init(opts *broker.InitOptions)

func (*BrokerProviderMock) Publish

func (p *BrokerProviderMock) Publish(ctx context.Context, topic string, msg *broker.Message) error

func (*BrokerProviderMock) Subscribe

func (p *BrokerProviderMock) Subscribe(ctx context.Context, topic string, handler broker.SubscribeHandler) error

type EngineMock

type EngineMock struct {
	InitCalled     bool
	RenderCalled   bool
	RenderCallArgs *EngineMockRenderCallArgs
}

func (*EngineMock) Init

func (e *EngineMock) Init() error

func (*EngineMock) Render

func (e *EngineMock) Render(w http.ResponseWriter, status int, template string, data *sync.Map) error

type EngineMockRenderCallArgs

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

type PublishCallArgs

type PublishCallArgs struct {
	Ctx   context.Context
	Topic string
	Msg   *broker.Message
}

type ResponseMock

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

func NewResponseMock

func NewResponseMock(t *testing.T) *ResponseMock

func (*ResponseMock) Assert

func (r *ResponseMock) Assert(status int, body string)

func (*ResponseMock) Header

func (r *ResponseMock) Header() http.Header

func (*ResponseMock) Write

func (r *ResponseMock) Write(body []byte) (int, error)

func (*ResponseMock) WriteHeader

func (r *ResponseMock) WriteHeader(status int)

type SubscribeCallArgs

type SubscribeCallArgs struct {
	Ctx     context.Context
	Topic   string
	Handler broker.SubscribeHandler
}