metadata

Documentation

Index

• Constants
• type Repository
  • func NewRepository(db *gorm.DB) *Repository
  • func (r *Repository) CreateBulkActions(ctx context.Context, payload []action.Persistent) error
  • func (r *Repository) CreateBulkStates(ctx context.Context, payload []state.Persistent) error
  • func (r *Repository) CreateBulkTransitions(ctx context.Context, payload []transition.Persistent) error
  • func (r *Repository) CreateBulkWorkers(ctx context.Context, payload []worker.Persistent) error
  • func (r *Repository) CreateProject(ctx context.Context, payload project.Persistent) (project.Persistent, error)
  • func (r *Repository) GetActions(ctx context.Context, projectUID string) ([]*action.Persistent, error)
  • func (r *Repository) GetProject(ctx context.Context, projectName, activityName string) (*project.Persistent, error)
  • func (r *Repository) GetStates(ctx context.Context, projectUID string) ([]*state.Persistent, error)
  • func (r *Repository) GetTransitions(ctx context.Context, projectUID string) ([]*transition.Persistent, error)
  • func (r *Repository) GetWorkers(ctx context.Context, projectUID string) ([]*worker.Persistent, error)

Constants

const (
	TableProject     = "metadata_projects"
	TableStates      = "metadata_states"
	TableActions     = "metadata_actions"
	TableTransitions = "metadata_transitions"
	TableWorkers     = "metadata_workers"
)

Types

type Repository

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

func NewRepository

func NewRepository(db *gorm.DB) *Repository

func (*Repository) CreateBulkActions

func (r *Repository) CreateBulkActions(ctx context.Context, payload []action.Persistent) error

func (*Repository) CreateBulkStates

func (r *Repository) CreateBulkStates(ctx context.Context, payload []state.Persistent) error

func (*Repository) CreateBulkTransitions

func (r *Repository) CreateBulkTransitions(ctx context.Context, payload []transition.Persistent) error

func (*Repository) CreateBulkWorkers

func (r *Repository) CreateBulkWorkers(ctx context.Context, payload []worker.Persistent) error

func (*Repository) CreateProject

func (r *Repository) CreateProject(ctx context.Context, payload project.Persistent) (project.Persistent, error)

func (*Repository) GetActions

func (r *Repository) GetActions(ctx context.Context, projectUID string) ([]*action.Persistent, error)

func (*Repository) GetProject

func (r *Repository) GetProject(ctx context.Context, projectName, activityName string) (*project.Persistent, error)

func (*Repository) GetStates

func (r *Repository) GetStates(ctx context.Context, projectUID string) ([]*state.Persistent, error)

func (*Repository) GetTransitions

func (r *Repository) GetTransitions(ctx context.Context, projectUID string) ([]*transition.Persistent, error)

func (*Repository) GetWorkers

func (r *Repository) GetWorkers(ctx context.Context, projectUID string) ([]*worker.Persistent, error)