v2

Documentation

Index

• func DefaultAcknowledge(a *nbmpv2.Acknowledge) error
• func DefaultAssertion(a *nbmpv2.Assertion) error
• func DefaultCapabilities(c *nbmpv2.Capabilities) error
• func DefaultClientAssistant(ca *nbmpv2.ClientAssistant) error
• func DefaultConnectionMapping(cm *nbmpv2.ConnectionMapping) error
• func DefaultConnectionMappingPort(p *nbmpv2.ConnectionMappingPort) error
• func DefaultFailover(fo *nbmpv2.Failover) error
• func DefaultFlowcontrolRequirement(fcr *nbmpv2.FlowcontrolRequirement) error
• func DefaultFunction(f *nbmpv2.Function) error
• func DefaultFunctionRestriction(fr *nbmpv2.FunctionRestriction) error
• func DefaultGeneral(g *nbmpv2.General) error
• func DefaultInput(i *nbmpv2.Input) error
• func DefaultMediaParameter(mp *nbmpv2.MediaParameter) error
• func DefaultMediaProcessingEntityCapabilities(mpec *nbmpv2.MediaProcessingEntityCapabilities) error
• func DefaultMetadataParameter(mp *nbmpv2.MetadataParameter) error
• func DefaultNotification(n *nbmpv2.Notification) error
• func DefaultOutput(o *nbmpv2.Output) error
• func DefaultProcessing(p *nbmpv2.Processing) error
• func DefaultProcessingImage(pi *nbmpv2.ProcessingImage) error
• func DefaultReporting(r *nbmpv2.Reporting) error
• func DefaultRepository(r *nbmpv2.Repository) error
• func DefaultRequirement(r *nbmpv2.Requirement) error
• func DefaultScale(s *nbmpv2.Scale) error
• func DefaultSchedule(s *nbmpv2.Schedule) error
• func DefaultScheduleTableItem(sti *nbmpv2.ScheduleTableItem) error
• func DefaultScheme(s *nbmpv2.Scheme) error
• func DefaultSecurity(s *nbmpv2.Security) error
• func DefaultSecurityRequirement(sr *nbmpv2.SecurityRequirement) error
• func DefaultStep(s *nbmpv2.Step) error
• func DefaultTask(t *nbmpv2.Task) error
• func DefaultTaskGroupItem(tgi *nbmpv2.TaskGroupItem) error
• func DefaultTaskSplitEfficiency(tse *nbmpv2.TaskSplitEfficiency) error
• func DefaultWorkflow(w *nbmpv2.Workflow) error
• func DefaultWorkflowTaskRequirement(wtr *nbmpv2.WorkflowTaskRequirement) error
• type TaskDummyMiddleware
  • func (m *TaskDummyMiddleware) Create(ctx context.Context, w *nbmpv2.Task) error
  • func (m *TaskDummyMiddleware) Delete(ctx context.Context, w *nbmpv2.Task) error
  • func (m *TaskDummyMiddleware) Retrieve(ctx context.Context, w *nbmpv2.Task) error
  • func (m *TaskDummyMiddleware) Update(ctx context.Context, w *nbmpv2.Task) error
• type TaskService
  • func TaskDefaulterSpecMiddleware(next TaskService) TaskService
  • func TaskValidatorSpecLaxMiddleware(next TaskService) TaskService
• type TaskServiceMiddleware
• type WorkflowDummyMiddleware
  • func (m *WorkflowDummyMiddleware) Create(ctx context.Context, w *nbmpv2.Workflow) error
  • func (m *WorkflowDummyMiddleware) Delete(ctx context.Context, w *nbmpv2.Workflow) error
  • func (m *WorkflowDummyMiddleware) Retrieve(ctx context.Context, w *nbmpv2.Workflow) error
  • func (m *WorkflowDummyMiddleware) Update(ctx context.Context, w *nbmpv2.Workflow) error
• type WorkflowService
  • func WorkflowDefaulterSpecMiddleware(next WorkflowService) WorkflowService
  • func WorkflowValidatorSpecLaxMiddleware(next WorkflowService) WorkflowService
• type WorkflowServiceMiddleware

Functions

func DefaultAcknowledge

func DefaultAcknowledge(a *nbmpv2.Acknowledge) error

func DefaultAssertion

func DefaultAssertion(a *nbmpv2.Assertion) error

func DefaultCapabilities

func DefaultCapabilities(c *nbmpv2.Capabilities) error

func DefaultClientAssistant

func DefaultClientAssistant(ca *nbmpv2.ClientAssistant) error

func DefaultConnectionMapping

func DefaultConnectionMapping(cm *nbmpv2.ConnectionMapping) error

func DefaultConnectionMappingPort

func DefaultConnectionMappingPort(p *nbmpv2.ConnectionMappingPort) error

func DefaultFailover

func DefaultFailover(fo *nbmpv2.Failover) error

func DefaultFlowcontrolRequirement

func DefaultFlowcontrolRequirement(fcr *nbmpv2.FlowcontrolRequirement) error

func DefaultFunction

func DefaultFunction(f *nbmpv2.Function) error

func DefaultFunctionRestriction

func DefaultFunctionRestriction(fr *nbmpv2.FunctionRestriction) error

func DefaultGeneral

func DefaultGeneral(g *nbmpv2.General) error

func DefaultInput

func DefaultInput(i *nbmpv2.Input) error

func DefaultMediaParameter

func DefaultMediaParameter(mp *nbmpv2.MediaParameter) error

func DefaultMediaProcessingEntityCapabilities

