route

Documentation

Index

• type Adapter
  • func NewAdapter(service route.Service, kubeClient kube_client.Client, mgr ctrl.Manager) *Adapter
  • func (s *Adapter) GetFromRuntime(id string) (types.RuntimeEntity, error)
  • func (s *Adapter) GetFromStorage(id string) (types.StorageEntity, error)
  • func (s *Adapter) ListRuntime() ([]types.RuntimeEntity, error)
  • func (s *Adapter) ListStorage() ([]types.StorageEntity, error)
  • func (s *Adapter) SubscribeRuntimeUpdates(syncHook types.StatusPollingHookFunc) error
• type KubeEntity
  • func (k KubeEntity) Delete() error
  • func (k KubeEntity) GetID() string
  • func (k KubeEntity) GetSpecHash() (uint64, error)
  • func (k KubeEntity) GetStatusHash() (uint64, error)
  • func (k KubeEntity) IsDeleting() bool
  • func (k KubeEntity) ReportStatus() error
• type StorageEntity
  • func (s *StorageEntity) CreateInRuntime() error
  • func (s *StorageEntity) DeleteInDB() error
  • func (s *StorageEntity) DeleteInRuntime() error
  • func (s *StorageEntity) GetID() string
  • func (s *StorageEntity) GetSpecHash() (uint64, error)
  • func (s *StorageEntity) GetStatusHash() (uint64, error)
  • func (s *StorageEntity) HasDeletionMark() bool
  • func (s *StorageEntity) IsFinished() bool
  • func (s *StorageEntity) UpdateInRuntime() error

Types

type Adapter

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

func NewAdapter

func NewAdapter(service route.Service, kubeClient kube_client.Client, mgr ctrl.Manager) *Adapter

func (*Adapter) GetFromRuntime

func (s *Adapter) GetFromRuntime(id string) (types.RuntimeEntity, error)

func (*Adapter) GetFromStorage

func (s *Adapter) GetFromStorage(id string) (types.StorageEntity, error)

func (*Adapter) ListRuntime

func (s *Adapter) ListRuntime() ([]types.RuntimeEntity, error)

func (*Adapter) ListStorage

func (s *Adapter) ListStorage() ([]types.StorageEntity, error)

func (*Adapter) SubscribeRuntimeUpdates

func (s *Adapter) SubscribeRuntimeUpdates(syncHook types.StatusPollingHookFunc) error

type KubeEntity

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

func (KubeEntity) Delete

func (k KubeEntity) Delete() error

func (KubeEntity) GetID

func (k KubeEntity) GetID() string

func (KubeEntity) GetSpecHash

func (k KubeEntity) GetSpecHash() (uint64, error)

func (KubeEntity) GetStatusHash

func (k KubeEntity) GetStatusHash() (uint64, error)

func (KubeEntity) IsDeleting

func (k KubeEntity) IsDeleting() bool

func (KubeEntity) ReportStatus

func (k KubeEntity) ReportStatus() error

type StorageEntity

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

func (*StorageEntity) CreateInRuntime

func (s *StorageEntity) CreateInRuntime() error

func (*StorageEntity) DeleteInDB

func (s *StorageEntity) DeleteInDB() error

func (*StorageEntity) DeleteInRuntime

func (s *StorageEntity) DeleteInRuntime() error

func (*StorageEntity) GetID

func (s *StorageEntity) GetID() string

func (*StorageEntity) GetSpecHash

func (s *StorageEntity) GetSpecHash() (uint64, error)

func (*StorageEntity) GetStatusHash

func (s *StorageEntity) GetStatusHash() (uint64, error)

func (*StorageEntity) HasDeletionMark

func (s *StorageEntity) HasDeletionMark() bool

func (*StorageEntity) IsFinished

func (s *StorageEntity) IsFinished() bool

func (*StorageEntity) UpdateInRuntime

func (s *StorageEntity) UpdateInRuntime() error