server

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2022 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DBServer 

type DBServer struct {
	// contains filtered or unexported fields
}

DBServer is a gRPC Server for database-backed Tinkerbell.

func NewDBServer 

func NewDBServer(l log.Logger, database db.Database, opts ...DBServerOption) (*DBServer, error)

NewServer returns a new Tinkerbell server.

func (*DBServer) All 

func (s *DBServer) All(_ *hardware.Empty, stream hardware.HardwareService_AllServer) error

ALL implements hardware.All.

func (*DBServer) ByID 

func (s *DBServer) ByID(ctx context.Context, in *hardware.GetRequest) (*hardware.Hardware, error)

ByID implements hardware.ByID.

func (*DBServer) ByIP 

func (s *DBServer) ByIP(ctx context.Context, in *hardware.GetRequest) (*hardware.Hardware, error)

func (*DBServer) ByMAC 

func (s *DBServer) ByMAC(ctx context.Context, in *hardware.GetRequest) (*hardware.Hardware, error)

func (*DBServer) CreateTemplate 

func (s *DBServer) CreateTemplate(ctx context.Context, in *template.WorkflowTemplate) (*template.CreateResponse, error)

CreateTemplate implements template.CreateTemplate.

func (*DBServer) CreateWorkflow 

func (s *DBServer) CreateWorkflow(ctx context.Context, in *workflow.CreateRequest) (*workflow.CreateResponse, error)

CreateWorkflow implements workflow.CreateWorkflow.

func (*DBServer) Delete 

func (s *DBServer) Delete(ctx context.Context, in *hardware.DeleteRequest) (*hardware.Empty, error)

func (*DBServer) DeleteTemplate 

func (s *DBServer) DeleteTemplate(ctx context.Context, in *template.GetRequest) (*template.Empty, error)

DeleteTemplate implements template.DeleteTemplate.

func (*DBServer) DeleteWorkflow 

func (s *DBServer) DeleteWorkflow(ctx context.Context, in *workflow.GetRequest) (*workflow.Empty, error)

DeleteWorkflow implements workflow.DeleteWorkflow.

func (*DBServer) DeprecatedWatch 

func (s *DBServer) DeprecatedWatch(in *hardware.GetRequest, stream hardware.HardwareService_DeprecatedWatchServer) error

func (*DBServer) GetTemplate 

func (s *DBServer) GetTemplate(ctx context.Context, in *template.GetRequest) (*template.WorkflowTemplate, error)

GetTemplate implements template.GetTemplate.

func (*DBServer) GetWorkflow 

func (s *DBServer) GetWorkflow(ctx context.Context, in *workflow.GetRequest) (*workflow.Workflow, error)

GetWorkflow implements workflow.GetWorkflow.

func (*DBServer) GetWorkflowActions 

func (s *DBServer) GetWorkflowActions(ctx context.Context, req *workflow.WorkflowActionsRequest) (*workflow.WorkflowActionList, error)

GetWorkflowActions implements tinkerbell.GetWorkflowActions.

func (*DBServer) GetWorkflowContext 

func (s *DBServer) GetWorkflowContext(ctx context.Context, in *workflow.GetRequest) (*workflow.WorkflowContext, error)

func (*DBServer) GetWorkflowContextList 

func (s *DBServer) GetWorkflowContextList(ctx context.Context, req *workflow.WorkflowContextRequest) (*workflow.WorkflowContextList, error)

GetWorkflowContextList implements tinkerbell.GetWorkflowContextList.

func (*DBServer) GetWorkflowContexts 

func (s *DBServer) GetWorkflowContexts(req *workflow.WorkflowContextRequest, stream workflow.WorkflowService_GetWorkflowContextsServer) error

GetWorkflowContexts implements tinkerbell.GetWorkflowContexts.

func (*DBServer) GetWorkflowData 

func (s *DBServer) GetWorkflowData(ctx context.Context, req *workflow.GetWorkflowDataRequest) (*workflow.GetWorkflowDataResponse, error)

GetWorkflowData gets the ephemeral data for a workflow.

func (*DBServer) GetWorkflowDataVersion 

func (s *DBServer) GetWorkflowDataVersion(ctx context.Context, req *workflow.GetWorkflowDataRequest) (*workflow.GetWorkflowDataResponse, error)

GetWorkflowDataVersion returns the latest version of data for a workflow.

func (*DBServer) GetWorkflowMetadata 

func (s *DBServer) GetWorkflowMetadata(ctx context.Context, req *workflow.GetWorkflowDataRequest) (*workflow.GetWorkflowDataResponse, error)

GetWorkflowMetadata returns metadata wrt to the ephemeral data of a workflow.

func (*DBServer) ListTemplates 

func (s *DBServer) ListTemplates(in *template.ListRequest, stream template.TemplateService_ListTemplatesServer) error

ListTemplates implements template.ListTemplates.

func (*DBServer) ListWorkflows 

func (s *DBServer) ListWorkflows(_ *workflow.Empty, stream workflow.WorkflowService_ListWorkflowsServer) error

ListWorkflows implements workflow.ListWorkflows.

func (*DBServer) Push 

func (s *DBServer) Push(ctx context.Context, in *hardware.PushRequest) (*hardware.Empty, error)

func (*DBServer) Register 

func (s *DBServer) Register(gserver *grpc.Server)

Register registers Template, Workflow, and Hardware APIs on a gRPC server.

func (*DBServer) ReportActionStatus 

func (s *DBServer) ReportActionStatus(ctx context.Context, req *workflow.WorkflowActionStatus) (*workflow.Empty, error)

