m_etcd

type Config struct {
	// Namespace is the key prefix to allow for multitenant use of etcd.
	//
	// Namespaces must start with a / (added by NewConfig if needed).
	Namespace string

	// Name of this Metafora consumer. Only one instance of a Name is allowed to
	// run in a Namespace at a time, so if you set the Name to hostname you can
	// effectively limit Metafora to one process per server.
	Name string

	// Hosts are the URLs to create etcd clients with.
	Hosts []string

	// ClaimTTL is the timeout on task claim markers in seconds.
	//
	// Since every task must update its claim before the TTL expires, setting
	// this lower will increase the load on etcd. Setting this setting higher
	// increases the amount of time it takes a task to be rescheduled if the node
	// it was running on shutsdown uncleanly (or is separated by a network
	// partition).
	//
	// If 0 it is set to DefaultClaimTTL
	ClaimTTL uint64

	// NodeTTL is the timeout on the node's name entry in seconds.
	//
	// If 0 it is set to DefaultNodeTTL
	NodeTTL uint64

	// NewTaskFunc is the function called to unmarshal tasks from etcd into a
	// custom struct. The struct must implement the metafora.Task interface.
	//
	// If nil it is set to DefaultTaskFunc
	NewTaskFunc TaskFunc
}

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

type TaskFunc func(id, value string) metafora.Task