reader

Documentation

Index

• type JobReader
  • func NewJobReader(validationConfig domain.JobValidationConfig, receiver JobReceiver) *JobReader
  • func (r JobReader) ReadFromDirectory(directory string) error
• type JobReceiver
• type NodeReader
  • func NewNodeReader(receiver NodeReceiver) *NodeReader
  • func (r NodeReader) ReadFromDirectory(directory string) error
• type NodeReceiver

Types

type JobReader

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

func NewJobReader

func NewJobReader(validationConfig domain.JobValidationConfig, receiver JobReceiver) *JobReader

func (JobReader) ReadFromDirectory

func (r JobReader) ReadFromDirectory(directory string) error

type JobReceiver

type JobReceiver interface {
	AddJob(domain.Job)
}

type NodeReader

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

func NewNodeReader

func NewNodeReader(receiver NodeReceiver) *NodeReader

func (NodeReader) ReadFromDirectory

func (r NodeReader) ReadFromDirectory(directory string) error

type NodeReceiver

type NodeReceiver interface {
	AddNode(domain.Node)
}