realTime

Documentation

Index

• type Manager
  • func New(ctx context.Context, options *types.Options, db *pgxpool.Pool, ...) (*Manager, error)
  • func (m *Manager) BootstrapWS(ctx context.Context, resp *types.RPCResponse, client *types.Client, ...) error
  • func (m *Manager) Disconnect(client *types.Client)
  • func (m *Manager) DisconnectAll()
  • func (m *Manager) InitiateGracefulShutdown()
  • func (m *Manager) IsShuttingDown() bool
  • func (m *Manager) PeriodicCleanup(ctx context.Context)
  • func (m *Manager) RPC(ctx context.Context, rpc *types.RPC)
  • func (m *Manager) TriggerGracefulReconnect()
• type ManagerI

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, options *types.Options, db *pgxpool.Pool, client redis.UniversalClient, dum documentUpdater.Manager) (*Manager, error)

func (*Manager) BootstrapWS

func (m *Manager) BootstrapWS(ctx context.Context, resp *types.RPCResponse, client *types.Client, claims projectJWT.Claims) error

func (*Manager) Disconnect

func (m *Manager) Disconnect(client *types.Client)

func (*Manager) DisconnectAll

func (m *Manager) DisconnectAll()

func (*Manager) InitiateGracefulShutdown

func (m *Manager) InitiateGracefulShutdown()

func (*Manager) IsShuttingDown

func (m *Manager) IsShuttingDown() bool

func (*Manager) PeriodicCleanup

func (m *Manager) PeriodicCleanup(ctx context.Context)

func (*Manager) RPC

func (m *Manager) RPC(ctx context.Context, rpc *types.RPC)

func (*Manager) TriggerGracefulReconnect

func (m *Manager) TriggerGracefulReconnect()

type ManagerI

type ManagerI interface {
	InitiateGracefulShutdown()
	TriggerGracefulReconnect()
	DisconnectAll()
	IsShuttingDown() bool
	PeriodicCleanup(ctx context.Context)
	BootstrapWS(ctx context.Context, resp *types.RPCResponse, client *types.Client, claims projectJWT.Claims) error
	RPC(ctx context.Context, rpc *types.RPC)
	Disconnect(client *types.Client)
}