srpcconsul

type Configurer interface {
	Run() error // blocked run
	Ready() <-chan struct{}
	IsReady() bool
	Stop()
}

type KeyValueChangeWatcher struct {
	Client       *consulapi.Client
	QueryOptions *consulapi.QueryOptions
	Key          string
	Wait         time.Duration

	Value func([]byte)
	Ready func()

	Logger kitlog.Logger
	// contains filtered or unexported fields
}

type ServiceConfigurerOptions struct {
	Client            *consulapi.Client
	Service           interface{}
	ServiceCoordinate srpc.ServiceCoordinate // override
	Logger            kitlog.Logger

	Conf  interface{}
	State interface{}
}

type StateChangeWatcher struct {
	Value interface{}
	Wait  time.Duration

	Change func([]byte)
	Ready  func()

	Logger kitlog.Logger
	// contains filtered or unexported fields
}