tau

Documentation

Index

• Variables
• type Config
  • func NewConfig() (*Config, error)
  • func (c *Config) BindAddress() string
• type Server
  • func NewServer(config *Config, zk utils.Zookeeper, datasetsManager dataset.Manager, ...) Server
• type ServerConfig

Variables

var (
	ErrDatasetNotFound      error = errors.New("Dataset not found")
	ErrDatasetAlreadyExists error = errors.New("Dataset already exists")
)

Types

type Config

type Config struct {
	Server    ServerConfig
	Dataset   dataset.DatasetManagerConfig
	Zookeeper utils.ZookeeperConfig
}

func NewConfig

func NewConfig() (*Config, error)

func (*Config) BindAddress

func (c *Config) BindAddress() string

type Server

type Server interface {
	Start() error
	Stop()
}

func NewServer

func NewServer(config *Config, zk utils.Zookeeper, datasetsManager dataset.Manager, storage storage.Storage) Server

type ServerConfig

type ServerConfig struct {
	Address string
	Port    string
}