test

README

Preparation

1. Install godotenv tool

$ go get -v -t github.com/joho/godotenv/cmd/godotenv 

2. Configurate Your .env File from .env.sample

$ cp .env.sample .env

⚠️ Don't modify the .env.sample as your go test source

$ vim .env

---

Run Test

$ godotenv -f .env go test -v

Documentation

Index

• Variables
• type App
  • func (app *App) ConfigureLogger(l *log.Logger)
  • func (app *App) ConfigureTextMapPropagator()
  • func (app *App) ConfigureTracerProvider()
  • func (app *App) Init()
  • func (app *App) Logger() *log.Logger
  • func (app *App) OnInit()
  • func (app *App) OnInitComplete()
  • func (app *App) OnStart(ctx context.Context)
  • func (app *App) OnStop(ctx context.Context)
  • func (app *App) TextMapPropagator() propagation.TextMapPropagator
  • func (app *App) TracerProvider() *trace.SeverityTracerProvider
• type BlackholeEventLog
  • func (l *BlackholeEventLog) Flush()
  • func (l *BlackholeEventLog) OnError(message *nsq.Message, err interface{}, stackTrace []byte)
  • func (l *BlackholeEventLog) OnProcessMessage(message *nsq.Message)
  • func (l *BlackholeEventLog) OnProcessMessageComplete(message *nsq.Message, reply nsq.ReplyCode)
• type BlackholeLoggerService
  • func (*BlackholeLoggerService) ConfigureLogger(l *log.Logger)
  • func (s *BlackholeLoggerService) CreateEventLog(ev nsq.EventEvidence) nsq.EventLog
• type Config
• type EventLog
  • func (l EventLog) Flush()
  • func (l EventLog) OnError(message *nsq.Message, err interface{}, stackTrace []byte)
  • func (l EventLog) OnProcessMessage(message *nsq.Message)
  • func (l EventLog) OnProcessMessageComplete(message *nsq.Message, reply nsq.ReplyCode)
• type GoTestStreamMessageObserver
  • func (*GoTestStreamMessageObserver) Init()
  • func (o *GoTestStreamMessageObserver) OnFinish(ctx *nsq.Context, message *nsq.Message)
  • func (o *GoTestStreamMessageObserver) OnRequeue(ctx *nsq.Context, message *nsq.Message)
  • func (o *GoTestStreamMessageObserver) OnTouch(ctx *nsq.Context, message *nsq.Message)
  • func (o *GoTestStreamMessageObserver) Type() reflect.Type
• type GoTestTopicMessageCounter
• type GoTestTopicMessageHandler
  • func (h *GoTestTopicMessageHandler) Init()
  • func (*GoTestTopicMessageHandler) MessageObserverTypes() []reflect.Type
  • func (h *GoTestTopicMessageHandler) ProcessMessage(ctx *nsq.Context, message *nsq.Message) error
• type Host
  • func (h *Host) Init(conf *Config)
  • func (h *Host) OnError(err error) (disposed bool)
• type InvalidMessageHandler
  • func (h *InvalidMessageHandler) Init()
  • func (h *InvalidMessageHandler) ProcessMessage(ctx *nsq.Context, message *nsq.Message) error
• type LoggingService
  • func (s *LoggingService) ConfigureLogger(l *log.Logger)
  • func (s *LoggingService) CreateEventLog(ev nsq.EventEvidence) nsq.EventLog
• type MockComponent
  • func (c *MockComponent) Runner() host.Runner
• type MockComponentRunner
  • func (c *MockComponentRunner) Start()
  • func (c *MockComponentRunner) Stop()
• type MultiEventLog
  • func (l MultiEventLog) Flush()
  • func (l MultiEventLog) OnError(message *nsq.Message, err interface{}, stackTrace []byte)
  • func (l MultiEventLog) OnProcessMessage(message *nsq.Message)
  • func (l MultiEventLog) OnProcessMessageComplete(message *nsq.Message, reply nsq.ReplyCode)
