ingestion

package
v0.0.0-...-b9360c4 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2023 License: BSD-3-Clause Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const ServiceName = "ingestion"

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 = [7]string{"process pending", "walk everything", "process station", "process station ingestions", "process ingestion", "refresh views", "delete"}

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 MakeBadRequest 

func MakeBadRequest(err error) *goa.ServiceError

MakeBadRequest builds a goa.ServiceError from an error.

func MakeForbidden 

func MakeForbidden(err error) *goa.ServiceError

MakeForbidden builds a goa.ServiceError from an error.

func MakeNotFound 

func MakeNotFound(err error) *goa.ServiceError

MakeNotFound builds a goa.ServiceError from an error.

func MakeUnauthorized 

func MakeUnauthorized(err error) *goa.ServiceError

MakeUnauthorized builds a goa.ServiceError from an error.

func NewDeleteEndpoint 

func NewDeleteEndpoint(s Service, authJWTFn security.AuthJWTFunc) goa.Endpoint

NewDeleteEndpoint returns an endpoint function that calls the method "delete" of service "ingestion".

func NewProcessIngestionEndpoint 

func NewProcessIngestionEndpoint(s Service, authJWTFn security.AuthJWTFunc) goa.Endpoint

NewProcessIngestionEndpoint returns an endpoint function that calls the method "process ingestion" of service "ingestion".

func NewProcessPendingEndpoint 

func NewProcessPendingEndpoint(s Service, authJWTFn security.AuthJWTFunc) goa.Endpoint

NewProcessPendingEndpoint returns an endpoint function that calls the method "process pending" of service "ingestion".

func NewProcessStationEndpoint 

func NewProcessStationEndpoint(s Service, authJWTFn security.AuthJWTFunc) goa.Endpoint

NewProcessStationEndpoint returns an endpoint function that calls the method "process station" of service "ingestion".

func NewProcessStationIngestionsEndpoint 

func NewProcessStationIngestionsEndpoint(s Service, authJWTFn security.AuthJWTFunc) goa.Endpoint

NewProcessStationIngestionsEndpoint returns an endpoint function that calls the method "process station ingestions" of service "ingestion".

func NewRefreshViewsEndpoint 

func NewRefreshViewsEndpoint(s Service, authJWTFn security.AuthJWTFunc) goa.Endpoint

NewRefreshViewsEndpoint returns an endpoint function that calls the method "refresh views" of service "ingestion".

func NewWalkEverythingEndpoint 

func NewWalkEverythingEndpoint(s Service, authJWTFn security.AuthJWTFunc) goa.Endpoint

NewWalkEverythingEndpoint returns an endpoint function that calls the method "walk everything" of service "ingestion".

Types

type Auther 

type Auther interface {
	// JWTAuth implements the authorization logic for the JWT security scheme.
	JWTAuth(ctx context.Context, token string, schema *security.JWTScheme) (context.Context, error)
}

Auther defines the authorization functions to be implemented by the service.

type Client 

type Client struct {
	ProcessPendingEndpoint           goa.Endpoint
	WalkEverythingEndpoint           goa.Endpoint
	ProcessStationEndpoint           goa.Endpoint
	ProcessStationIngestionsEndpoint goa.Endpoint
	ProcessIngestionEndpoint         goa.Endpoint
	RefreshViewsEndpoint             goa.Endpoint
	DeleteEndpoint                   goa.Endpoint
}

Client is the "ingestion" service client.

func NewClient 

func NewClient(processPending, walkEverything, processStation, processStationIngestions, processIngestion, refreshViews, delete_ goa.Endpoint) *Client

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

func (*Client) Delete 

func (c *Client) Delete(ctx context.Context, p *DeletePayload) (err error)

Delete calls the "delete" endpoint of the "ingestion" service.

func (*Client) ProcessIngestion 

func (c *Client) ProcessIngestion(ctx context.Context, p *ProcessIngestionPayload) (err error)

