pipeline

package
v0.41.6 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const ServiceName = "pipeline"

ServiceName is the name of the service as defined in the design. This is the same value that is set in the endpoint request contexts under the ServiceKey key.

Variables

View Source 
var MethodNames = [3]string{"list", "show", "processing"}

MethodNames lists the service method names as defined in the design. These are the same values that are set in the endpoint request contexts under the MethodKey key.

Functions

func NewListEndpoint 

func NewListEndpoint(s Service) goa.Endpoint

NewListEndpoint returns an endpoint function that calls the method "list" of service "pipeline".

func NewProcessingEndpoint added in v0.34.0 

func NewProcessingEndpoint(s Service) goa.Endpoint

NewProcessingEndpoint returns an endpoint function that calls the method "processing" of service "pipeline".

func NewShowEndpoint 

func NewShowEndpoint(s Service) goa.Endpoint

NewShowEndpoint returns an endpoint function that calls the method "show" of service "pipeline".

func NewViewedEnduroStoredPipeline 

func NewViewedEnduroStoredPipeline(res *EnduroStoredPipeline, view string) *pipelineviews.EnduroStoredPipeline

NewViewedEnduroStoredPipeline initializes viewed result type EnduroStoredPipeline from result type EnduroStoredPipeline using the given view.

Types

type Client 

type Client struct {
	ListEndpoint       goa.Endpoint
	ShowEndpoint       goa.Endpoint
	ProcessingEndpoint goa.Endpoint
}

Client is the "pipeline" service client.

func NewClient 

func NewClient(list, show, processing goa.Endpoint) *Client

NewClient initializes a "pipeline" service client given the endpoints.

func (*Client) List 

func (c *Client) List(ctx context.Context, p *ListPayload) (res []*EnduroStoredPipeline, err error)

List calls the "list" endpoint of the "pipeline" service.

func (*Client) Processing added in v0.34.0 

func (c *Client) Processing(ctx context.Context, p *ProcessingPayload) (res []string, err error)

Processing calls the "processing" endpoint of the "pipeline" service. Processing may return the following errors:

  • "not_found" (type *PipelineNotFound): Pipeline not found
  • error: internal error

func (*Client) Show 

func (c *Client) Show(ctx context.Context, p *ShowPayload) (res *EnduroStoredPipeline, err error)

Show calls the "show" endpoint of the "pipeline" service. Show may return the following errors:

  • "not_found" (type *PipelineNotFound): Pipeline not found
  • error: internal error

type Endpoints 

type Endpoints struct {
	List       goa.Endpoint
	Show       goa.Endpoint
	Processing goa.Endpoint
}

Endpoints wraps the "pipeline" service endpoints.

func NewEndpoints 

func NewEndpoints(s Service) *Endpoints

NewEndpoints wraps the methods of the "pipeline" service with endpoints.

func (*Endpoints) Use 

func (e *Endpoints) Use(m func(goa.Endpoint) goa.Endpoint)

Use applies the given middleware to all the "pipeline" service endpoints.

type EnduroStoredPipeline 

type EnduroStoredPipeline struct {
	// Identifier of pipeline
	ID *string
	// Name of the pipeline
	Name string
	// Maximum concurrent transfers
	Capacity *int64
	// Current transfers
	Current *int64
	Status  *string
}

EnduroStoredPipeline is the result type of the pipeline service show method.

func NewEnduroStoredPipeline 

func NewEnduroStoredPipeline(vres *pipelineviews.EnduroStoredPipeline) *EnduroStoredPipeline

NewEnduroStoredPipeline initializes result type EnduroStoredPipeline from viewed result type EnduroStoredPipeline.

type ListPayload 

type ListPayload struct {
	Name   *string
	Status bool
}

ListPayload is the payload type of the pipeline service list method.

type PipelineNotFound added in v0.34.0 

type PipelineNotFound struct {
	// Message of error
	Message string
	// Identifier of missing pipeline
	ID string
}

Pipeline not found.

func (*PipelineNotFound) Error added in v0.34.0 

func (e *PipelineNotFound) Error() string

Error returns an error description.

func (*PipelineNotFound) ErrorName deprecated added in v0.34.0 

func (e *PipelineNotFound) ErrorName() string

ErrorName returns "PipelineNotFound".

Deprecated: Use GoaErrorName - https://github.com/goadesign/goa/issues/3105

func (*PipelineNotFound) GoaErrorName added in v0.37.0 

func (e *PipelineNotFound) GoaErrorName() string

GoaErrorName returns "PipelineNotFound".

type ProcessingPayload added in v0.34.0 

type ProcessingPayload struct {
	// Identifier of pipeline
	ID string
}

ProcessingPayload is the payload type of the pipeline service processing method.

type Service 

type Service interface {
	// List all known pipelines
	List(context.Context, *ListPayload) (res []*EnduroStoredPipeline, err error)
	// Show pipeline by ID
	Show(context.Context, *ShowPayload) (res *EnduroStoredPipeline, err error)
	// List all processing configurations of a pipeline given its ID
	Processing(context.Context, *ProcessingPayload) (res []string, err error)
}

The pipeline service manages Archivematica pipelines.

type ShowPayload 

type ShowPayload struct {
	// Identifier of pipeline to show
	ID string
}

ShowPayload is the payload type of the pipeline service show method.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.