store

Documentation

Index

• type SQLiteStore
  • func NewSQLiteStore(instanceService instanceid.Service) (*SQLiteStore, error)
  • func (s *SQLiteStore) Add(obj interface{}) error
  • func (s *SQLiteStore) CountWorkflows(ctx context.Context, namespace, nameFilter string, ...) (int64, error)
  • func (s *SQLiteStore) Delete(obj interface{}) error
  • func (s *SQLiteStore) Get(obj interface{}) (item interface{}, exists bool, err error)
  • func (s *SQLiteStore) GetByKey(key string) (item interface{}, exists bool, err error)
  • func (s *SQLiteStore) List() []interface{}
  • func (s *SQLiteStore) ListKeys() []string
  • func (s *SQLiteStore) ListWorkflows(ctx context.Context, namespace, nameFilter string, ...) (*wfv1.WorkflowList, error)
  • func (s *SQLiteStore) Replace(list []interface{}, resourceVersion string) error
  • func (s *SQLiteStore) Resync() error
  • func (s *SQLiteStore) Update(obj interface{}) error
• type WorkflowLister
  • func NewKubeLister(wfClient versioned.Interface) WorkflowLister
• type WorkflowStore

Types

type SQLiteStore

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

SQLiteStore is a sqlite-based store.

func NewSQLiteStore

func NewSQLiteStore(instanceService instanceid.Service) (*SQLiteStore, error)

func (*SQLiteStore) Add

func (s *SQLiteStore) Add(obj interface{}) error

func (*SQLiteStore) CountWorkflows

func (s *SQLiteStore) CountWorkflows(ctx context.Context, namespace, nameFilter string, listOptions metav1.ListOptions) (int64, error)

func (*SQLiteStore) Delete

func (s *SQLiteStore) Delete(obj interface{}) error

func (*SQLiteStore) Get

func (s *SQLiteStore) Get(obj interface{}) (item interface{}, exists bool, err error)

func (*SQLiteStore) GetByKey

func (s *SQLiteStore) GetByKey(key string) (item interface{}, exists bool, err error)

func (*SQLiteStore) List

func (s *SQLiteStore) List() []interface{}

func (*SQLiteStore) ListKeys

func (s *SQLiteStore) ListKeys() []string

func (*SQLiteStore) ListWorkflows

func (s *SQLiteStore) ListWorkflows(ctx context.Context, namespace, nameFilter string, listOptions metav1.ListOptions) (*wfv1.WorkflowList, error)

func (*SQLiteStore) Replace

func (s *SQLiteStore) Replace(list []interface{}, resourceVersion string) error

func (*SQLiteStore) Resync

func (s *SQLiteStore) Resync() error

func (*SQLiteStore) Update

func (s *SQLiteStore) Update(obj interface{}) error

type WorkflowLister

type WorkflowLister interface {
	ListWorkflows(ctx context.Context, namespace, nameFilter string, listOptions metav1.ListOptions) (*wfv1.WorkflowList, error)
	CountWorkflows(ctx context.Context, namespace, nameFilter string, listOptions metav1.ListOptions) (int64, error)
}

func NewKubeLister

func NewKubeLister(wfClient versioned.Interface) WorkflowLister

type WorkflowStore

type WorkflowStore interface {
	cache.Store
}