Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion embedded/util.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ type NodeCommand struct {
NodeId string
}

// Returns a connected client/coordinator pair for embedded/testing use
// NewEmbeddedPair returns a connected client/coordinator pair for embedded/testing use
func NewEmbeddedPair(nodeid string) (metafora.Coordinator, metafora.Client) {
taskchan := make(chan metafora.Task)
cmdchan := make(chan *NodeCommand)
Expand Down
2 changes: 1 addition & 1 deletion handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ type Handler interface {
// of work necessary to initialize a handler should be done.
type HandlerFunc func(Task) Handler

// SimpleHander creates a HandlerFunc for a simple function that accepts a stop
// SimpleHandler creates a HandlerFunc for a simple function that accepts a stop
// channel. The channel will be closed when Stop is called.
func SimpleHandler(f func(t Task, stop <-chan bool) bool) HandlerFunc {
return func(t Task) Handler {
Expand Down
2 changes: 1 addition & 1 deletion metcdv3/coordinator.go
Original file line number Diff line number Diff line change
Expand Up @@ -388,7 +388,7 @@ func (ec *EtcdV3Coordinator) Name() string {
return ec.name
}

// Start an mclient.
// Init starts an mclient.
func (ec *EtcdV3Coordinator) Init(cordCtx metafora.CoordinatorContext) error {
ec.cordCtx = cordCtx

Expand Down
2 changes: 1 addition & 1 deletion metcdv3/testutil/testutil.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ type TestCase interface {
Fatalf(format string, args ...interface{})
}

// NewEtcdClient creates a new etcd client for use by the metafora client during testing.
// NewEtcdV3Client creates a new etcd client for use by the metafora client during testing.
func NewEtcdV3Client(t TestCase) *etcdv3.Client {
if os.Getenv("ETCDTESTS") == "" {
t.Skip("ETCDTESTS unset. Skipping etcd tests.")
Expand Down