harrowArchivist

package
v0.0.0-...-a8e4d9d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 7, 2020 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const ProgramName = "harrow-archivist"

Variables

This section is empty.

Functions

func Main

func Main()

Types

type Activities

type Activities interface {
	FindActivityByNameAndPayloadUuid(name, payloadUuid string) (*domain.Activity, error)
}

type ActivitiesInMemory

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

func NewActivitiesInMemory

func NewActivitiesInMemory() *ActivitiesInMemory

func (*ActivitiesInMemory) Add

func (self *ActivitiesInMemory) Add(activity *domain.Activity) *ActivitiesInMemory

func (*ActivitiesInMemory) FindActivityByNameAndPayloadUuid

func (self *ActivitiesInMemory) FindActivityByNameAndPayloadUuid(name string, payloadUuid string) (*domain.Activity, error)

type ActivityBus

type ActivityBus interface {
	Publish(activity *domain.Activity) error
}

type Command

type Command func() error

func DocumentEnvironmentCreations

func DocumentEnvironmentCreations(db *sqlx.DB, c *config.Config, activityBus ActivityBus) Command

func DocumentJobCreations

func DocumentJobCreations(db *sqlx.DB, c *config.Config, activityBus ActivityBus) Command

func DocumentOrganizationCreations

func DocumentOrganizationCreations(db *sqlx.DB, c *config.Config, activityBus ActivityBus) Command

func DocumentOrganizationDeletions

func DocumentOrganizationDeletions(db *sqlx.DB, c *config.Config, activityBus ActivityBus) Command

func DocumentProjectCreations

func DocumentProjectCreations(db *sqlx.DB, c *config.Config, activityBus ActivityBus) Command

func DocumentProjectDeletions

func DocumentProjectDeletions(db *sqlx.DB, c *config.Config, activityBus ActivityBus) Command

func DocumentTaskCreations

func DocumentTaskCreations(db *sqlx.DB, c *config.Config, activityBus ActivityBus) Command

type CreationSubject

type CreationSubject interface {
	Id() string
	CreationDate() time.Time
	AuthorizationName() string
}

type DeletionSubject

type DeletionSubject interface {
	Id() string
	DeletionDate() time.Time
	AuthorizationName() string
}

type DocumentCreation

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

func NewDocumentCreation

func NewDocumentCreation(subject CreationSubject, activities Activities) *DocumentCreation

func (*DocumentCreation) Activity

func (self *DocumentCreation) Activity(prototype *domain.Activity) (*domain.Activity, error)

Activity returns the activity to create for the organization.

type DocumentDeletion

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

func NewDocumentDeletion

func NewDocumentDeletion(subject DeletionSubject, activities Activities) *DocumentDeletion

func (*DocumentDeletion) Activity

func (self *DocumentDeletion) Activity(prototype *domain.Activity) (*domain.Activity, error)

Activity returns the activity to create for the organization.

type DryRunActivityBus

type DryRunActivityBus struct{}

func NewDryRunActivityBus

func NewDryRunActivityBus() *DryRunActivityBus

func (*DryRunActivityBus) Publish

func (self *DryRunActivityBus) Publish(activity *domain.Activity) error

type Errors

type Errors []error

func NewErrors

func NewErrors() Errors

func (Errors) Error

func (self Errors) Error() string

func (Errors) ToError

func (self Errors) ToError() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL