proxy

package

Go to main page

Versions in this module

v3

v3.2.3

Jun 30, 2022

v3.2.2

Jun 8, 2022

v3.2.1

May 30, 2022

v3.2.0

Apr 29, 2022

v3.1.1

Dec 5, 2021

v3.1.0

Nov 6, 2021

Changes in this version

type ConnectProxy

+ func GetConnectProxy(p Proxy) (ConnectProxy, error)

+ type Proxy struct

+ BinaryEncoding bool

+ Endpoint string

+ GrpcCertFile string

+ GrpcCredentialsKey string

+ GrpcCredentialsValue string

+ GrpcMetadata []string

+ HttpHeaders []string

+ IncludeConnectionMeta bool

+ Name string

+ Timeout tools.Duration

type PublishHandlerConfig

+ GranularProxyMode bool

+ Proxies map[string]PublishProxy

type PublishProxy

+ func GetPublishProxy(p Proxy) (PublishProxy, error)

type RPCHandlerConfig

+ GranularProxyMode bool

+ Proxies map[string]RPCProxy

type RPCProxy

+ func GetRpcProxy(p Proxy) (RPCProxy, error)

type RefreshProxy

+ func GetRefreshProxy(p Proxy) (RefreshProxy, error)

type SubscribeHandlerConfig

+ GranularProxyMode bool

+ Proxies map[string]SubscribeProxy

type SubscribeProxy

+ func GetSubscribeProxy(p Proxy) (SubscribeProxy, error)

v3.0.5

Oct 18, 2021

v3.0.4

Oct 16, 2021

v3.0.3

Oct 10, 2021

v3.0.2

Oct 6, 2021

v3.0.1

Sep 12, 2021

v3.0.0

Sep 1, 2021

Changes in this version

+ const DefaultMaxIdleConnsPerHost

+ type BoolValue struct

+ Value bool

+ type Config struct

+ BinaryEncoding bool

+ ConnectEndpoint string

+ ConnectTimeout time.Duration

+ GRPCConfig GRPCConfig

+ GRPCMetadata []string

+ HTTPConfig HTTPConfig

+ HTTPHeaders []string

+ IncludeConnectionMeta bool

+ PublishEndpoint string

+ PublishTimeout time.Duration

+ RPCEndpoint string

+ RPCTimeout time.Duration

+ RefreshEndpoint string

+ RefreshTimeout time.Duration

+ SubscribeEndpoint string

+ SubscribeTimeout time.Duration

+ type ConnectCredentials struct

+ Base64Data string

+ Base64Info string

+ Channels []string

+ Data json.RawMessage

+ ExpireAt int64

+ Info json.RawMessage

+ Subs map[string]SubscribeOptions

+ UserID string

+ type ConnectHandler struct

+ func NewConnectHandler(c ConnectHandlerConfig, ruleContainer *rule.Container) *ConnectHandler

+ func (h *ConnectHandler) Handle(node *centrifuge.Node) centrifuge.ConnectingHandler

+ type ConnectHandlerConfig struct

+ Proxy ConnectProxy

+ type ConnectProxy interface

+ Protocol func() string

+ ProxyConnect func(context.Context, *proxyproto.ConnectRequest) (*proxyproto.ConnectResponse, error)

+ UseBase64 func() bool

+ type ConnectReply struct

+ Disconnect *centrifuge.Disconnect

+ Error *centrifuge.Error

+ Result *ConnectCredentials

+ type ConnectRequest struct

+ ClientID string

+ Data []byte

+ Name string

+ Transport centrifuge.TransportInfo

+ Version string

+ type GRPCConfig struct

+ CertFile string

+ Codec encoding.Codec

+ CredentialsKey string

+ CredentialsValue string

+ type GRPCConnectProxy struct

+ func NewGRPCConnectProxy(endpoint string, config Config) (*GRPCConnectProxy, error)

+ func (p *GRPCConnectProxy) Protocol() string

+ func (p *GRPCConnectProxy) ProxyConnect(ctx context.Context, req *proxyproto.ConnectRequest) (*proxyproto.ConnectResponse, error)

+ func (p *GRPCConnectProxy) UseBase64() bool

+ type GRPCPublishProxy struct

+ func NewGRPCPublishProxy(endpoint string, config Config) (*GRPCPublishProxy, error)

+ func (p *GRPCPublishProxy) IncludeMeta() bool

+ func (p *GRPCPublishProxy) Protocol() string

+ func (p *GRPCPublishProxy) ProxyPublish(ctx context.Context, req *proxyproto.PublishRequest) (*proxyproto.PublishResponse, error)

+ func (p *GRPCPublishProxy) UseBase64() bool

+ type GRPCRPCProxy struct

+ func NewGRPCRPCProxy(endpoint string, config Config) (*GRPCRPCProxy, error)

