Documentation
¶
Index ¶
- Constants
- Variables
- type ActorServiceTester
- func (t *ActorServiceTester) CloseInput(name string)
- func (t *ActorServiceTester) FeedInput(name string, fragment api.Envelope)
- func (t *ActorServiceTester) GetOutputEnvelope(name string, timeout time.Duration) (*api.Envelope, error)
- func (t *ActorServiceTester) GetOutputReceiver(name string) *xbus.EnvelopeReceiver
- func (t *ActorServiceTester) RunProcess() (*api.ActorProcessingState, error)
- func (t *ActorServiceTester) SetInputEnvelope(name string, fragment *api.Envelope)
- func (t *ActorServiceTester) SetSettings(settings map[string]interface{})
- type ExpectedError
- type MatchMessage
- type TestAPCLogger
- func (l *TestAPCLogger) EnvErrorf(env *api.Envelope, format string, args ...interface{})
- func (l *TestAPCLogger) EnvNoticef(env *api.Envelope, format string, args ...interface{})
- func (l *TestAPCLogger) EnvWarningf(env *api.Envelope, format string, args ...interface{})
- func (l *TestAPCLogger) Errorf(format string, args ...interface{})
- func (l *TestAPCLogger) Noticef(format string, args ...interface{})
- func (l *TestAPCLogger) Warningf(format string, args ...interface{})
- type TestLogger
- func (m *TestLogger) ExpectsError(expectedError interface{})
- func (m *TestLogger) SetTest(t testing.TB) func()
- func (m *TestLogger) SubTest(tb testing.TB) (*TestLogger, func())
- func (m *TestLogger) SubTestCapture(tb testing.TB) func()
- func (m TestLogger) VerifyExpectations()
- func (m *TestLogger) Write(p []byte) (int, error)
- func (m *TestLogger) WriteLevel(level zerolog.Level, p []byte) (int, error)
Constants ¶
const ( // DefaultNodeID used in the ProcessingContext DefaultNodeID = "node" // DefaultActorName of the test actor DefaultActorName = "actor" )
Variables ¶
var ( // DefaultProcessID used in the ProcessingContext DefaultProcessID = api.MustUUIDFromString("af75efb0-1f0d-11e9-9513-2329a2a94eaf") // DefaultActorID of the test actor DefaultActorID = api.MustUUIDFromString("7fe4f2b8-1f0e-11e9-8661-ebbdab78f251") )
Functions ¶
This section is empty.
Types ¶
type ActorServiceTester ¶
type ActorServiceTester struct {
Apc xbus.ActorProcessingContext
Outputs map[string]*xbus.EnvelopeReceiver
// contains filtered or unexported fields
}
ActorServiceTester helps testing a ActorProcessService service
func NewActorServiceTester ¶
func NewActorServiceTester( t *testing.T, serviceName string, factory func(actor *xbus.Actor) xbus.ActorService, ) *ActorServiceTester
NewActorServiceTester creates a ActorServiceTester
func (*ActorServiceTester) CloseInput ¶
func (t *ActorServiceTester) CloseInput(name string)
CloseInput marks an input as closed
func (*ActorServiceTester) FeedInput ¶
func (t *ActorServiceTester) FeedInput(name string, fragment api.Envelope)
FeedInput adds a fragment to an input stream. Must be called _during_ Run to avoid being locked
func (*ActorServiceTester) GetOutputEnvelope ¶
func (t *ActorServiceTester) GetOutputEnvelope(name string, timeout time.Duration) (*api.Envelope, error)
GetOutputEnvelope returns the complete envelope send on a given output Run must be over
func (*ActorServiceTester) GetOutputReceiver ¶
func (t *ActorServiceTester) GetOutputReceiver(name string) *xbus.EnvelopeReceiver
GetOutputReceiver returns an envelope receiver for envelope send on a given output
func (*ActorServiceTester) RunProcess ¶
func (t *ActorServiceTester) RunProcess() (*api.ActorProcessingState, error)
RunProcess runs Process() with the inputs if provided and store the outputs for further inspection
func (*ActorServiceTester) SetInputEnvelope ¶
func (t *ActorServiceTester) SetInputEnvelope(name string, fragment *api.Envelope)
SetInputEnvelope associate an initial envelope fragment to an input If needed, further fragments can be fed during the RunProcess() with FeedInput
func (*ActorServiceTester) SetSettings ¶
func (t *ActorServiceTester) SetSettings(settings map[string]interface{})
SetSettings sets the service settings in the Actor definition
type ExpectedError ¶
type ExpectedError struct {
MatchMessage MatchMessage
Name string
}
ExpectedError is the definition of an expected error
func ExpectsContains ¶
func ExpectsContains(value string) ExpectedError
ExpectsContains returns a ExpectedError matching a partial message
func ExpectsEqual ¶
func ExpectsEqual(value string) ExpectedError
ExpectsEqual returns a ExpectedError matching a message exactly
type MatchMessage ¶
MatchMessage is a function that match a log message
type TestAPCLogger ¶
type TestAPCLogger struct {
// contains filtered or unexported fields
}
TestAPCLogger ...
func (*TestAPCLogger) EnvErrorf ¶
func (l *TestAPCLogger) EnvErrorf(env *api.Envelope, format string, args ...interface{})
EnvErrorf logs a error message
func (*TestAPCLogger) EnvNoticef ¶
func (l *TestAPCLogger) EnvNoticef(env *api.Envelope, format string, args ...interface{})
EnvNoticef logs a notice message
func (*TestAPCLogger) EnvWarningf ¶
func (l *TestAPCLogger) EnvWarningf(env *api.Envelope, format string, args ...interface{})
EnvWarningf logs a warning message
func (*TestAPCLogger) Errorf ¶
func (l *TestAPCLogger) Errorf(format string, args ...interface{})
Errorf logs a error message
func (*TestAPCLogger) Noticef ¶
func (l *TestAPCLogger) Noticef(format string, args ...interface{})
Noticef logs a notice message
func (*TestAPCLogger) Warningf ¶
func (l *TestAPCLogger) Warningf(format string, args ...interface{})
Warningf logs a warning message
type TestLogger ¶
type TestLogger struct {
xbus.ZeroLogger
// contains filtered or unexported fields
}
TestLogger is a BusLogger for tests
func GetTestLogger ¶
func GetTestLogger(t testing.TB) *TestLogger
GetTestLogger returns a new BusLogger for the passed testing.T
func (*TestLogger) ExpectsError ¶
func (m *TestLogger) ExpectsError(expectedError interface{})
ExpectsError anticipate an error and make it non-fatal to the test
func (*TestLogger) SetTest ¶
func (m *TestLogger) SetTest(t testing.TB) func()
SetTest changes the current test, and return a function to cancel the change
func (*TestLogger) SubTest ¶ added in v3.2.0
func (m *TestLogger) SubTest(tb testing.TB) (*TestLogger, func())
SubTest returns a logger for the given test. Until it is cleaned, all the logs from the parent logger will be sent to the subtest logger. The returned 'clean' function will run VerifyExpectations() on the sublogger
func (*TestLogger) SubTestCapture ¶ added in v3.2.0
func (m *TestLogger) SubTestCapture(tb testing.TB) func()
SubTestCapture is like SubTest but does not return the new logger
func (TestLogger) VerifyExpectations ¶
func (m TestLogger) VerifyExpectations()
VerifyExpectations enforce error expectations
func (*TestLogger) WriteLevel ¶ added in v3.2.0
WriteLevel implements zerolog.LevelWriter interface
Source Files