endpoints.go

// Code generated by goa v3.19.1, DO NOT EDIT.
//
// control-plane endpoints
//
// Command:
// $ goa gen github.com/pgEdge/control-plane/api/design

package controlplane

import (
	"context"

	goa "goa.design/goa/v3/pkg"
)

// Endpoints wraps the "control-plane" service endpoints.
type Endpoints struct {
	InitCluster         goa.Endpoint
	JoinCluster         goa.Endpoint
	GetJoinToken        goa.Endpoint
	GetJoinOptions      goa.Endpoint
	InspectCluster      goa.Endpoint
	ListHosts           goa.Endpoint
	InspectHost         goa.Endpoint
	RemoveHost          goa.Endpoint
	ListDatabases       goa.Endpoint
	CreateDatabase      goa.Endpoint
	GetDatabase         goa.Endpoint
	UpdateDatabase      goa.Endpoint
	DeleteDatabase      goa.Endpoint
	BackupDatabaseNode  goa.Endpoint
	ListDatabaseTasks   goa.Endpoint
	InspectDatabaseTask goa.Endpoint
	GetDatabaseTaskLog  goa.Endpoint
	RestoreDatabase     goa.Endpoint
	GetVersion          goa.Endpoint
}

// NewEndpoints wraps the methods of the "control-plane" service with endpoints.
func NewEndpoints(s Service) *Endpoints {
	return &Endpoints{
		InitCluster:         NewInitClusterEndpoint(s),
		JoinCluster:         NewJoinClusterEndpoint(s),
		GetJoinToken:        NewGetJoinTokenEndpoint(s),
		GetJoinOptions:      NewGetJoinOptionsEndpoint(s),
		InspectCluster:      NewInspectClusterEndpoint(s),
		ListHosts:           NewListHostsEndpoint(s),
		InspectHost:         NewInspectHostEndpoint(s),
		RemoveHost:          NewRemoveHostEndpoint(s),
		ListDatabases:       NewListDatabasesEndpoint(s),
		CreateDatabase:      NewCreateDatabaseEndpoint(s),
		GetDatabase:         NewGetDatabaseEndpoint(s),
		UpdateDatabase:      NewUpdateDatabaseEndpoint(s),
		DeleteDatabase:      NewDeleteDatabaseEndpoint(s),
		BackupDatabaseNode:  NewBackupDatabaseNodeEndpoint(s),
		ListDatabaseTasks:   NewListDatabaseTasksEndpoint(s),
		InspectDatabaseTask: NewInspectDatabaseTaskEndpoint(s),
		GetDatabaseTaskLog:  NewGetDatabaseTaskLogEndpoint(s),
		RestoreDatabase:     NewRestoreDatabaseEndpoint(s),
		GetVersion:          NewGetVersionEndpoint(s),
	}
}

// Use applies the given middleware to all the "control-plane" service
// endpoints.
func (e *Endpoints) Use(m func(goa.Endpoint) goa.Endpoint) {
	e.InitCluster = m(e.InitCluster)
	e.JoinCluster = m(e.JoinCluster)
	e.GetJoinToken = m(e.GetJoinToken)
	e.GetJoinOptions = m(e.GetJoinOptions)
	e.InspectCluster = m(e.InspectCluster)
	e.ListHosts = m(e.ListHosts)
	e.InspectHost = m(e.InspectHost)
	e.RemoveHost = m(e.RemoveHost)
	e.ListDatabases = m(e.ListDatabases)
	e.CreateDatabase = m(e.CreateDatabase)
	e.GetDatabase = m(e.GetDatabase)
	e.UpdateDatabase = m(e.UpdateDatabase)
	e.DeleteDatabase = m(e.DeleteDatabase)
	e.BackupDatabaseNode = m(e.BackupDatabaseNode)
	e.ListDatabaseTasks = m(e.ListDatabaseTasks)
	e.InspectDatabaseTask = m(e.InspectDatabaseTask)
	e.GetDatabaseTaskLog = m(e.GetDatabaseTaskLog)
	e.RestoreDatabase = m(e.RestoreDatabase)
	e.GetVersion = m(e.GetVersion)
}

// NewInitClusterEndpoint returns an endpoint function that calls the method
// "init-cluster" of service "control-plane".
func NewInitClusterEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		return s.InitCluster(ctx)
	}
}

// NewJoinClusterEndpoint returns an endpoint function that calls the method
// "join-cluster" of service "control-plane".
func NewJoinClusterEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*ClusterJoinToken)
		return nil, s.JoinCluster(ctx, p)
	}
}