+ func (p *GRPCRPCProxy) IncludeMeta() bool

+ func (p *GRPCRPCProxy) Protocol() string

+ func (p *GRPCRPCProxy) ProxyRPC(ctx context.Context, req *proxyproto.RPCRequest) (*proxyproto.RPCResponse, error)

+ func (p *GRPCRPCProxy) UseBase64() bool

+ type GRPCRefreshProxy struct

+ func NewGRPCRefreshProxy(endpoint string, config Config) (*GRPCRefreshProxy, error)

+ func (p *GRPCRefreshProxy) IncludeMeta() bool

+ func (p *GRPCRefreshProxy) Protocol() string

+ func (p *GRPCRefreshProxy) ProxyRefresh(ctx context.Context, req *proxyproto.RefreshRequest) (*proxyproto.RefreshResponse, error)

+ func (p *GRPCRefreshProxy) UseBase64() bool

+ type GRPCSubscribeProxy struct

+ func NewGRPCSubscribeProxy(endpoint string, config Config) (*GRPCSubscribeProxy, error)

+ func (p *GRPCSubscribeProxy) IncludeMeta() bool

+ func (p *GRPCSubscribeProxy) Protocol() string

+ func (p *GRPCSubscribeProxy) ProxySubscribe(ctx context.Context, req *proxyproto.SubscribeRequest) (*proxyproto.SubscribeResponse, error)

+ func (p *GRPCSubscribeProxy) UseBase64() bool

+ type HTTPCaller interface

+ CallHTTP func(context.Context, string, http.Header, []byte) ([]byte, error)

+ func NewHTTPCaller(httpClient *http.Client) HTTPCaller

+ type HTTPConfig struct

+ Decoder proxyproto.ResponseDecoder

+ Encoder proxyproto.RequestEncoder

+ type HTTPConnectProxy struct

+ func NewHTTPConnectProxy(endpoint string, config Config) (*HTTPConnectProxy, error)

+ func (p *HTTPConnectProxy) Protocol() string

+ func (p *HTTPConnectProxy) ProxyConnect(ctx context.Context, req *proxyproto.ConnectRequest) (*proxyproto.ConnectResponse, error)

+ func (p *HTTPConnectProxy) UseBase64() bool

+ type HTTPPublishProxy struct

+ func NewHTTPPublishProxy(endpoint string, config Config) (*HTTPPublishProxy, error)

+ func (p *HTTPPublishProxy) IncludeMeta() bool

+ func (p *HTTPPublishProxy) Protocol() string

+ func (p *HTTPPublishProxy) ProxyPublish(ctx context.Context, req *proxyproto.PublishRequest) (*proxyproto.PublishResponse, error)

+ func (p *HTTPPublishProxy) UseBase64() bool

+ type HTTPRPCProxy struct

+ func NewHTTPRPCProxy(endpoint string, config Config) (*HTTPRPCProxy, error)

+ func (p *HTTPRPCProxy) IncludeMeta() bool

+ func (p *HTTPRPCProxy) Protocol() string

+ func (p *HTTPRPCProxy) ProxyRPC(ctx context.Context, req *proxyproto.RPCRequest) (*proxyproto.RPCResponse, error)

+ func (p *HTTPRPCProxy) UseBase64() bool

+ type HTTPRefreshProxy struct

+ func NewHTTPRefreshProxy(endpoint string, config Config) (*HTTPRefreshProxy, error)

+ func (p *HTTPRefreshProxy) IncludeMeta() bool

+ func (p *HTTPRefreshProxy) Protocol() string

+ func (p *HTTPRefreshProxy) ProxyRefresh(ctx context.Context, req *proxyproto.RefreshRequest) (*proxyproto.RefreshResponse, error)

+ func (p *HTTPRefreshProxy) UseBase64() bool

+ type HTTPSubscribeProxy struct

+ func NewHTTPSubscribeProxy(endpoint string, config Config) (*HTTPSubscribeProxy, error)

+ func (p *HTTPSubscribeProxy) IncludeMeta() bool

+ func (p *HTTPSubscribeProxy) Protocol() string

+ func (p *HTTPSubscribeProxy) ProxySubscribe(ctx context.Context, req *proxyproto.SubscribeRequest) (*proxyproto.SubscribeResponse, error)

+ func (p *HTTPSubscribeProxy) UseBase64() bool

+ type PublishHandler struct

+ func NewPublishHandler(c PublishHandlerConfig) *PublishHandler

+ func (h *PublishHandler) Handle(node *centrifuge.Node) PublishHandlerFunc

+ type PublishHandlerConfig struct

+ Proxy PublishProxy

+ type PublishHandlerFunc func(*centrifuge.Client, centrifuge.PublishEvent, rule.ChannelOptions) (centrifuge.PublishReply, error)

