event

type Bus struct {
	EventC    chan interface{}
	StopC     chan bool
	NumEvents uint64
	// contains filtered or unexported fields
}

type HeartbeatEvent struct {
	Name     string            `json:"name"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

type HttpEventNotifier struct {
	ConfigMap map[string]string
}

type Listener interface {
	Event(event interface{})
}

type ListenerFunc func(event interface{})

type MinimalHttpServer struct {
	Mux    *http.ServeMux
	Server *http.Server
	URL    string
}

type SNSEventNotifier struct {
	ConfigMap map[string]string
	// contains filtered or unexported fields
}

type TaskAbortedEvent struct {
	Name     string            `json:"name"`
	TaskId   string            `json:"taskId"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

type TaskCompletedEvent struct {
	Name     string            `json:"name"`
	TaskId   string            `json:"taskId"`
	Ok       bool              `json:"ok"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

type TaskStartedEvent struct {
	Name     string            `json:"name"`
	TaskId   string            `json:"taskId"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

type TaskSubmittedEvent struct {
	Name     string            `json:"name"`
	Metadata map[string]string `json:"metadata,omitempty"`
}