mapreduce

Documentation

Index

• type MapTask
• type MapTaskMatcher
  • func (m MapTaskMatcher) Matches(x interface{}) bool
  • func (m MapTaskMatcher) String() string
• type MapTaskResult
• type MapTaskResultMatcher
  • func (m MapTaskResultMatcher) Matches(x interface{}) bool
  • func (m MapTaskResultMatcher) String() string
• type ReduceTask
• type ReduceTaskMatcher
  • func (m ReduceTaskMatcher) Matches(x interface{}) bool
  • func (m ReduceTaskMatcher) String() string
• type ReduceTaskResult
• type ReduceTaskResultMatcher
  • func (m ReduceTaskResultMatcher) Matches(x interface{}) bool
  • func (m ReduceTaskResultMatcher) String() string
• type TaskStatus
  • func (ts TaskStatus) String() string

Types

type MapTask

type MapTask struct {
	ID            string
	InputFile     string
	Status        TaskStatus
	CreatedAt     time.Time
	InProgressAt  *time.Time
	FailedAt      *time.Time
	DoneAt        *time.Time
	RescheduledAt *time.Time
}

type MapTaskMatcher

type MapTaskMatcher struct {
	MapTask
}

func (MapTaskMatcher) Matches

func (m MapTaskMatcher) Matches(x interface{}) bool

func (MapTaskMatcher) String

func (m MapTaskMatcher) String() string

type MapTaskResult

type MapTaskResult struct {
	TaskID      string
	OutputFiles []string
	Error       error
}

type MapTaskResultMatcher

type MapTaskResultMatcher struct {
	MapTaskResult
}

func (MapTaskResultMatcher) Matches

func (m MapTaskResultMatcher) Matches(x interface{}) bool

func (MapTaskResultMatcher) String

func (m MapTaskResultMatcher) String() string

type ReduceTask

type ReduceTask struct {
	ID            string
	InputFiles    []string
	Status        TaskStatus
	CreatedAt     time.Time
	InProgressAt  *time.Time
	FailedAt      *time.Time
	DoneAt        *time.Time
	RescheduledAt *time.Time
}

type ReduceTaskMatcher

type ReduceTaskMatcher struct {
	ReduceTask
}

func (ReduceTaskMatcher) Matches

func (m ReduceTaskMatcher) Matches(x interface{}) bool

func (ReduceTaskMatcher) String

func (m ReduceTaskMatcher) String() string

type ReduceTaskResult

type ReduceTaskResult struct {
	TaskID     string
	OutputFile string
	Error      error
}

type ReduceTaskResultMatcher

type ReduceTaskResultMatcher struct {
	ReduceTaskResult
}

func (ReduceTaskResultMatcher) Matches

func (m ReduceTaskResultMatcher) Matches(x interface{}) bool

func (ReduceTaskResultMatcher) String

func (m ReduceTaskResultMatcher) String() string

type TaskStatus

type TaskStatus int

const (
	TaskCreated TaskStatus = iota
	TaskInProgress
	TaskFailed
	TaskDone
	TaskRescheduled
)

func (TaskStatus) String

func (ts TaskStatus) String() string