Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ablytest

package

Go to main page

Versions in this module

v1

v1.2.17

Feb 2, 2024

v1.2.16

Jan 19, 2024

v1.2.15

Jan 16, 2024

v1.2.14

Oct 5, 2023

v1.2.13

Aug 1, 2023

Changes in this version

+ func GenerateRandomString(length int) string

v1.2.12

Jun 9, 2023

v1.2.11

Jan 5, 2023

v1.2.10

Dec 16, 2022

v1.2.9

Nov 25, 2022

v1.2.8

Jul 1, 2022

v1.2.7

Jun 9, 2022

Changes in this version

type Sandbox

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

v1.2.6

May 11, 2022

v1.2.5

Mar 14, 2022

v1.2.4

Feb 10, 2022

v1.2.3

Oct 27, 2021

v1.2.2

Oct 22, 2021

v1.2.1

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)