storage

Documentation

Index

• Variables
• func InitDB(ctx context.Context, db *sql.DB) error
• type OpStatus
• type PipeStore
  • func NewPipeStore(db *sql.DB) *PipeStore
  • func (s *PipeStore) Delete(ctx context.Context, name integrity.NameDigest) error
  • func (s *PipeStore) DeleteBatch(ctx context.Context, names []integrity.NameDigest) error
  • func (s *PipeStore) Load(ctx context.Context, name integrity.NameDigest) (*api.Pipe, error)
  • func (s *PipeStore) LoadBatch(ctx context.Context, names []integrity.NameDigest) iter.Seq2[*api.Pipe, error]
  • func (s *PipeStore) Scan(ctx context.Context) iter.Seq2[*api.Pipe, error]
  • func (s *PipeStore) ScanDependencies(ctx context.Context, pipe integrity.NameDigest) iter.Seq2[*api.Pipe, error]
  • func (s *PipeStore) ScanNames(ctx context.Context) iter.Seq2[integrity.NameDigest, error]
  • func (s *PipeStore) Store(ctx context.Context, pipe *api.Pipe) error
  • func (s *PipeStore) StoreBatch(ctx context.Context, objects []*api.Pipe) error
• type PlanStore
  • func NewPlanStore(db *sql.DB) *PlanStore
  • func (s *PlanStore) Finish(ctx context.Context, uuid string) error
  • func (s *PlanStore) Store(ctx context.Context, uuid string, plan *trigger.Plan) error
• type ResourceStore
  • func NewResourceStore(db *sql.DB) *ResourceStore
  • func (s *ResourceStore) StorePipeResource(ctx context.Context, resource *api.Resource, pipe *api.Pipe) error
  • func (s *ResourceStore) StoreRuleResource(ctx context.Context, resource *api.Resource, rule nuggit.Rule) error
  • func (s *ResourceStore) StoreViewResource(ctx context.Context, resource *api.Resource, viewUUID string) error
• type ResultStore
  • func NewResultStore(db *sql.DB) *ResultStore
  • func (s *ResultStore) StoreResults(ctx context.Context, event *api.TriggerEvent, results []api.TriggerResult) error
• type RuleStore
  • func NewRuleStore(db *sql.DB) *RuleStore
  • func (s *RuleStore) DeleteRule(ctx context.Context, rule nuggit.Rule) error
  • func (s *RuleStore) ScanMatched(ctx context.Context, u *url.URL) iter.Seq2[*api.Pipe, error]
  • func (s *RuleStore) StoreRule(ctx context.Context, rule nuggit.Rule) error
• type Type
• type UUID
• type ViewStore
  • func NewViewStore(db *sql.DB) *ViewStore
  • func (s *ViewStore) Store(ctx context.Context, uuid string, view nuggit.View) error

Variables

var ErrStopScan = errors.New("stop scan")

Functions

func InitDB

func InitDB(ctx context.Context, db *sql.DB) error

Types

type OpStatus

type OpStatus = string

const (
	OpUndefined OpStatus = "" // Same as StatusUnknown.
	OpUnknown   OpStatus = "unknown"
	OpStoring   OpStatus = "storing"
	OpComplete  OpStatus = "complete"
)

type PipeStore

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

func NewPipeStore

func NewPipeStore(db *sql.DB) *PipeStore

func (*PipeStore) Delete

func (s *PipeStore) Delete(ctx context.Context, name integrity.NameDigest) error

func (*PipeStore) DeleteBatch

func (s *PipeStore) DeleteBatch(ctx context.Context, names []integrity.NameDigest) error

func (*PipeStore) Load

func (s *PipeStore) Load(ctx context.Context, name integrity.NameDigest) (*api.Pipe, error)

func (*PipeStore) LoadBatch

func (s *PipeStore) LoadBatch(ctx context.Context, names []integrity.NameDigest) iter.Seq2[*api.Pipe, error]

func (*PipeStore) Scan

func (s *PipeStore) Scan(ctx context.Context) iter.Seq2[*api.Pipe, error]

func (*PipeStore) ScanDependencies

func (s *PipeStore) ScanDependencies(ctx context.Context, pipe integrity.NameDigest) iter.Seq2[*api.Pipe, error]

func (*PipeStore) ScanNames

func (s *PipeStore) ScanNames(ctx context.Context) iter.Seq2[integrity.NameDigest, error]

func (*PipeStore) Store

func (s *PipeStore) Store(ctx context.Context, pipe *api.Pipe) error

func (*PipeStore) StoreBatch

func (s *PipeStore) StoreBatch(ctx context.Context, objects []*api.Pipe) error

type PlanStore

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

func NewPlanStore

func NewPlanStore(db *sql.DB) *PlanStore

func (*PlanStore) Finish

func (s *PlanStore) Finish(ctx context.Context, uuid string) error

func (*PlanStore) Store

func (s *PlanStore) Store(ctx context.Context, uuid string, plan *trigger.Plan) error

type ResourceStore

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

func NewResourceStore

func NewResourceStore(db *sql.DB) *ResourceStore

func (*ResourceStore) StorePipeResource

func (s *ResourceStore) StorePipeResource(ctx context.Context, resource *api.Resource, pipe *api.Pipe) error

func (*ResourceStore) StoreRuleResource

func (s *ResourceStore) StoreRuleResource(ctx context.Context, resource *api.Resource, rule nuggit.Rule) error

func (*ResourceStore) StoreViewResource

func (s *ResourceStore) StoreViewResource(ctx context.Context, resource *api.Resource, viewUUID string) error

type ResultStore

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

func NewResultStore

func NewResultStore(db *sql.DB) *ResultStore

func (*ResultStore) StoreResults

func (s *ResultStore) StoreResults(ctx context.Context, event *api.TriggerEvent, results []api.TriggerResult) error

type RuleStore

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

func NewRuleStore

func NewRuleStore(db *sql.DB) *RuleStore

func (*RuleStore) DeleteRule

func (s *RuleStore) DeleteRule(ctx context.Context, rule nuggit.Rule) error

func (*RuleStore) ScanMatched

func (s *RuleStore) ScanMatched(ctx context.Context, u *url.URL) iter.Seq2[*api.Pipe, error]

func (*RuleStore) StoreRule

func (s *RuleStore) StoreRule(ctx context.Context, rule nuggit.Rule) error

type Type

type Type = string

const (
	StorageUndefined Type = "" // Same as in memory.
	StorageInMemory  Type = "inmemory"
)

type UUID

type UUID interface{ UUID() string }

type ViewStore

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

func NewViewStore

func NewViewStore(db *sql.DB) *ViewStore

func (*ViewStore) Store

func (s *ViewStore) Store(ctx context.Context, uuid string, view nuggit.View) error