Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkflowClient ¶
type WorkflowClient interface {
// DownloadArtifact downloads an artifact from the storage service
DownloadArtifact(ctx context.Context, req *pb.DownloadArtifactRequest) (pb.NodeService_DownloadArtifactClient, error)
// DownloadArtifactStream streams artifact chunks to a callback as they are received
DownloadArtifactStream(ctx context.Context, req *pb.DownloadArtifactRequest, onChunk func(*pb.DownloadArtifactChunk) error) error
// Close closes the gRPC connection
Close() error
}
WorkflowClient is a gRPC client for the node service to be used by workflow node.
func NewWorkflowClient ¶
func NewWorkflowClient(lggr logger.Logger, address string, opts ...WorkflowClientOpt) (WorkflowClient, error)
NewWorkflowClient creates a new WorkflowClient with the specified address and options It returns a WorkflowClient which can DownloadArtifacts
type WorkflowClientOpt ¶
type WorkflowClientOpt func(*workflowConfig)
WorkflowClientOpt is a functional option type for configuring the WorkflowClient
func WithJWTGenerator ¶
func WithJWTGenerator(jwtGenerator nodeauth.JWTGenerator) WorkflowClientOpt
WithJWTGenerator sets the JWT generator for authentication.
func WithServerName ¶
func WithServerName(name string) WorkflowClientOpt
WithServerName allows overriding the expected server name in the TLS certificate.
func WithWorkflowTLSCert ¶
func WithWorkflowTLSCert(cert string) WorkflowClientOpt
func WithWorkflowTransportCredentials ¶
func WithWorkflowTransportCredentials(creds credentials.TransportCredentials) WorkflowClientOpt
Source Files
Click to show internal directories.
Click to hide internal directories.