• type MultiLoggerService
  • func (s *MultiLoggerService) ConfigureLogger(l *log.Logger)
  • func (s *MultiLoggerService) CreateEventLog(ev nsq.EventEvidence) nsq.EventLog
• type ServiceProvider
  • func (provider *ServiceProvider) Init(conf *Config)
  • func (provider *ServiceProvider) Logger() *log.Logger

Variables

var MessageObserverManager = struct {
	*GoTestStreamMessageObserver
}{}

Types

type App

type App struct {
	Host            *Host
	Config          *Config
	ServiceProvider *ServiceProvider

	Component       *MockComponent
	ComponentRunner *MockComponentRunner
}

func (*App) ConfigureLogger

func (app *App) ConfigureLogger(l *log.Logger)

func (*App) ConfigureTextMapPropagator

func (app *App) ConfigureTextMapPropagator()

func (*App) ConfigureTracerProvider

func (app *App) ConfigureTracerProvider()

func (*App) Init

func (app *App) Init()

func (*App) Logger

func (app *App) Logger() *log.Logger

func (*App) OnInit

func (app *App) OnInit()

func (*App) OnInitComplete

func (app *App) OnInitComplete()

func (*App) OnStart

func (app *App) OnStart(ctx context.Context)

func (*App) OnStop

func (app *App) OnStop(ctx context.Context)

func (*App) TextMapPropagator

func (app *App) TextMapPropagator() propagation.TextMapPropagator

func (*App) TracerProvider

func (app *App) TracerProvider() *trace.SeverityTracerProvider

type BlackholeEventLog

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

func (*BlackholeEventLog) Flush

func (l *BlackholeEventLog) Flush()

func (*BlackholeEventLog) OnError

func (l *BlackholeEventLog) OnError(message *nsq.Message, err interface{}, stackTrace []byte)

func (*BlackholeEventLog) OnProcessMessage

func (l *BlackholeEventLog) OnProcessMessage(message *nsq.Message)

func (*BlackholeEventLog) OnProcessMessageComplete

func (l *BlackholeEventLog) OnProcessMessageComplete(message *nsq.Message, reply nsq.ReplyCode)

type BlackholeLoggerService

type BlackholeLoggerService struct {
	Buffer *bytes.Buffer
}

func (*BlackholeLoggerService) ConfigureLogger

func (*BlackholeLoggerService) ConfigureLogger(l *log.Logger)

func (*BlackholeLoggerService) CreateEventLog

func (s *BlackholeLoggerService) CreateEventLog(ev nsq.EventEvidence) nsq.EventLog

type Config

type Config struct {
	// nsq
	NsqAddress            string `env:"*TEST_NSQLOOKUPD_ADDRESS"   yaml:"-"`
	NsqChannel            string `env:"-"                          yaml:"NsqChannel"`
	NsqHandlerConcurrency int    `env:"-"                          yaml:"NsqHandlerConcurrency"`

	// jaeger
	JaegerTraceUrl string `yaml:"jaegerTraceUrl"`
	JaegerQueryUrl string `yaml:"jaegerQueryUrl"`
}

type EventLog

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

func (EventLog) Flush

func (l EventLog) Flush()

Flush implements middleware.EventLog.

func (EventLog) OnError

func (l EventLog) OnError(message *nsq.Message, err interface{}, stackTrace []byte)

LogError implements middleware.EventLog.

func (EventLog) OnProcessMessage

func (l EventLog) OnProcessMessage(message *nsq.Message)

BeforeProcessMessage implements middleware.EventLog.

func (EventLog) OnProcessMessageComplete

func (l EventLog) OnProcessMessageComplete(message *nsq.Message, reply nsq.ReplyCode)

AfterProcessMessage implements middleware.EventLog.

type GoTestStreamMessageObserver

type GoTestStreamMessageObserver struct {
	ServiceProvider *ServiceProvider
}

func (*GoTestStreamMessageObserver) Init

func (*GoTestStreamMessageObserver) Init()

func (*GoTestStreamMessageObserver) OnFinish

func (o *GoTestStreamMessageObserver) OnFinish(ctx *nsq.Context, message *nsq.Message)