func DefaultMediaProcessingEntityCapabilities(mpec *nbmpv2.MediaProcessingEntityCapabilities) error

func DefaultMetadataParameter

func DefaultMetadataParameter(mp *nbmpv2.MetadataParameter) error

func DefaultNotification

func DefaultNotification(n *nbmpv2.Notification) error

func DefaultOutput

func DefaultOutput(o *nbmpv2.Output) error

func DefaultProcessing

func DefaultProcessing(p *nbmpv2.Processing) error

func DefaultProcessingImage

func DefaultProcessingImage(pi *nbmpv2.ProcessingImage) error

func DefaultReporting

func DefaultReporting(r *nbmpv2.Reporting) error

func DefaultRepository

func DefaultRepository(r *nbmpv2.Repository) error

func DefaultRequirement

func DefaultRequirement(r *nbmpv2.Requirement) error

func DefaultScale

func DefaultScale(s *nbmpv2.Scale) error

func DefaultSchedule

func DefaultSchedule(s *nbmpv2.Schedule) error

func DefaultScheduleTableItem

func DefaultScheduleTableItem(sti *nbmpv2.ScheduleTableItem) error

func DefaultScheme

func DefaultScheme(s *nbmpv2.Scheme) error

func DefaultSecurity

func DefaultSecurity(s *nbmpv2.Security) error

func DefaultSecurityRequirement

func DefaultSecurityRequirement(sr *nbmpv2.SecurityRequirement) error

func DefaultStep

func DefaultStep(s *nbmpv2.Step) error

func DefaultTask

func DefaultTask(t *nbmpv2.Task) error

func DefaultTaskGroupItem

func DefaultTaskGroupItem(tgi *nbmpv2.TaskGroupItem) error

func DefaultTaskSplitEfficiency

func DefaultTaskSplitEfficiency(tse *nbmpv2.TaskSplitEfficiency) error

func DefaultWorkflow

func DefaultWorkflow(w *nbmpv2.Workflow) error

func DefaultWorkflowTaskRequirement

func DefaultWorkflowTaskRequirement(wtr *nbmpv2.WorkflowTaskRequirement) error

Types

type TaskDummyMiddleware

type TaskDummyMiddleware struct {
	Next TaskService
}

func (*TaskDummyMiddleware) Create

func (m *TaskDummyMiddleware) Create(ctx context.Context, w *nbmpv2.Task) error

func (*TaskDummyMiddleware) Delete

func (m *TaskDummyMiddleware) Delete(ctx context.Context, w *nbmpv2.Task) error

func (*TaskDummyMiddleware) Retrieve

func (m *TaskDummyMiddleware) Retrieve(ctx context.Context, w *nbmpv2.Task) error

func (*TaskDummyMiddleware) Update

func (m *TaskDummyMiddleware) Update(ctx context.Context, w *nbmpv2.Task) error

type TaskService

type TaskService interface {
	Create(context.Context, *nbmpv2.Task) error
	Update(context.Context, *nbmpv2.Task) error
	Delete(context.Context, *nbmpv2.Task) error
	Retrieve(context.Context, *nbmpv2.Task) error
}

TaskService handles NBMP Task API requests.

func TaskDefaulterSpecMiddleware

func TaskDefaulterSpecMiddleware(next TaskService) TaskService

TaskDefaulterSpecMiddleware sets default values for given task.

func TaskValidatorSpecLaxMiddleware

func TaskValidatorSpecLaxMiddleware(next TaskService) TaskService

TaskValidatorSpecLaxMiddleware validates given task according the NBMP specification allowing for some deviation.

type TaskServiceMiddleware

type TaskServiceMiddleware func(next TaskService) TaskService

TaskServiceMiddleware is a function that implements a TaskService middleware.

type WorkflowDummyMiddleware

type WorkflowDummyMiddleware struct {
	Next WorkflowService
}

func (*WorkflowDummyMiddleware) Create

func (m *WorkflowDummyMiddleware) Create(ctx context.Context, w *nbmpv2.Workflow) error

func (*WorkflowDummyMiddleware) Delete

func (m *WorkflowDummyMiddleware) Delete(ctx context.Context, w *nbmpv2.Workflow) error

func (*WorkflowDummyMiddleware) Retrieve

func (m *WorkflowDummyMiddleware) Retrieve(ctx context.Context, w *nbmpv2.Workflow) error

func (*WorkflowDummyMiddleware) Update

func (m *WorkflowDummyMiddleware) Update(ctx context.Context, w *nbmpv2.Workflow) error

type WorkflowService

type WorkflowService interface {
	Create(context.Context, *nbmpv2.Workflow) error
	Update(context.Context, *nbmpv2.Workflow) error
	Delete(context.Context, *nbmpv2.Workflow) error
	Retrieve(context.Context, *nbmpv2.Workflow) error
}

WorkflowService handles NBMP Workflow API requests.

func WorkflowDefaulterSpecMiddleware

func WorkflowDefaulterSpecMiddleware(next WorkflowService) WorkflowService

WorkflowDefaulterSpecMiddleware sets default values for given workflow.

func WorkflowValidatorSpecLaxMiddleware

func WorkflowValidatorSpecLaxMiddleware(next WorkflowService) WorkflowService

WorkflowValidatorSpecLaxMiddleware validates given workflow according the NBMP specification allowing for some deviation.

type WorkflowServiceMiddleware

type WorkflowServiceMiddleware func(next WorkflowService) WorkflowService

WorkflowServiceMiddleware is a function that implements a WorkflowService middleware.