Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewServer ¶
func NewServer(scheduler Scheduler, podStatusStore PodStatusStore, consulClient consulutil.ConsulClient) store
func PodStatusResponseToPodStatus ¶
func PodStatusResponseToPodStatus(resp podstore_protos.PodStatusResponse) podstatus.PodStatus
func PodStatusToResp ¶
func PodStatusToResp(podStatus podstatus.PodStatus) *podstore_protos.PodStatusResponse
Types ¶
type PodStatusStore ¶
type PodStatusStore interface { Get(key types.PodUniqueKey) (podstatus.PodStatus, *api.QueryMeta, error) Delete(podUniqueKey types.PodUniqueKey) error WaitForStatus(key types.PodUniqueKey, waitIndex uint64) (podstatus.PodStatus, *api.QueryMeta, error) List() (map[types.PodUniqueKey]podstatus.PodStatus, error) MutateStatus(ctx context.Context, key types.PodUniqueKey, mutator func(podstatus.PodStatus) (podstatus.PodStatus, error)) error }
Click to show internal directories.
Click to hide internal directories.