ingestion

package
v0.0.0-...-d2cf98a Latest Latest
Warning

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

Go to latest
Published: Oct 22, 2024 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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL