technician

Documentation

Index

• func NewEventHandlingSystem(eventHandlingSystemType eventhandling.EventHandlingSystemType, ...) (eventhandling.EventHandlingSystem, error)
• func NewWorkHandler(workHandlerType workhandler.WorkHandlerType, technician *Technician, ...) (workhandler.WorkHandler, error)
• type Technician
  • func NewTechnician(address string, port int, domainAddress string, domainPort int, ...) (*Technician, error)
  • func (technician *Technician) ReceiveEvent(event []byte)
  • func (technician *Technician) StopTechnician() error
  • func (technician *Technician) Subscribe(requestedService string) error
  • func (technician *Technician) Unsubscribe(requestedService string) error
• type WorkDTO

Functions

func NewEventHandlingSystem

func NewEventHandlingSystem(eventHandlingSystemType eventhandling.EventHandlingSystemType, workHandlerType workhandler.WorkHandlerType, technician *Technician, certificateInfo orchestratormodels.CertificateInfo) (eventhandling.EventHandlingSystem, error)

func NewWorkHandler

func NewWorkHandler(workHandlerType workhandler.WorkHandlerType, technician *Technician, certificateInfo orchestratormodels.CertificateInfo) (workhandler.WorkHandler, error)

Types

type Technician

type Technician struct {
	eventhandling.EventHandlingSystem
	models.SystemDefinition
	ServiceRegistryConnection serviceregistry.ServiceRegistryConnection
	OrchestrationConnection   orchestrator.OrchestratorConnection

	SystemAddress string
	SystemPort    int
	// contains filtered or unexported fields
}

func NewTechnician

func NewTechnician(address string, port int, domainAddress string, domainPort int, systemName string, serviceRegistryAddress string, serviceRegistryPort int, eventHandlingSystemType eventhandling.EventHandlingSystemType, workHandlerType workhandler.WorkHandlerType, output io.Writer) (*Technician, error)

func (*Technician) ReceiveEvent

func (technician *Technician) ReceiveEvent(event []byte)

func (*Technician) StopTechnician

func (technician *Technician) StopTechnician() error

func (*Technician) Subscribe

func (technician *Technician) Subscribe(requestedService string) error

func (*Technician) Unsubscribe

func (technician *Technician) Unsubscribe(requestedService string) error

type WorkDTO

type WorkDTO struct {
	WorkId string `json:"workId"`

	ProductId string `json:"productId"`
	EventType string `json:"eventType"`
}