OnFinish implements internal.MessageObserver.

func (*GoTestStreamMessageObserver) OnRequeue

func (o *GoTestStreamMessageObserver) OnRequeue(ctx *nsq.Context, message *nsq.Message)

OnRequeue implements internal.MessageObserver.

func (*GoTestStreamMessageObserver) OnTouch

func (o *GoTestStreamMessageObserver) OnTouch(ctx *nsq.Context, message *nsq.Message)

OnTouch implements internal.MessageObserver.

func (*GoTestStreamMessageObserver) Type

func (o *GoTestStreamMessageObserver) Type() reflect.Type

type GoTestTopicMessageCounter

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

type GoTestTopicMessageHandler

type GoTestTopicMessageHandler struct {
	ServiceProvider *ServiceProvider
	// contains filtered or unexported fields
}

func (*GoTestTopicMessageHandler) Init

func (h *GoTestTopicMessageHandler) Init()

func (*GoTestTopicMessageHandler) MessageObserverTypes

func (*GoTestTopicMessageHandler) MessageObserverTypes() []reflect.Type

MessageObserverTypes implements internal.MessageObserverAffair.

func (*GoTestTopicMessageHandler) ProcessMessage

func (h *GoTestTopicMessageHandler) ProcessMessage(ctx *nsq.Context, message *nsq.Message) error

type Host

type Host nsq.Worker

func (*Host) Init

func (h *Host) Init(conf *Config)

func (*Host) OnError

func (h *Host) OnError(err error) (disposed bool)

type InvalidMessageHandler

type InvalidMessageHandler struct {
	ServiceProvider *ServiceProvider
}

func (*InvalidMessageHandler) Init

func (h *InvalidMessageHandler) Init()

func (*InvalidMessageHandler) ProcessMessage

func (h *InvalidMessageHandler) ProcessMessage(ctx *nsq.Context, message *nsq.Message) error

type LoggingService

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

func (*LoggingService) ConfigureLogger

func (s *LoggingService) ConfigureLogger(l *log.Logger)

ConfigureLogger implements middleware.LoggingService.

func (*LoggingService) CreateEventLog

func (s *LoggingService) CreateEventLog(ev nsq.EventEvidence) nsq.EventLog

CreateEventLog implements middleware.LoggingService.

type MockComponent

type MockComponent struct {
}

func (*MockComponent) Runner

func (c *MockComponent) Runner() host.Runner

type MockComponentRunner

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

func (*MockComponentRunner) Start

func (c *MockComponentRunner) Start()

func (*MockComponentRunner) Stop

func (c *MockComponentRunner) Stop()

type MultiEventLog

type MultiEventLog struct {
	EventLogs []nsq.EventLog
}

func (MultiEventLog) Flush

func (l MultiEventLog) Flush()

Flush implements middleware.EventLog.

func (MultiEventLog) OnError

func (l MultiEventLog) OnError(message *nsq.Message, err interface{}, stackTrace []byte)

OnError implements middleware.EventLog.

func (MultiEventLog) OnProcessMessage

func (l MultiEventLog) OnProcessMessage(message *nsq.Message)

OnProcessMessage implements middleware.EventLog.

func (MultiEventLog) OnProcessMessageComplete

func (l MultiEventLog) OnProcessMessageComplete(message *nsq.Message, reply nsq.ReplyCode)

OnProcessMessageComplete implements middleware.EventLog.

type MultiLoggerService

type MultiLoggerService struct {
	LoggingServices []nsq.LoggingService
}

func (*MultiLoggerService) ConfigureLogger

func (s *MultiLoggerService) ConfigureLogger(l *log.Logger)

func (*MultiLoggerService) CreateEventLog

func (s *MultiLoggerService) CreateEventLog(ev nsq.EventEvidence) nsq.EventLog

type ServiceProvider

type ServiceProvider struct {
	ResourceName string
}

func (*ServiceProvider) Init

func (provider *ServiceProvider) Init(conf *Config)

func (*ServiceProvider) Logger

func (provider *ServiceProvider) Logger() *log.Logger