ProcessIngestion calls the "process ingestion" endpoint of the "ingestion" service.

func (*Client) ProcessPending 

func (c *Client) ProcessPending(ctx context.Context, p *ProcessPendingPayload) (err error)

ProcessPending calls the "process pending" endpoint of the "ingestion" service.

func (*Client) ProcessStation 

func (c *Client) ProcessStation(ctx context.Context, p *ProcessStationPayload) (err error)

ProcessStation calls the "process station" endpoint of the "ingestion" service.

func (*Client) ProcessStationIngestions 

func (c *Client) ProcessStationIngestions(ctx context.Context, p *ProcessStationIngestionsPayload) (err error)

ProcessStationIngestions calls the "process station ingestions" endpoint of the "ingestion" service.

func (*Client) RefreshViews 

func (c *Client) RefreshViews(ctx context.Context, p *RefreshViewsPayload) (err error)

RefreshViews calls the "refresh views" endpoint of the "ingestion" service.

func (*Client) WalkEverything 

func (c *Client) WalkEverything(ctx context.Context, p *WalkEverythingPayload) (err error)

WalkEverything calls the "walk everything" endpoint of the "ingestion" service.

type DeletePayload 

type DeletePayload struct {
	Auth        string
	IngestionID int64
}

DeletePayload is the payload type of the ingestion service delete method.

type Endpoints 

type Endpoints struct {
	ProcessPending           goa.Endpoint
	WalkEverything           goa.Endpoint
	ProcessStation           goa.Endpoint
	ProcessStationIngestions goa.Endpoint
	ProcessIngestion         goa.Endpoint
	RefreshViews             goa.Endpoint
	Delete                   goa.Endpoint
}

Endpoints wraps the "ingestion" service endpoints.

func NewEndpoints 

func NewEndpoints(s Service) *Endpoints

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

func (*Endpoints) Use 

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

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

type ProcessIngestionPayload 

type ProcessIngestionPayload struct {
	Auth        string
	IngestionID int64
}

ProcessIngestionPayload is the payload type of the ingestion service process ingestion method.

type ProcessPendingPayload 

type ProcessPendingPayload struct {
	Auth string
}

ProcessPendingPayload is the payload type of the ingestion service process pending method.

type ProcessStationIngestionsPayload 

type ProcessStationIngestionsPayload struct {
	Auth      string
	StationID int64
}

ProcessStationIngestionsPayload is the payload type of the ingestion service process station ingestions method.

type ProcessStationPayload 

type ProcessStationPayload struct {
	Auth       string
	StationID  int32
	Completely *bool
	SkipManual *bool
}

ProcessStationPayload is the payload type of the ingestion service process station method.

type RefreshViewsPayload 

type RefreshViewsPayload struct {
	Auth string
}

RefreshViewsPayload is the payload type of the ingestion service refresh views method.

type Service 

type Service interface {
	// ProcessPending implements process pending.
	ProcessPending(context.Context, *ProcessPendingPayload) (err error)
	// WalkEverything implements walk everything.
	WalkEverything(context.Context, *WalkEverythingPayload) (err error)
	// ProcessStation implements process station.
	ProcessStation(context.Context, *ProcessStationPayload) (err error)
	// ProcessStationIngestions implements process station ingestions.
	ProcessStationIngestions(context.Context, *ProcessStationIngestionsPayload) (err error)
	// ProcessIngestion implements process ingestion.
	ProcessIngestion(context.Context, *ProcessIngestionPayload) (err error)
	// RefreshViews implements refresh views.
	RefreshViews(context.Context, *RefreshViewsPayload) (err error)
	// Delete implements delete.
	Delete(context.Context, *DeletePayload) (err error)
}

Service is the ingestion service interface.

type WalkEverythingPayload 

type WalkEverythingPayload struct {
	Auth string
}

WalkEverythingPayload is the payload type of the ingestion service walk everything method.

Source Files

View all Source files

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.