etcd_helpers

Documentation

Index

• type ETCDHelper
  • func NewETCDHelper(serializationFormat *format.Format, cryptor encryption.Cryptor, ...) *ETCDHelper
  • func (t *ETCDHelper) CreateDesiredLRPsInDomains(domainCounts map[string]int) map[string][]*models.DesiredLRP
  • func (t *ETCDHelper) CreateInvalidDesiredLRPComponent()
  • func (t *ETCDHelper) CreateMalformedActualLRP(guid string, index int32)
  • func (t *ETCDHelper) CreateMalformedDesiredLRP(guid string)
  • func (t *ETCDHelper) CreateMalformedEvacuatingLRP(guid string, index int32)
  • func (t *ETCDHelper) CreateMalformedTask(guid string)
  • func (t *ETCDHelper) CreateOrphanedRunInfo(guid string, createdAt time.Time)
  • func (t *ETCDHelper) CreateOrphanedSchedulingInfo(guid string, createdAt time.Time)
  • func (t *ETCDHelper) CreateValidActualLRP(guid string, index int32)
  • func (t *ETCDHelper) CreateValidDesiredLRP(guid string)
  • func (t *ETCDHelper) CreateValidEvacuatingLRP(guid string, index int32)
  • func (t *ETCDHelper) CreateValidTask(guid string)
  • func (t *ETCDHelper) DeleteActualLRP(guid string, index int32)
  • func (t *ETCDHelper) DeleteDesiredLRP(guid string)
  • func (t *ETCDHelper) DeleteTask(guid string)
  • func (t *ETCDHelper) GetInstanceActualLRP(lrpKey *models.ActualLRPKey) (*models.ActualLRP, error)
  • func (t *ETCDHelper) SetRawActualLRP(lrp *models.ActualLRP)
  • func (t *ETCDHelper) SetRawDesiredLRP(lrp *models.DesiredLRP)
  • func (t *ETCDHelper) SetRawDesiredLRPRunInfo(model *models.DesiredLRPRunInfo)
  • func (t *ETCDHelper) SetRawDesiredLRPSchedulingInfo(model *models.DesiredLRPSchedulingInfo)
  • func (t *ETCDHelper) SetRawDomain(domain string)
  • func (t *ETCDHelper) SetRawEvacuatingActualLRP(lrp *models.ActualLRP, ttlInSeconds uint64)
  • func (t *ETCDHelper) SetRawTask(task *models.Task)

Types

type ETCDHelper

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

func NewETCDHelper

func NewETCDHelper(serializationFormat *format.Format, cryptor encryption.Cryptor, client etcd.StoreClient, clock clock.Clock) *ETCDHelper

func (*ETCDHelper) CreateDesiredLRPsInDomains

func (t *ETCDHelper) CreateDesiredLRPsInDomains(domainCounts map[string]int) map[string][]*models.DesiredLRP

func (*ETCDHelper) CreateInvalidDesiredLRPComponent

func (t *ETCDHelper) CreateInvalidDesiredLRPComponent()

func (*ETCDHelper) CreateMalformedActualLRP

func (t *ETCDHelper) CreateMalformedActualLRP(guid string, index int32)

func (*ETCDHelper) CreateMalformedDesiredLRP

func (t *ETCDHelper) CreateMalformedDesiredLRP(guid string)

func (*ETCDHelper) CreateMalformedEvacuatingLRP

func (t *ETCDHelper) CreateMalformedEvacuatingLRP(guid string, index int32)

func (*ETCDHelper) CreateMalformedTask

func (t *ETCDHelper) CreateMalformedTask(guid string)

func (*ETCDHelper) CreateOrphanedRunInfo

func (t *ETCDHelper) CreateOrphanedRunInfo(guid string, createdAt time.Time)

func (*ETCDHelper) CreateOrphanedSchedulingInfo

func (t *ETCDHelper) CreateOrphanedSchedulingInfo(guid string, createdAt time.Time)

func (*ETCDHelper) CreateValidActualLRP

func (t *ETCDHelper) CreateValidActualLRP(guid string, index int32)

func (*ETCDHelper) CreateValidDesiredLRP

func (t *ETCDHelper) CreateValidDesiredLRP(guid string)

func (*ETCDHelper) CreateValidEvacuatingLRP

func (t *ETCDHelper) CreateValidEvacuatingLRP(guid string, index int32)

func (*ETCDHelper) CreateValidTask

func (t *ETCDHelper) CreateValidTask(guid string)

func (*ETCDHelper) DeleteActualLRP

func (t *ETCDHelper) DeleteActualLRP(guid string, index int32)

func (*ETCDHelper) DeleteDesiredLRP

func (t *ETCDHelper) DeleteDesiredLRP(guid string)

func (*ETCDHelper) DeleteTask

func (t *ETCDHelper) DeleteTask(guid string)

func (*ETCDHelper) GetInstanceActualLRP

func (t *ETCDHelper) GetInstanceActualLRP(lrpKey *models.ActualLRPKey) (*models.ActualLRP, error)

func (*ETCDHelper) SetRawActualLRP

func (t *ETCDHelper) SetRawActualLRP(lrp *models.ActualLRP)

func (*ETCDHelper) SetRawDesiredLRP

func (t *ETCDHelper) SetRawDesiredLRP(lrp *models.DesiredLRP)

func (*ETCDHelper) SetRawDesiredLRPRunInfo

func (t *ETCDHelper) SetRawDesiredLRPRunInfo(model *models.DesiredLRPRunInfo)

func (*ETCDHelper) SetRawDesiredLRPSchedulingInfo

func (t *ETCDHelper) SetRawDesiredLRPSchedulingInfo(model *models.DesiredLRPSchedulingInfo)

func (*ETCDHelper) SetRawDomain

func (t *ETCDHelper) SetRawDomain(domain string)

func (*ETCDHelper) SetRawEvacuatingActualLRP

func (t *ETCDHelper) SetRawEvacuatingActualLRP(lrp *models.ActualLRP, ttlInSeconds uint64)

func (*ETCDHelper) SetRawTask

func (t *ETCDHelper) SetRawTask(task *models.Task)