reservationstore

Documentation

Index

• type Store
  • func NewStore(db backend.DB, admitter admission.Admitter) *Store
  • func (s *Store) AdmitE2EReservation(ctx context.Context, request e2e.SetupRequest) (base.MessageWithPath, error)
  • func (s *Store) AdmitSegmentReservation(ctx context.Context, req *segment.SetupReq) (base.MessageWithPath, error)
  • func (s *Store) CleanupE2EReservation(ctx context.Context, req *e2e.CleanupReq) (base.MessageWithPath, error)
  • func (s *Store) CleanupSegmentReservation(ctx context.Context, req *segment.CleanupReq) (base.MessageWithPath, error)
  • func (s *Store) ConfirmSegmentReservation(ctx context.Context, req *segment.IndexConfirmationReq) (base.MessageWithPath, error)
  • func (s *Store) DeleteExpiredIndices(ctx context.Context) (int, error)
  • func (s *Store) TearDownSegmentReservation(ctx context.Context, req *segment.TeardownReq) (base.MessageWithPath, error)

Types

type Store

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

Store is the reservation store.

func NewStore

func NewStore(db backend.DB, admitter admission.Admitter) *Store

NewStore creates a new reservation store.

func (*Store) AdmitE2EReservation

func (s *Store) AdmitE2EReservation(ctx context.Context, request e2e.SetupRequest) (
	base.MessageWithPath, error)

AdmitE2EReservation will atempt to admit an e2e reservation.

func (*Store) AdmitSegmentReservation

func (s *Store) AdmitSegmentReservation(ctx context.Context, req *segment.SetupReq) (
	base.MessageWithPath, error)

AdmitSegmentReservation receives a setup/renewal request to admit a segment reservation. It is expected that this AS is not the reservation initiator.

func (*Store) CleanupE2EReservation

func (s *Store) CleanupE2EReservation(ctx context.Context, req *e2e.CleanupReq) (
	base.MessageWithPath, error)

CleanupE2EReservation will remove an index from an e2e reservation.

func (*Store) CleanupSegmentReservation

func (s *Store) CleanupSegmentReservation(ctx context.Context, req *segment.CleanupReq) (
	base.MessageWithPath, error)

CleanupSegmentReservation deletes an index from a segment reservation.

func (*Store) ConfirmSegmentReservation

func (s *Store) ConfirmSegmentReservation(ctx context.Context, req *segment.IndexConfirmationReq) (
	base.MessageWithPath, error)

ConfirmSegmentReservation changes the state of an index from temporary to confirmed.

func (*Store) DeleteExpiredIndices

func (s *Store) DeleteExpiredIndices(ctx context.Context) (int, error)

DeleteExpiredIndices will just call the DB's method to delete the expired indices.

func (*Store) TearDownSegmentReservation

func (s *Store) TearDownSegmentReservation(ctx context.Context, req *segment.TeardownReq) (
	base.MessageWithPath, error)

TearDownSegmentReservation removes a whole segment reservation.