offline

Documentation

Index

• Constants
• type Offline
  • func New(router router.Router, hosts *host.Hosts, rep repository.Offline, ...) *Offline
  • func (m *Offline) AccountFeatures() []string
  • func (m *Offline) Name() string
  • func (m *Offline) ServerFeatures() []string
  • func (m *Offline) Start(_ context.Context) error
  • func (m *Offline) Stop(_ context.Context) error
  • func (m *Offline) StreamFeature(_ context.Context, _ string) stravaganza.Element
• type Options

Constants

const ModuleName = "offline"

ModuleName represents offline module name.

Types

type Offline

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

Offline represents offline module type.

func New

func New(
	router router.Router,
	hosts *host.Hosts,
	rep repository.Offline,
	locker locker.Locker,
	sn *sonar.Sonar,
	opts Options,
) *Offline

New creates and initializes a new Offline instance.

func (*Offline) AccountFeatures

func (m *Offline) AccountFeatures() []string

AccountFeatures returns offline module account disco features.

func (*Offline) Name

func (m *Offline) Name() string

Name returns offline module name.

func (*Offline) ServerFeatures

func (m *Offline) ServerFeatures() []string

ServerFeatures returns offline module server disco features.

func (*Offline) Start

func (m *Offline) Start(_ context.Context) error

Start starts offline module.

func (*Offline) Stop

func (m *Offline) Stop(_ context.Context) error

Stop stops offline module.

func (*Offline) StreamFeature

func (m *Offline) StreamFeature(_ context.Context, _ string) stravaganza.Element

StreamFeature returns offline module stream feature.

type Options

type Options struct {
	// QueueSize defines maximum offline queue size.
	QueueSize int
}

Options contains offline module configuration options.