ReportActionStatus implements tinkerbell.ReportActionStatus.

func (*DBServer) ShowWorkflowEvents 

func (s *DBServer) ShowWorkflowEvents(req *workflow.GetRequest, stream workflow.WorkflowService_ShowWorkflowEventsServer) error

ShowWorflowevents implements workflow.ShowWorflowEvents.

func (*DBServer) UpdateTemplate 

func (s *DBServer) UpdateTemplate(ctx context.Context, in *template.WorkflowTemplate) (*template.Empty, error)

UpdateTemplate implements template.UpdateTemplate.

func (*DBServer) UpdateWorkflowData 

func (s *DBServer) UpdateWorkflowData(ctx context.Context, req *workflow.UpdateWorkflowDataRequest) (*workflow.Empty, error)

UpdateWorkflowData updates workflow ephemeral data.

type DBServerOption 

type DBServerOption func(*DBServer) error

DBServerOption is a type for modifying a DBServer.

type KubernetesBackedServer 

type KubernetesBackedServer struct {
	ClientFunc func() client.Client
	// contains filtered or unexported fields
}

KubernetesBackedServer is a server that implements a workflow API.

func NewKubeBackedServer 

func NewKubeBackedServer(logger log.Logger, kubeconfig, apiserver, namespace string) (*KubernetesBackedServer, error)

NewKubeBackedServer returns a server that implements the Workflow server interface for a given kubeconfig.

func NewKubeBackedServerFromREST 

func NewKubeBackedServerFromREST(logger log.Logger, config *rest.Config, namespace string) *KubernetesBackedServer

NewKubeBackedServerFromREST returns a server that implements the Workflow server interface with the given Kubernetes rest client and namespace.

func (*KubernetesBackedServer) CreateWorkflow 

func (s *KubernetesBackedServer) CreateWorkflow(context.Context, *pb.CreateRequest) (*pb.CreateResponse, error)

CreateWorkflow will return a not implemented error.

func (*KubernetesBackedServer) DeleteWorkflow 

func (s *KubernetesBackedServer) DeleteWorkflow(context.Context, *pb.GetRequest) (*pb.Empty, error)

DeleteWorkflow will return a not implemented error.

func (*KubernetesBackedServer) GetWorkflow 

func (s *KubernetesBackedServer) GetWorkflow(context.Context, *pb.GetRequest) (*pb.Workflow, error)

GetWorkflow will return a not implemented error.

func (*KubernetesBackedServer) GetWorkflowActions 

func (s *KubernetesBackedServer) GetWorkflowActions(ctx context.Context, req *pb.WorkflowActionsRequest) (*pb.WorkflowActionList, error)

func (*KubernetesBackedServer) GetWorkflowContext 

func (s *KubernetesBackedServer) GetWorkflowContext(context.Context, *pb.GetRequest) (*pb.WorkflowContext, error)

GetWorkflowContext will return a not implemented error.

func (*KubernetesBackedServer) GetWorkflowContextList 

func (s *KubernetesBackedServer) GetWorkflowContextList(context.Context, *pb.WorkflowContextRequest) (*pb.WorkflowContextList, error)

GetWorkflowContextList will return a not implemented error.

func (*KubernetesBackedServer) GetWorkflowContexts 

func (s *KubernetesBackedServer) GetWorkflowContexts(req *pb.WorkflowContextRequest, stream pb.WorkflowService_GetWorkflowContextsServer) error

func (*KubernetesBackedServer) GetWorkflowData 

func (s *KubernetesBackedServer) GetWorkflowData(_ context.Context, _ *pb.GetWorkflowDataRequest) (*pb.GetWorkflowDataResponse, error)

GetWorkflowData is deprecated, responding with empty values until it is removed.

func (*KubernetesBackedServer) GetWorkflowDataVersion 

func (s *KubernetesBackedServer) GetWorkflowDataVersion(context.Context, *pb.GetWorkflowDataRequest) (*pb.GetWorkflowDataResponse, error)

GetWorkflowDataVersion will return a not implemented error.

func (*KubernetesBackedServer) GetWorkflowMetadata 

func (s *KubernetesBackedServer) GetWorkflowMetadata(context.Context, *pb.GetWorkflowDataRequest) (*pb.GetWorkflowDataResponse, error)

GetWorkflowMetadata will return a not implemented error.

func (*KubernetesBackedServer) ListWorkflows 

func (s *KubernetesBackedServer) ListWorkflows(*pb.Empty, pb.WorkflowService_ListWorkflowsServer) error

ListWOrkflows will return a not implemented error.

func (*KubernetesBackedServer) Register 

func (s *KubernetesBackedServer) Register(server *grpc.Server)

Register registers the service on the gRPC server.

func (*KubernetesBackedServer) ReportActionStatus 

func (s *KubernetesBackedServer) ReportActionStatus(ctx context.Context, req *pb.WorkflowActionStatus) (*pb.Empty, error)

func (*KubernetesBackedServer) ShowWorkflowEvents 

func (s *KubernetesBackedServer) ShowWorkflowEvents(*pb.GetRequest, pb.WorkflowService_ShowWorkflowEventsServer) error

ShowWorkflowEvents will return a not implemented error.

func (*KubernetesBackedServer) UpdateWorkflowData 

func (s *KubernetesBackedServer) UpdateWorkflowData(_ context.Context, _ *pb.UpdateWorkflowDataRequest) (*pb.Empty, error)

UpdateWorkflowData is deprecated, responding with empty values until it is removed.

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.