realtime

Documentation

Index

• func AllModules() *modules.ModuleSet
• type RealtimeServer
  • func NewServer(conf *v1beta1.RealtimeServerSpec, opts ...RealtimeServerOption) (*RealtimeServer, error)
  • func (rt *RealtimeServer) Start(ctx context.Context) error
• type RealtimeServerOption
  • func WithLogger(logger *zap.SugaredLogger) RealtimeServerOption
  • func WithModuleSet(moduleSet *modules.ModuleSet) RealtimeServerOption
• type RealtimeServerOptions
  • func (o *RealtimeServerOptions) Apply(opts ...RealtimeServerOption)

Functions

func AllModules

func AllModules() *modules.ModuleSet

Types

type RealtimeServer

type RealtimeServer struct {
	RealtimeServerOptions
	// contains filtered or unexported fields
}

func NewServer

func NewServer(conf *v1beta1.RealtimeServerSpec, opts ...RealtimeServerOption) (*RealtimeServer, error)

func (*RealtimeServer) Start

func (rt *RealtimeServer) Start(ctx context.Context) error

type RealtimeServerOption

type RealtimeServerOption func(*RealtimeServerOptions)

func WithLogger

func WithLogger(logger *zap.SugaredLogger) RealtimeServerOption

func WithModuleSet

func WithModuleSet(moduleSet *modules.ModuleSet) RealtimeServerOption

type RealtimeServerOptions

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

func (*RealtimeServerOptions) Apply

func (o *RealtimeServerOptions) Apply(opts ...RealtimeServerOption)