processadapter

Documentation

Index

• func Migrate(db *gorm.DB, logger process.Logger) error
• type GormStore
  • func NewGormStore(db *gorm.DB) *GormStore
  • func (s *GormStore) GetProcess(ctx context.Context, id string) (process.Process, error)
  • func (s *GormStore) ListProcesses(ctx context.Context, query process.Process) ([]process.Process, error)
  • func (s *GormStore) LogProcess(ctx context.Context, p process.Process) error
  • func (s *GormStore) LogProcessEvent(ctx context.Context, p process.ProcessEvent) error

Functions

func Migrate

func Migrate(db *gorm.DB, logger process.Logger) error

Migrate executes the table migrations for the process module.

Types

type GormStore

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

GormStore is a notification store using Gorm for data persistence.

func NewGormStore

func NewGormStore(db *gorm.DB) *GormStore

NewGormStore returns a new GormStore.

func (*GormStore) GetProcess

func (s *GormStore) GetProcess(ctx context.Context, id string) (process.Process, error)

GetProcess returns the list of active processes.

func (*GormStore) ListProcesses

func (s *GormStore) ListProcesses(ctx context.Context, query process.Process) ([]process.Process, error)

ListProcesses returns the list of active processes.

func (*GormStore) LogProcess

func (s *GormStore) LogProcess(ctx context.Context, p process.Process) error

LogProcess logs a process entry

func (*GormStore) LogProcessEvent

func (s *GormStore) LogProcessEvent(ctx context.Context, p process.ProcessEvent) error

LogProcessEvent logs a process event