// NewGetJoinTokenEndpoint returns an endpoint function that calls the method
// "get-join-token" of service "control-plane".
func NewGetJoinTokenEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		return s.GetJoinToken(ctx)
	}
}

// NewGetJoinOptionsEndpoint returns an endpoint function that calls the method
// "get-join-options" of service "control-plane".
func NewGetJoinOptionsEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*ClusterJoinRequest)
		return s.GetJoinOptions(ctx, p)
	}
}

// NewInspectClusterEndpoint returns an endpoint function that calls the method
// "inspect-cluster" of service "control-plane".
func NewInspectClusterEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		return s.InspectCluster(ctx)
	}
}

// NewListHostsEndpoint returns an endpoint function that calls the method
// "list-hosts" of service "control-plane".
func NewListHostsEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		return s.ListHosts(ctx)
	}
}

// NewInspectHostEndpoint returns an endpoint function that calls the method
// "inspect-host" of service "control-plane".
func NewInspectHostEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*InspectHostPayload)
		return s.InspectHost(ctx, p)
	}
}

// NewRemoveHostEndpoint returns an endpoint function that calls the method
// "remove-host" of service "control-plane".
func NewRemoveHostEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*RemoveHostPayload)
		return nil, s.RemoveHost(ctx, p)
	}
}

// NewListDatabasesEndpoint returns an endpoint function that calls the method
// "list-databases" of service "control-plane".
func NewListDatabasesEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		res, err := s.ListDatabases(ctx)
		if err != nil {
			return nil, err
		}
		vres := NewViewedDatabaseCollection(res, "abbreviated")
		return vres, nil
	}
}

// NewCreateDatabaseEndpoint returns an endpoint function that calls the method
// "create-database" of service "control-plane".
func NewCreateDatabaseEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*CreateDatabaseRequest)
		return s.CreateDatabase(ctx, p)
	}
}

// NewGetDatabaseEndpoint returns an endpoint function that calls the method
// "get-database" of service "control-plane".
func NewGetDatabaseEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*GetDatabasePayload)
		res, err := s.GetDatabase(ctx, p)
		if err != nil {
			return nil, err
		}
		vres := NewViewedDatabase(res, "default")
		return vres, nil
	}
}

// NewUpdateDatabaseEndpoint returns an endpoint function that calls the method
// "update-database" of service "control-plane".
func NewUpdateDatabaseEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*UpdateDatabasePayload)
		return s.UpdateDatabase(ctx, p)
	}
}

// NewDeleteDatabaseEndpoint returns an endpoint function that calls the method
// "delete-database" of service "control-plane".
func NewDeleteDatabaseEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*DeleteDatabasePayload)
		return s.DeleteDatabase(ctx, p)
	}
}

// NewBackupDatabaseNodeEndpoint returns an endpoint function that calls the
// method "backup-database-node" of service "control-plane".
func NewBackupDatabaseNodeEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*BackupDatabaseNodePayload)
		return s.BackupDatabaseNode(ctx, p)
	}
}

// NewListDatabaseTasksEndpoint returns an endpoint function that calls the
// method "list-database-tasks" of service "control-plane".
func NewListDatabaseTasksEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*ListDatabaseTasksPayload)
		return s.ListDatabaseTasks(ctx, p)
	}
}

// NewInspectDatabaseTaskEndpoint returns an endpoint function that calls the
// method "inspect-database-task" of service "control-plane".
func NewInspectDatabaseTaskEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*InspectDatabaseTaskPayload)
		return s.InspectDatabaseTask(ctx, p)
	}
}

// NewGetDatabaseTaskLogEndpoint returns an endpoint function that calls the
// method "get-database-task-log" of service "control-plane".
func NewGetDatabaseTaskLogEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*GetDatabaseTaskLogPayload)
		return s.GetDatabaseTaskLog(ctx, p)
	}
}

// NewRestoreDatabaseEndpoint returns an endpoint function that calls the
// method "restore-database" of service "control-plane".
func NewRestoreDatabaseEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		p := req.(*RestoreDatabasePayload)
		return s.RestoreDatabase(ctx, p)
	}
}

// NewGetVersionEndpoint returns an endpoint function that calls the method
// "get-version" of service "control-plane".
func NewGetVersionEndpoint(s Service) goa.Endpoint {
	return func(ctx context.Context, req any) (any, error) {
		return s.GetVersion(ctx)
	}
}