+ type PublishProxy interface

+ IncludeMeta func() bool

+ Protocol func() string

+ ProxyPublish func(context.Context, *proxyproto.PublishRequest) (*proxyproto.PublishResponse, error)

+ UseBase64 func() bool

+ type PublishReply struct

+ Disconnect *centrifuge.Disconnect

+ Error *centrifuge.Error

+ Result *PublishResult

+ type PublishRequest struct

+ Channel string

+ ClientID string

+ Data []byte

+ Transport centrifuge.TransportInfo

+ UserID string

+ type PublishRequestHTTP struct

+ Base64Data string

+ Channel string

+ Data json.RawMessage

+ UserID string

+ type PublishResult struct

+ Base64Data string

+ Data json.RawMessage

+ type RPCData struct

+ Base64Data string

+ Data json.RawMessage

+ type RPCHandler struct

+ func NewRPCHandler(c RPCHandlerConfig) *RPCHandler

+ func (h *RPCHandler) Handle(node *centrifuge.Node) RPCHandlerFunc

+ type RPCHandlerConfig struct

+ Proxy RPCProxy

+ type RPCHandlerFunc func(*centrifuge.Client, centrifuge.RPCEvent) (centrifuge.RPCReply, error)

+ type RPCProxy interface

+ IncludeMeta func() bool

+ Protocol func() string

+ ProxyRPC func(context.Context, *proxyproto.RPCRequest) (*proxyproto.RPCResponse, error)

+ UseBase64 func() bool

+ type RPCReply struct

+ Disconnect *centrifuge.Disconnect

+ Error *centrifuge.Error

+ Result *RPCData

+ type RPCRequest struct

+ ClientID string

+ Data []byte

+ Method string

+ Transport centrifuge.TransportInfo

+ UserID string

+ type RefreshCredentials struct

+ Base64Info string

+ ExpireAt int64

+ Expired bool

+ Info json.RawMessage

+ type RefreshHandler struct

+ func NewRefreshHandler(c RefreshHandlerConfig) *RefreshHandler

+ func (h *RefreshHandler) Handle(node *centrifuge.Node) RefreshHandlerFunc

+ type RefreshHandlerConfig struct

+ Proxy RefreshProxy

+ type RefreshHandlerFunc func(*centrifuge.Client, centrifuge.RefreshEvent) (centrifuge.RefreshReply, error)

+ type RefreshProxy interface

+ IncludeMeta func() bool

+ Protocol func() string

+ ProxyRefresh func(context.Context, *proxyproto.RefreshRequest) (*proxyproto.RefreshResponse, error)

+ UseBase64 func() bool

+ type RefreshReply struct

+ Disconnect *centrifuge.Disconnect

+ Error *centrifuge.Error

+ Result *RefreshCredentials

+ type RefreshRequest struct

+ ClientID string

+ Transport centrifuge.TransportInfo

+ UserID string

+ type RefreshRequestHTTP struct

+ UserID string

+ type SubscribeHandler struct

+ func NewSubscribeHandler(c SubscribeHandlerConfig) *SubscribeHandler

+ func (h *SubscribeHandler) Handle(node *centrifuge.Node) SubscribeHandlerFunc

+ type SubscribeHandlerConfig struct

+ Proxy SubscribeProxy

+ type SubscribeHandlerFunc func(*centrifuge.Client, centrifuge.SubscribeEvent, rule.ChannelOptions) (centrifuge.SubscribeReply, error)

+ type SubscribeOptionOverride struct

+ JoinLeave *BoolValue

+ Position *BoolValue

+ Presence *BoolValue

+ Recover *BoolValue

+ type SubscribeOptions struct

+ Base64Data string

+ Base64Info string

+ Data json.RawMessage

+ ExpireAt int64

+ Info json.RawMessage

+ Override *SubscribeOptionOverride

+ type SubscribeProxy interface

+ IncludeMeta func() bool

+ Protocol func() string

+ ProxySubscribe func(context.Context, *proxyproto.SubscribeRequest) (*proxyproto.SubscribeResponse, error)

+ UseBase64 func() bool

+ type SubscribeReply struct

+ Disconnect *centrifuge.Disconnect

+ Error *centrifuge.Error

+ Result *SubscribeResult

+ type SubscribeRequest struct

+ Channel string

+ ClientID string

+ Token string

+ Transport centrifuge.TransportInfo

+ UserID string

+ type SubscribeResult struct

v3.0.0-beta.2

Aug 15, 2021

v3.0.0-beta.1

Jul 12, 2021

Other modules containing this package

github.com/centrifugal/centrifugo

github.com/centrifugal/centrifugo/v4

github.com/centrifugal/centrifugo/v5

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL