daemonsetstatus

Documentation

Index

• type ConsulStore
  • func NewConsul(statusStore statusstore.Store, namespace statusstore.Namespace) ConsulStore
  • func (c ConsulStore) CASTxn(ctx context.Context, dsID dsfields.ID, modifyIndex uint64, status Status) error
  • func (c ConsulStore) Get(dsID dsfields.ID) (Status, *api.QueryMeta, error)
  • func (c ConsulStore) SetTxn(ctx context.Context, dsID dsfields.ID, status Status) error
• type Status

Types

type ConsulStore

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

func NewConsul

func NewConsul(statusStore statusstore.Store, namespace statusstore.Namespace) ConsulStore

func (ConsulStore) CASTxn

func (c ConsulStore) CASTxn(ctx context.Context, dsID dsfields.ID, modifyIndex uint64, status Status) error

func (ConsulStore) Get

func (c ConsulStore) Get(dsID dsfields.ID) (Status, *api.QueryMeta, error)

func (ConsulStore) SetTxn

func (c ConsulStore) SetTxn(ctx context.Context, dsID dsfields.ID, status Status) error

type Status

type Status struct {
	// ManifestSHA is the sha of the manifest that was most recently
	// deployed
	ManifestSHA string `json:"manifest_sha"`

	// NodesDeployed is roughly the number of nodes that have had the manifest
	// corresponding to manifest_sha deployed to them. This number is
	// periodically sampled so that it doesn't need to be written every time a
	// node is scheduled
	NodesDeployed int `json:"nodes_deployed"`

	ReplicationInProgress bool `json:"replication_in_progress"`
}