ablytest

Feb 6, 2025

Changes in this version

+ var Endpoint = "nonprod:sandbox"

type Sandbox

+ Endpoint string

+ func NewSandboxWithEndpoint(config *Config, endpoint string) (*Sandbox, error)

Sep 12, 2024

Changes in this version

+ var CREATE_JWT_URL string = "https://echo.ably.io/createJWT"

type Sandbox

+ func (app *Sandbox) CreateJwt(expiresIn time.Duration, invalid bool) (string, error)

+ func (app *Sandbox) GetJwtAuthParams(expiresIn time.Duration, invalid bool) url.Values

Sep 6, 2024

Changes in this version

type RoundTripRecorder

+ func NewHttpRecorder() (*RoundTripRecorder, []ably.ClientOption)

Aug 1, 2023

Changes in this version

+ func GenerateRandomString(length int) string

Jun 9, 2022

Changes in this version

type Sandbox

+ func NewSandboxWithEnv(config *Config, env string) (*Sandbox, error)

Aug 9, 2021

Changes in this version

+ var ClientOptionsInspector struct

+ var DefaultLogLevel = ably.LogNone

+ var DiscardLogger ably.Logger = discardLogger

+ var Environment = "sandbox"

+ var Instantly = Before(10 * time.Millisecond)

+ var NoBinaryProtocol bool

+ var PresenceFixtures = func() []Presence

+ var Soon = Before(Timeout)

+ var Timeout = 30 * time.Second

+ func AllPages(dst, paginatedRequest interface{}) error

+ func Contains(s, sub interface{}) bool

+ func FullRealtimeCloser(c *ably.Realtime) io.Closer

+ func GetReconnectionTimersFrom(t *testing.T, afterCalls <-chan AfterCall) (reconnect AfterCall, suspend AfterCall)

+ func ItemsEqual(expected, got []interface{}, equal func(x, y interface{}) bool) bool

+ func MergeOptions(opts ...[]ably.ClientOption) []ably.ClientOption

+ func MustQuery(req *http.Request) url.Values

+ func NewHTTPClient() *http.Client

+ func NewHTTPClientNoKeepAlive() *http.Client

+ func NewLogger(messages chan<- LogMessage) ably.Logger

+ func NewTokenParams(query url.Values) *ably.TokenParams

+ func Query(req *http.Request) (url.Values, error)

+ func ReceiveMessages(channel *ably.RealtimeChannel, name string) (messages <-chan *ably.Message, unsubscribe func(), err error)

+ func ReceivePresenceMessages(channel *ably.RealtimeChannel, action *ably.PresenceAction) (messages <-chan *ably.PresenceMessage, unsubscribe func(), err error)

+ func TestPagination(expected, request interface{}, perPage int, options ...PaginationOption) error

+ func TimeFuncs(afterCalls chan<- AfterCall) (now func() time.Time, ...)

+ func Wait(res Result, err error) error

+ type AfterCall struct

+ Ctx context.Context

+ D time.Duration

+ Deadline time.Time

+ Time chan<- time.Time

+ func (a AfterCall) IsTriggered() bool

+ func (c AfterCall) Fire()

+ type AuthReverseProxy struct

+ Listener net.Listener

+ TokenQueue []*ably.TokenDetails

+ func MustAuthReverseProxy(opts ...ably.ClientOption) *AuthReverseProxy

+ func NewAuthReverseProxy(opts ...ably.ClientOption) (*AuthReverseProxy, error)

+ func (srv *AuthReverseProxy) Callback(responseType string) func(context.Context, ably.TokenParams) (ably.Tokener, error)

+ func (srv *AuthReverseProxy) Close() error

+ func (srv *AuthReverseProxy) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (srv *AuthReverseProxy) URL(responseType string) string

+ type ChanStatesRecorder struct

+ func (cs *ChanStatesRecorder) Listen(channel *ably.RealtimeChannel) (off func())

+ func (cs *ChanStatesRecorder) States() []ably.ChannelState

+ type Channel struct

+ Name string

+ Presence []Presence

+ type Config struct

+ AccountID string

+ AppID string

+ Channels []Channel

+ Connections []Connection

+ Created int

+ ID string

+ Keys []Key

+ Labels string

+ Modified int

+ Namespaces []Namespace

+ Status int

+ TLSOnly bool

+ func DefaultConfig() *Config

+ type ConnErrorsRecorder struct

