centrifuge

Documentation

Index

• type CentrifugeClientConfig
• type ICentrifugeClient
• type IClientHandlers
• type ISubscriptionHandlers
• type UnimplementedClientHandlers
  • func (s UnimplementedClientHandlers) OnConnectedHandler(centrifuge.ConnectedEvent)
  • func (s UnimplementedClientHandlers) OnConnectingHandler(centrifuge.ConnectingEvent)
  • func (s UnimplementedClientHandlers) OnDisconnectHandler(centrifuge.DisconnectedEvent)
  • func (s UnimplementedClientHandlers) OnErrorHandler(centrifuge.ErrorEvent)
  • func (s UnimplementedClientHandlers) OnMessageHandler(centrifuge.MessageEvent)
  • func (s UnimplementedClientHandlers) OnServerJoinHandler(centrifuge.ServerJoinEvent)
  • func (s UnimplementedClientHandlers) OnServerLeaveHandler(centrifuge.ServerLeaveEvent)
  • func (s UnimplementedClientHandlers) OnServerPublicationHandler(centrifuge.ServerPublicationEvent)
  • func (s UnimplementedClientHandlers) OnServerSubscribedHandler(centrifuge.ServerSubscribedEvent)
  • func (s UnimplementedClientHandlers) OnServerSubscribingHandler(centrifuge.ServerSubscribingEvent)
  • func (s UnimplementedClientHandlers) OnServerUnsubscribedHandler(centrifuge.ServerUnsubscribedEvent)
• type UnimplementedSubscriptionHandlers
  • func (s UnimplementedSubscriptionHandlers) OnJoinHandler(centrifuge.JoinEvent)
  • func (s UnimplementedSubscriptionHandlers) OnLeaveHandler(centrifuge.LeaveEvent)
  • func (s UnimplementedSubscriptionHandlers) OnPublicationHandler(centrifuge.PublicationEvent)
  • func (s UnimplementedSubscriptionHandlers) OnSubscribedHandler(centrifuge.SubscribedEvent)
  • func (s UnimplementedSubscriptionHandlers) OnSubscribingHandler(centrifuge.SubscribingEvent)
  • func (s UnimplementedSubscriptionHandlers) OnSubscriptionErrorHandler(centrifuge.SubscriptionErrorEvent)
  • func (s UnimplementedSubscriptionHandlers) OnUnsubscribedHandler(centrifuge.UnsubscribedEvent)

Types

type CentrifugeClientConfig

type CentrifugeClientConfig struct {
	Endpoint string `json:"endpoint"`
}

type ICentrifugeClient

type ICentrifugeClient interface {
	fluffycore_contracts_common.ICloser
	fluffycore_contracts_common.IDispose
	Configure(ctx context.Context, config *CentrifugeClientConfig)
	GetClient() (*centrifuge.Client, error)
}

type IClientHandlers

type IClientHandlers interface {
	centrifuge.ConnectedHandler
	centrifuge.ConnectingHandler
	centrifuge.DisconnectHandler
	centrifuge.MessageHandler
	centrifuge.ServerPublicationHandler
	centrifuge.ServerSubscribedHandler
	centrifuge.ServerSubscribingHandler
	centrifuge.ServerUnsubscribedHandler
	centrifuge.ServerJoinHandler
	centrifuge.ServerLeaveHandler
	centrifuge.ErrorHandler
}

type ISubscriptionHandlers

type ISubscriptionHandlers interface {
	centrifuge.PublicationHandler
	centrifuge.JoinHandler
	centrifuge.LeaveHandler
	centrifuge.UnsubscribedHandler
	centrifuge.SubscribingHandler
	centrifuge.SubscribedHandler
	centrifuge.SubscriptionErrorHandler
}

type UnimplementedClientHandlers

type UnimplementedClientHandlers struct{}

func (UnimplementedClientHandlers) OnConnectedHandler

func (s UnimplementedClientHandlers) OnConnectedHandler(centrifuge.ConnectedEvent)

func (UnimplementedClientHandlers) OnConnectingHandler

func (s UnimplementedClientHandlers) OnConnectingHandler(centrifuge.ConnectingEvent)

func (UnimplementedClientHandlers) OnDisconnectHandler

func (s UnimplementedClientHandlers) OnDisconnectHandler(centrifuge.DisconnectedEvent)

func (UnimplementedClientHandlers) OnErrorHandler

func (s UnimplementedClientHandlers) OnErrorHandler(centrifuge.ErrorEvent)

func (UnimplementedClientHandlers) OnMessageHandler

func (s UnimplementedClientHandlers) OnMessageHandler(centrifuge.MessageEvent)

func (UnimplementedClientHandlers) OnServerJoinHandler

func (s UnimplementedClientHandlers) OnServerJoinHandler(centrifuge.ServerJoinEvent)

func (UnimplementedClientHandlers) OnServerLeaveHandler

func (s UnimplementedClientHandlers) OnServerLeaveHandler(centrifuge.ServerLeaveEvent)

func (UnimplementedClientHandlers) OnServerPublicationHandler

func (s UnimplementedClientHandlers) OnServerPublicationHandler(centrifuge.ServerPublicationEvent)

func (UnimplementedClientHandlers) OnServerSubscribedHandler

func (s UnimplementedClientHandlers) OnServerSubscribedHandler(centrifuge.ServerSubscribedEvent)

func (UnimplementedClientHandlers) OnServerSubscribingHandler

func (s UnimplementedClientHandlers) OnServerSubscribingHandler(centrifuge.ServerSubscribingEvent)

func (UnimplementedClientHandlers) OnServerUnsubscribedHandler

func (s UnimplementedClientHandlers) OnServerUnsubscribedHandler(centrifuge.ServerUnsubscribedEvent)

type UnimplementedSubscriptionHandlers

type UnimplementedSubscriptionHandlers struct{}

func (UnimplementedSubscriptionHandlers) OnJoinHandler

func (s UnimplementedSubscriptionHandlers) OnJoinHandler(centrifuge.JoinEvent)

func (UnimplementedSubscriptionHandlers) OnLeaveHandler

func (s UnimplementedSubscriptionHandlers) OnLeaveHandler(centrifuge.LeaveEvent)

func (UnimplementedSubscriptionHandlers) OnPublicationHandler

func (s UnimplementedSubscriptionHandlers) OnPublicationHandler(centrifuge.PublicationEvent)

func (UnimplementedSubscriptionHandlers) OnSubscribedHandler

func (s UnimplementedSubscriptionHandlers) OnSubscribedHandler(centrifuge.SubscribedEvent)

func (UnimplementedSubscriptionHandlers) OnSubscribingHandler

func (s UnimplementedSubscriptionHandlers) OnSubscribingHandler(centrifuge.SubscribingEvent)

func (UnimplementedSubscriptionHandlers) OnSubscriptionErrorHandler

func (s UnimplementedSubscriptionHandlers) OnSubscriptionErrorHandler(centrifuge.SubscriptionErrorEvent)

func (UnimplementedSubscriptionHandlers) OnUnsubscribedHandler

func (s UnimplementedSubscriptionHandlers) OnUnsubscribedHandler(centrifuge.UnsubscribedEvent)