store

Documentation

Index

• type InstanceEntry
• type Store
  • func NewStore(path string) (*Store, error)
  • func (s *Store) Close() error
  • func (s *Store) CreateInstance(instance core.Instance, event core.InstanceEvent) error
  • func (s *Store) DeleteReservation(id string) error
  • func (s *Store) DestroyInstanceBucket(id string) error
  • func (s *Store) Init() error
  • func (s *Store) LoadInstances() ([]InstanceEntry, error)
  • func (s *Store) LoadReservations() ([]structs.Reservation, error)
  • func (s *Store) PutReservation(r structs.Reservation) error
  • func (s *Store) SetLastReportedEventId(instanceId string, eventId ulid.ULID) error
  • func (s *Store) UpdateInstance(instance core.Instance, event core.InstanceEvent) error

Types

type InstanceEntry

type InstanceEntry struct {
	Instance         core.Instance
	LastEvent        core.InstanceEvent
	UnreportedEvents []core.InstanceEvent
}

type Store

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

func NewStore

func NewStore(path string) (*Store, error)

func (*Store) Close

func (s *Store) Close() error

func (*Store) CreateInstance

func (s *Store) CreateInstance(instance core.Instance, event core.InstanceEvent) error

func (*Store) DeleteReservation

func (s *Store) DeleteReservation(id string) error

func (*Store) DestroyInstanceBucket

func (s *Store) DestroyInstanceBucket(id string) error

func (*Store) Init

func (s *Store) Init() error

func (*Store) LoadInstances

func (s *Store) LoadInstances() ([]InstanceEntry, error)

func (*Store) LoadReservations

func (s *Store) LoadReservations() ([]structs.Reservation, error)

func (*Store) PutReservation

func (s *Store) PutReservation(r structs.Reservation) error

func (*Store) SetLastReportedEventId

func (s *Store) SetLastReportedEventId(instanceId string, eventId ulid.ULID) error

func (*Store) UpdateInstance

func (s *Store) UpdateInstance(instance core.Instance, event core.InstanceEvent) error