service

Documentation

Index

• Constants
• func Archive(ctx common.ExtendedContext, illRepo ill_db.IllRepo, statusList string, ...) error
• func ParseDurationWithDays(archiveDelay string) (time.Duration, error)
• type Availability
• type LookupAdapterFactory
  • func NewLookupAdapterFactory(illRepo ill_db.IllRepo, dirAdapter adapter.DirectoryLookupAdapter, ...) *LookupAdapterFactory
  • func (s *LookupAdapterFactory) GetAdapterRequester(ctx common.ExtendedContext, requester ill_db.Peer) (catalog.LookupAdapter, dirapi.Entry, error)
  • func (s *LookupAdapterFactory) GetAdapterSupplier(ctx common.ExtendedContext, supplier ill_db.Peer) (catalog.LookupAdapter, error)
• type SkippedSupplier
• type SupplierLocator
  • func CreateSupplierLocator(eventBus events.EventBus, illRepo ill_db.IllRepo, ...) SupplierLocator
  • func (s *SupplierLocator) CheckAvailability(ctx common.ExtendedContext, event events.Event)
  • func (s *SupplierLocator) LocateSuppliers(ctx common.ExtendedContext, event events.Event)
  • func (s *SupplierLocator) SelectSupplier(ctx common.ExtendedContext, event events.Event)
• type WorkflowConfig
• type WorkflowManager
  • func CreateWorkflowManager(eventBus events.EventBus, illRepo ill_db.IllRepo, config WorkflowConfig) WorkflowManager
  • func (w *WorkflowManager) OnCheckAvailabilityComplete(ctx common.ExtendedContext, event events.Event)
  • func (w *WorkflowManager) OnLocateSupplierComplete(ctx common.ExtendedContext, event events.Event)
  • func (w *WorkflowManager) OnMessageRequesterComplete(ctx common.ExtendedContext, event events.Event)
  • func (w *WorkflowManager) OnMessageSupplierComplete(ctx common.ExtendedContext, event events.Event)
  • func (w *WorkflowManager) OnSelectSupplierComplete(ctx common.ExtendedContext, event events.Event)
  • func (w *WorkflowManager) RequestReceived(ctx common.ExtendedContext, event events.Event)
  • func (w *WorkflowManager) RequesterMessageReceived(ctx common.ExtendedContext, event events.Event)
  • func (w *WorkflowManager) SupplierMessageReceived(ctx common.ExtendedContext, event events.Event)

Constants

const AvailabilityKey = "availability"

const COMP = "supplier_locator"

const DATE_LAYOUT = "2006-01-02"

const ROTA_INFO_KEY = "rotaInfo"

const SUP_PROBLEM = "no-suppliers"

const WF_COMP = "workflow_manager"

Functions

func Archive

func Archive(ctx common.ExtendedContext, illRepo ill_db.IllRepo, statusList string, archiveDelay string, background bool) error

func ParseDurationWithDays

func ParseDurationWithDays(archiveDelay string) (time.Duration, error)

Types

type Availability

type Availability string

const (
	AvailabilityAvailable   Availability = "available"
	AvailabilityUnavailable Availability = "unavailable"
	AvailabilityUnknown     Availability = "unknown"
)

type LookupAdapterFactory

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

func NewLookupAdapterFactory

func NewLookupAdapterFactory(illRepo ill_db.IllRepo, dirAdapter adapter.DirectoryLookupAdapter, consortiumSymbol string, globalLookupAdapter catalog.LookupAdapter, lookupAdapterCreator catalog.LookupAdapterCreator) *LookupAdapterFactory

func (*LookupAdapterFactory) GetAdapterRequester

func (s *LookupAdapterFactory) GetAdapterRequester(ctx common.ExtendedContext, requester ill_db.Peer) (catalog.LookupAdapter, dirapi.Entry, error)

func (*LookupAdapterFactory) GetAdapterSupplier

func (s *LookupAdapterFactory) GetAdapterSupplier(ctx common.ExtendedContext, supplier ill_db.Peer) (catalog.LookupAdapter, error)

type SkippedSupplier

type SkippedSupplier struct {
	Symbol string `json:"symbol"`
	Reason string `json:"reason"`
}

type SupplierLocator

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

func CreateSupplierLocator

func CreateSupplierLocator(eventBus events.EventBus, illRepo ill_db.IllRepo, dirAdapter adapter.DirectoryLookupAdapter, lookupAdapterFactory *LookupAdapterFactory) SupplierLocator

func (*SupplierLocator) CheckAvailability

func (s *SupplierLocator) CheckAvailability(ctx common.ExtendedContext, event events.Event)

func (*SupplierLocator) LocateSuppliers

func (s *SupplierLocator) LocateSuppliers(ctx common.ExtendedContext, event events.Event)

func (*SupplierLocator) SelectSupplier

func (s *SupplierLocator) SelectSupplier(ctx common.ExtendedContext, event events.Event)

type WorkflowConfig

type WorkflowConfig struct {
}

type WorkflowManager

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

func CreateWorkflowManager

func CreateWorkflowManager(eventBus events.EventBus, illRepo ill_db.IllRepo, config WorkflowConfig) WorkflowManager

func (*WorkflowManager) OnCheckAvailabilityComplete

func (w *WorkflowManager) OnCheckAvailabilityComplete(ctx common.ExtendedContext, event events.Event)

func (*WorkflowManager) OnLocateSupplierComplete

func (w *WorkflowManager) OnLocateSupplierComplete(ctx common.ExtendedContext, event events.Event)

func (*WorkflowManager) OnMessageRequesterComplete

func (w *WorkflowManager) OnMessageRequesterComplete(ctx common.ExtendedContext, event events.Event)

func (*WorkflowManager) OnMessageSupplierComplete

func (w *WorkflowManager) OnMessageSupplierComplete(ctx common.ExtendedContext, event events.Event)

func (*WorkflowManager) OnSelectSupplierComplete

func (w *WorkflowManager) OnSelectSupplierComplete(ctx common.ExtendedContext, event events.Event)

func (*WorkflowManager) RequestReceived

func (w *WorkflowManager) RequestReceived(ctx common.ExtendedContext, event events.Event)

func (*WorkflowManager) RequesterMessageReceived

func (w *WorkflowManager) RequesterMessageReceived(ctx common.ExtendedContext, event events.Event)

func (*WorkflowManager) SupplierMessageReceived

func (w *WorkflowManager) SupplierMessageReceived(ctx common.ExtendedContext, event events.Event)