tools

Apr 29, 2022

Changes in this version

+ func ErrorMessageFromConfigError(err error, configPath string) string

type TestTransport

+ func (t *TestTransport) AppLevelPing() centrifuge.AppLevelPing

+ func (t *TestTransport) Emulation() bool

+ func (t *TestTransport) ProtocolVersion() centrifuge.ProtocolVersion

Sep 12, 2021

Changes in this version

+ type CommonGRPCProxyTestCase struct

+ Client *centrifuge.Client

+ ClientCloseFunc centrifuge.ClientCloseFunc

+ Listener *bufconn.Listener

+ Node *centrifuge.Node

+ Server *grpc.Server

+ func NewCommonGRPCProxyTestCase(ctx context.Context, srv proxyproto.CentrifugoProxyServer) *CommonGRPCProxyTestCase

+ func (c *CommonGRPCProxyTestCase) Teardown()

+ type CommonHTTPProxyTestCase struct

+ Client *centrifuge.Client

+ ClientCloseFunc centrifuge.ClientCloseFunc

+ Mux *http.ServeMux

+ Node *centrifuge.Node

+ Server *httptest.Server

+ func NewCommonHTTPProxyTestCase(ctx context.Context) *CommonHTTPProxyTestCase

+ func (c *CommonHTTPProxyTestCase) Teardown()

Sep 1, 2021

Changes in this version

+ func DecoderConfig(output interface{}) *mapstructure.DecoderConfig

+ func GenerateConfig(f string) error

+ func GetLogAddresses(addresses []string) string

+ func NodeWithMemoryEngine() *centrifuge.Node

+ func NodeWithMemoryEngineNoHandlers() *centrifuge.Node

+ func StringToDurationHookFunc() mapstructure.DecodeHookFunc

+ func StripPassword(address string) string

+ type Duration time.Duration

+ func (d *Duration) UnmarshalJSON(b []byte) error

+ func (d Duration) MarshalJSON() ([]byte, error)

+ type TestTransport struct

+ func NewTestTransport() *TestTransport

+ func (t *TestTransport) Close(disconnect *centrifuge.Disconnect) error

+ func (t *TestTransport) DisabledPushFlags() uint64

+ func (t *TestTransport) Name() string

+ func (t *TestTransport) Protocol() centrifuge.ProtocolType

+ func (t *TestTransport) Unidirectional() bool

+ func (t *TestTransport) Write(message []byte) error

+ func (t *TestTransport) WriteMany(messages ...[]byte) error