Documentation
¶
Index ¶
- type SQLiteStore
- func (s *SQLiteStore) Add(obj interface{}) error
- func (s *SQLiteStore) CountWorkflows(ctx context.Context, ...) (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, ...) (*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
- type WorkflowStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, createdAfter, finishedBefore 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, createdAfter, finishedBefore 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, createdAfter, finishedBefore string, listOptions metav1.ListOptions) (*wfv1.WorkflowList, error)
CountWorkflows(ctx context.Context, namespace, nameFilter, createdAfter, finishedBefore string, listOptions metav1.ListOptions) (int64, error)
}
func NewKubeLister ¶
func NewKubeLister(wfClient versioned.Interface) WorkflowLister
type WorkflowStore ¶
Source Files
Click to show internal directories.
Click to hide internal directories.