+ func (ce *ConnErrorsRecorder) Errors() []*ably.ErrorInfo

+ func (ce *ConnErrorsRecorder) Listen(r *ably.Realtime) (off func())

+ type ConnStatesRecorder struct

+ func (cs *ConnStatesRecorder) Listen(r *ably.Realtime) (off func())

+ func (cs *ConnStatesRecorder) States() []ably.ConnectionState

+ type Connection struct

+ Key string

+ Name string

+ type CryptoData struct

+ Algorithm string

+ IV string

+ Items []struct{ ... }

+ Key string

+ KeyLen int

+ Mode string

+ func LoadCryptoData(rel string) (*CryptoData, []byte, []byte, error)

+ type FmtFunc func(format string, args ...interface{})

+ func (f FmtFunc) Wrap(t *testing.T, format string, args ...interface{}) FmtFunc

+ type Key struct

+ Capability string

+ Created int

+ Expires int

+ ID string

+ Modified int

+ Privileged bool

+ ScopeID string

+ Status int

+ Type int

+ Value string

+ type LogMessage struct

+ Level ably.LogLevel

+ Message string

+ type MessageChannel chan *ably.Message

+ func (ch MessageChannel) Receive(m *ably.Message)

+ type Namespace struct

+ Created int

+ ID string

+ Modified int

+ Persisted bool

+ type PaginationOption func(*paginationOptions)

+ func PaginationWithEqual(equal func(x, y interface{}) bool) PaginationOption

+ func PaginationWithSortResult(sort func([]interface{})) PaginationOption

+ type Presence struct

+ ClientID string

+ Data string

+ Encoding string

+ type PresenceChannel chan *ably.PresenceMessage

+ func (ch PresenceChannel) Receive(m *ably.PresenceMessage)

+ type Result interface

+ Wait func(context.Context) error

+ func AssertionWaiter(assertion func() bool) Result

+ func ConnWaiter(client *ably.Realtime, do func(), expectedEvent ...ably.ConnectionEvent) Result

+ type ResultFunc func(context.Context) error

+ func (f ResultFunc) Go() Result

+ func (f ResultFunc) Wait(ctx context.Context) error

+ type ResultGroup struct

+ func (rg *ResultGroup) Add(res Result, err error)

+ func (rg *ResultGroup) GoAdd(f ResultFunc)

+ func (rg *ResultGroup) Wait() error

+ type RoundTripRecorder struct

+ func (rec *RoundTripRecorder) Hijack(rt http.RoundTripper) http.RoundTripper

+ func (rec *RoundTripRecorder) Len() int

+ func (rec *RoundTripRecorder) Request(n int) *http.Request

+ func (rec *RoundTripRecorder) Requests() []*http.Request

+ func (rec *RoundTripRecorder) Reset()

+ func (rec *RoundTripRecorder) Response(n int) *http.Response

+ func (rec *RoundTripRecorder) Responses() []*http.Response

+ func (rec *RoundTripRecorder) RoundTrip(req *http.Request) (*http.Response, error)

+ func (rec *RoundTripRecorder) Stop()

+ type Sandbox struct

+ Config *Config

+ Environment string

+ func MustSandbox(config *Config) *Sandbox

+ func NewREST(opts ...ably.ClientOption) (*Sandbox, *ably.REST)

+ func NewRealtime(opts ...ably.ClientOption) (*Sandbox, *ably.Realtime)

+ func NewSandbox(config *Config) (*Sandbox, error)

+ func NewSandboxWIthEnv(config *Config, env string) (*Sandbox, error)

+ func (app *Sandbox) Close() error

+ func (app *Sandbox) Key() string

+ func (app *Sandbox) KeyParts() (name, secret string)

+ func (app *Sandbox) NewRealtime(opts ...ably.ClientOption) *ably.Realtime

+ func (app *Sandbox) Options(opts ...ably.ClientOption) []ably.ClientOption

+ func (app *Sandbox) URL(paths ...string) string

+ type WithTimeout struct

+ func Before(d time.Duration) WithTimeout

+ func (wt WithTimeout) IsTrue(pred func() bool) bool

+ func (wt WithTimeout) NoRecv(t *testing.T, into, from interface{}, ...) (ok bool)

+ func (wt WithTimeout) Recv(t *testing.T, into, from interface{}, ...) (ok bool)

+ func (wt WithTimeout) Send(t *testing.T, ch, v interface{}, fail func(fmt string, args ...interface{}), ...) (ok bool)