offline

Documentation

Index

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

Constants

const ModuleName = "offline"

ModuleName represents offline module name.

Types

type Config

type Config struct {
	// QueueSize defines maximum offline queue size.
	QueueSize int `fig:"queue_size" default:"200"`
}

Config contains offline module configuration value.

type Offline

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

Offline represents offline module type.

func New

func New(
	cfg Config,
	router router.Router,
	hosts *host.Hosts,
	resMng resourcemanager.Manager,
	rep repository.Repository,
	hk *hook.Hooks,
	logger kitlog.Logger,
) *Offline

New creates and initializes a new Offline instance.

func (*Offline) AccountFeatures

func (m *Offline) AccountFeatures(_ context.Context) ([]string, error)

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(_ context.Context) ([]string, error)

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, error)

StreamFeature returns offline module stream feature.