Versions in this module Expand all Collapse all v0 v0.3.5 May 23, 2020 v0.3.4 May 23, 2020 v0.3.3 Apr 26, 2020 v0.3.2 Apr 12, 2020 Changes in this version + const DefaultTimeoutDuration + func AssertEqualJSON(t *testing.T, name string, result, expected interface{}, ctx ...interface{}) bool + func AssertError(t *testing.T, err error, ctx ...interface{}) + func AssertErrorCode(t *testing.T, err error, code string, ctx ...interface{}) + func AssertNil(t *testing.T, v interface{}, ctx ...interface{}) + func AssertNoError(t *testing.T, err error, ctx ...interface{}) + func AssertNotNil(t *testing.T, v interface{}, ctx ...interface{}) + func AssertPanic(t *testing.T, cb func(), ctx ...interface{}) + func AssertPanicNoRecover(t *testing.T, cb func(), ctx ...interface{}) + func AssertResError(t *testing.T, err error, rerr *res.Error, ctx ...interface{}) + func AssertTrue(t *testing.T, expectation string, isTrue bool, ctx ...interface{}) bool + func ToResultEvents(evs []Event) []store.ResultEvent + func WithFailSubscription(cfg *SessionConfig) + func WithGnatsd(cfg *SessionConfig) + func WithKeepLogger(cfg *SessionConfig) + func WithReset(resources []string, access []string) func(*SessionConfig) + func WithTest(name string) func(*SessionConfig) + func WithoutReset(cfg *SessionConfig) + type Event struct + Changed interface{} + Idx int + Name string + Payload interface{} + Value interface{} + func (ev Event) MarshalJSON() ([]byte, error) + type MockConn struct + func NewMockConn(t *testing.T, cfg *MockConnConfig) *MockConn + func (c *MockConn) Access(rid string, req *Request) *NATSRequest + func (c *MockConn) AssertNoSubscription(subj string) + func (c *MockConn) AssertSubscription(subj string) + func (c *MockConn) Auth(rid string, method string, req *Request) *NATSRequest + func (c *MockConn) Call(rid string, method string, req *Request) *NATSRequest + func (c *MockConn) ChanSubscribe(subj string, ch chan *nats.Msg) (*nats.Subscription, error) + func (c *MockConn) Close() + func (c *MockConn) FailNextSubscription() + func (c *MockConn) Get(rid string) *NATSRequest + func (c *MockConn) GetMsg() *Msg + func (c *MockConn) GetParallelMsgs(n int) ParallelMsgs + func (c *MockConn) IsClosed() bool + func (c *MockConn) Publish(subj string, payload []byte) error + func (c *MockConn) QueryRequest(querySubj string, query string) *NATSRequest + func (c *MockConn) QueueSubscribeSyncWithChan(subj, queue string, ch chan *nats.Msg) (*nats.Subscription, error) + func (c *MockConn) Request(subj string, payload interface{}) *NATSRequest + func (c *MockConn) RequestRaw(subj string, data []byte) string + func (c *MockConn) StopServer() + type MockConnConfig struct + TimeoutDuration time.Duration + UseGnatsd bool + type Msg struct + func (m *Msg) AssertAccess(get bool, call string) *Msg + func (m *Msg) AssertAddEvent(rid string, value interface{}, idx int) *Msg + func (m *Msg) AssertChangeEvent(rid string, values interface{}) *Msg + func (m *Msg) AssertCollection(collection interface{}) *Msg + func (m *Msg) AssertCreateEvent(rid string) *Msg + func (m *Msg) AssertCustomEvent(rid string, event string, payload interface{}) *Msg + func (m *Msg) AssertDeleteEvent(rid string) *Msg + func (m *Msg) AssertError(rerr *res.Error) *Msg + func (m *Msg) AssertErrorCode(code string) *Msg + func (m *Msg) AssertEvent(rid string, ev Event) *Msg + func (m *Msg) AssertEventName(rid string, name string) *Msg + func (m *Msg) AssertEvents(events ...Event) *Msg + func (m *Msg) AssertModel(model interface{}) *Msg + func (m *Msg) AssertNoPath(path string) *Msg + func (m *Msg) AssertPathPayload(path string, payload interface{}) *Msg + func (m *Msg) AssertPathType(path string, typ interface{}) *Msg + func (m *Msg) AssertPayload(payload interface{}) *Msg + func (m *Msg) AssertQuery(query string) *Msg + func (m *Msg) AssertQueryEvent(rid string, subject *string) *Msg + func (m *Msg) AssertRawPayload(payload []byte) *Msg + func (m *Msg) AssertReaccessEvent(rid string) *Msg + func (m *Msg) AssertRemoveEvent(rid string, idx int) *Msg + func (m *Msg) AssertResource(rid string) *Msg + func (m *Msg) AssertResult(result interface{}) *Msg + func (m *Msg) AssertSubject(subject string) *Msg + func (m *Msg) AssertSystemReset(resources []string, access []string) *Msg + func (m *Msg) AssertTokenEvent(cid string, token interface{}) *Msg + func (m *Msg) Equals(subject string, payload interface{}) *Msg + func (m *Msg) HasPath(path string) (interface{}, bool) + func (m *Msg) PathPayload(path string) interface{} + func (m *Msg) Payload() interface{} + type NATSRequest struct + func (nr *NATSRequest) Response() *Msg + type ParallelMsgs struct + func (pm ParallelMsgs) GetMsg(subject string) *Msg + type Request struct + CID string + Header map[string][]string + Host string + Params json.RawMessage + Query string + RemoteAddr string + Token json.RawMessage + URI string + func DefaultAuthRequest() *Request + func DefaultCallRequest() *Request + type Session struct + func NewSession(t *testing.T, service *res.Service, opts ...func(*SessionConfig)) *Session + func (s *Session) Close() error + func (s *Session) Service() *res.Service + type SessionConfig struct + FailSubscription bool + KeepLogger bool + NoReset bool + ResetAccess []string + ResetResources []string + TestName string + ValidateReset bool
Go to main page