server

Documentation

Index

• func NewCommand() *cobra.Command
• func Run(ctx context.Context, conf config.Config, log *logger.Logger) error
• type Database
• type Server
  • func NewServer(ctx context.Context, conf config.Config, log *logger.Logger) (*Server, error)
  • func (s *Server) Run(ctx context.Context) error

Functions

func NewCommand

func NewCommand() *cobra.Command

NewCommand returns the node command

func Run

func Run(ctx context.Context, conf config.Config, log *logger.Logger) error

Run runs the "server run" command.

Types

type Database

type Database interface {
	tes.ReadOnlyServer
	Init() error
}

Database represents the base funnel database interface

type Server

type Server struct {
	*server.Server
	*scheduler.Scheduler
}

Server is a Funnel server + scheduler.

func NewServer

func NewServer(ctx context.Context, conf config.Config, log *logger.Logger) (*Server, error)

NewServer returns a new Funnel server + scheduler based on the given config.

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

Run runs a default Funnel server. This opens a database, and starts an API server, scheduler and task logger. This blocks indefinitely.