hadoop

Documentation

Index

• type CfgOptFunc
  • func BaseDomainSetter(v string) CfgOptFunc
  • func CustomResourceNameSetter(v string) CfgOptFunc
  • func HdfsClusterIdSetter(v string) CfgOptFunc
  • func HdfsNodeTypeSetter(v string) CfgOptFunc
  • func NameNodeFqdnSetter(v ...string) CfgOptFunc
  • func NameNodeHostSetter(v string) CfgOptFunc
  • func NameNodePortSetter(v int) CfgOptFunc
  • func NamespaceSetter(v string) CfgOptFunc
  • func ResourceCountSetter(v int) CfgOptFunc
  • func ResourceNameSetter(v string) CfgOptFunc
  • func ServiceNameSetter(v string) CfgOptFunc
• type HadoopRecipient
  • func NewHadoopRecipient(options ...CfgOptFunc) (*HadoopRecipient, error)
  • func (recipe *HadoopRecipient) Generate(dir string) error
  • func (recipe *HadoopRecipient) New() (*apiv1.ConfigMap, error)
  • func (recipe *HadoopRecipient) Parse(assetName string) (*bytes.Buffer, error)
• type HadoopStartupRecipient
  • func NewHadoopStartupRecipient(options ...StartupOptFunc) (*HadoopStartupRecipient, error)
  • func (recipe *HadoopStartupRecipient) Generate(dir string) error
  • func (recipe *HadoopStartupRecipient) Parse(assetName string) (*bytes.Buffer, error)
• type StartupOptFunc
  • func BinNameSetter(v string) StartupOptFunc
  • func CmdNameSetter(v string) StartupOptFunc
  • func HadoopHomeSetter(v string) StartupOptFunc

Types

type CfgOptFunc

type CfgOptFunc func(*HadoopRecipient) error

func BaseDomainSetter

func BaseDomainSetter(v string) CfgOptFunc

func CustomResourceNameSetter

func CustomResourceNameSetter(v string) CfgOptFunc

func HdfsClusterIdSetter

func HdfsClusterIdSetter(v string) CfgOptFunc

func HdfsNodeTypeSetter

func HdfsNodeTypeSetter(v string) CfgOptFunc

func NameNodeFqdnSetter

func NameNodeFqdnSetter(v ...string) CfgOptFunc

func NameNodeHostSetter

func NameNodeHostSetter(v string) CfgOptFunc

func NameNodePortSetter

func NameNodePortSetter(v int) CfgOptFunc

func NamespaceSetter

func NamespaceSetter(v string) CfgOptFunc

func ResourceCountSetter

func ResourceCountSetter(v int) CfgOptFunc

func ResourceNameSetter

func ResourceNameSetter(v string) CfgOptFunc

func ServiceNameSetter

func ServiceNameSetter(v string) CfgOptFunc

type HadoopRecipient

type HadoopRecipient struct {
	CustomResourceName, ResourceName, ServiceName, Namespace, BaseDomain string
	NameNodeHost                                                         string
	NameNodePort, DfsReplication                                         int
	HdfsNodeType                                                         sampleapiv1alpha1.NodeType
	HdfsClusterID                                                        string
	ResourceCount                                                        int
}

func NewHadoopRecipient

func NewHadoopRecipient(options ...CfgOptFunc) (*HadoopRecipient, error)

func (*HadoopRecipient) Generate

func (recipe *HadoopRecipient) Generate(dir string) error

func (*HadoopRecipient) New

func (recipe *HadoopRecipient) New() (*apiv1.ConfigMap, error)

func (*HadoopRecipient) Parse

func (recipe *HadoopRecipient) Parse(assetName string) (*bytes.Buffer, error)

type HadoopStartupRecipient

type HadoopStartupRecipient struct {
	BinPath, CmdName string
	EtcPath          string
	// contains filtered or unexported fields
}

func NewHadoopStartupRecipient

func NewHadoopStartupRecipient(options ...StartupOptFunc) (*HadoopStartupRecipient, error)

func (*HadoopStartupRecipient) Generate

func (recipe *HadoopStartupRecipient) Generate(dir string) error

func (*HadoopStartupRecipient) Parse

func (recipe *HadoopStartupRecipient) Parse(assetName string) (*bytes.Buffer, error)

type StartupOptFunc

type StartupOptFunc func(*HadoopStartupRecipient) error

func BinNameSetter

func BinNameSetter(v string) StartupOptFunc

func CmdNameSetter

func CmdNameSetter(v string) StartupOptFunc

func HadoopHomeSetter

func HadoopHomeSetter(v string) StartupOptFunc