datanode

Documentation

Index

• func ConfigFilePath(nodeDir string) string
• func NewConfigTemplate(templateRaw string) (*template.Template, error)
• type ConfigGenerator
  • func NewConfigGenerator(conf *config.Config) (*ConfigGenerator, error)
  • func (dng *ConfigGenerator) Initiate(index int, dataNodeBinary string) (*types.DataNode, error)
  • func (dng ConfigGenerator) OverwriteConfig(ns types.NodeSet, configTemplate *template.Template) error
  • func (dng *ConfigGenerator) TemplateAndMergeConfig(ns types.NodeSet, configTemplate *template.Template) (*bytes.Buffer, error)
  • func (dng ConfigGenerator) TemplateConfig(ns types.NodeSet, configTemplate *template.Template) (*bytes.Buffer, error)
• type ConfigTemplateContext

Functions

func ConfigFilePath

func ConfigFilePath(nodeDir string) string

func NewConfigTemplate

func NewConfigTemplate(templateRaw string) (*template.Template, error)

Types

type ConfigGenerator

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

func NewConfigGenerator

func NewConfigGenerator(conf *config.Config) (*ConfigGenerator, error)

func (*ConfigGenerator) Initiate

func (dng *ConfigGenerator) Initiate(index int, dataNodeBinary string) (*types.DataNode, error)

func (ConfigGenerator) OverwriteConfig

func (dng ConfigGenerator) OverwriteConfig(ns types.NodeSet, configTemplate *template.Template) error

func (*ConfigGenerator) TemplateAndMergeConfig

func (dng *ConfigGenerator) TemplateAndMergeConfig(ns types.NodeSet, configTemplate *template.Template) (*bytes.Buffer, error)

func (ConfigGenerator) TemplateConfig

func (dng ConfigGenerator) TemplateConfig(ns types.NodeSet, configTemplate *template.Template) (*bytes.Buffer, error)

type ConfigTemplateContext

type ConfigTemplateContext struct {
	Prefix      string
	NodeHomeDir string
	NodeNumber  int
	NodeSet     types.NodeSet
}