centrifuge

Documentation

Index

• type Batch
• type CentrifugeClientConfig
• type CentrifugeConfig
• type ICentrifugeClient
• type ICentrifugeStreamBatcher
• type IClientHandlers
• type ISubscriptionHandlers
• type OnBatchReady
• 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 Batch

type Batch struct {
	Publications []centrifuge.Publication
}

type CentrifugeClientConfig

type CentrifugeClientConfig struct {
	Endpoint string `json:"endpoint"`
	GetToken func(evt centrifuge.ConnectionTokenEvent) (string, error)
}

type CentrifugeConfig

type CentrifugeConfig struct {
	Channel                string                     `json:"channel"`
	BatchSize              int32                      `json:"batchSize"`
	NumberOfBatches        int32                      `json:"numberOfBatches"`
	CatchupStreamPosition  *centrifuge.StreamPosition `json:"catchupStreamPosition"`
	OnBatchReady           OnBatchReady               `json:"-"`
	CentrifugeClientConfig *CentrifugeClientConfig    `json:"centrifugeClientConfig"`
}

type ICentrifugeClient

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

type ICentrifugeStreamBatcher

type ICentrifugeStreamBatcher interface {
	Configure(ctx context.Context, config *CentrifugeConfig) error
	GetBatch(ctx context.Context) (*Batch, error)
	Start(ctx context.Context) error
	Stop(ctx context.Context) 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 OnBatchReady

type OnBatchReady func()

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)