storage_service

type ArtifactType ¶

type ArtifactType int32

const (
	ArtifactType_ARTIFACT_TYPE_UNSPECIFIED ArtifactType = 0 // Unspecified artifact type
	ArtifactType_ARTIFACT_TYPE_BINARY      ArtifactType = 1 // Workflow binary artifact
	ArtifactType_ARTIFACT_TYPE_CONFIG      ArtifactType = 2 // Workflow configuration artifact
)

func (ArtifactType) Descriptor() protoreflect.EnumDescriptor

func (x ArtifactType) Enum() *ArtifactType

func (ArtifactType) EnumDescriptor() ([]byte, []int)

func (x ArtifactType) Number() protoreflect.EnumNumber

func (x ArtifactType) String() string

func (ArtifactType) Type() protoreflect.EnumType

type DownloadArtifactRequest ¶

type DownloadArtifactRequest struct {
	Id          string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                                 // ID of the artifact to download
	Type        ArtifactType    `protobuf:"varint,2,opt,name=type,proto3,enum=node.v1.ArtifactType" json:"type,omitempty"`                  // Type of the artifact to download
	Environment EnvironmentName `protobuf:"varint,3,opt,name=environment,proto3,enum=node.v1.EnvironmentName" json:"environment,omitempty"` // Environment of the artifact to download
	// contains filtered or unexported fields
}

func (*DownloadArtifactRequest) Descriptor() ([]byte, []int)

func (x *DownloadArtifactRequest) GetEnvironment() EnvironmentName

func (x *DownloadArtifactRequest) GetId() string

func (x *DownloadArtifactRequest) GetType() ArtifactType

func (*DownloadArtifactRequest) ProtoMessage()

func (x *DownloadArtifactRequest) ProtoReflect() protoreflect.Message

func (x *DownloadArtifactRequest) Reset()

func (x *DownloadArtifactRequest) String() string

type DownloadArtifactResponse ¶ added in v0.2.0

type DownloadArtifactResponse struct {
	Url    string                 `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`       // The presigned GET URL for downloading
	Expiry *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expiry,proto3" json:"expiry,omitempty"` // Expiration time of the presigned URL
	// contains filtered or unexported fields
}

func (*DownloadArtifactResponse) Descriptor() ([]byte, []int)

func (x *DownloadArtifactResponse) GetExpiry() *timestamppb.Timestamp

func (x *DownloadArtifactResponse) GetUrl() string

func (*DownloadArtifactResponse) ProtoMessage()

func (x *DownloadArtifactResponse) ProtoReflect() protoreflect.Message

func (x *DownloadArtifactResponse) Reset()

func (x *DownloadArtifactResponse) String() string

type EnvironmentName ¶

type EnvironmentName int32

environment indicates which Workflow Registry to use

const (
	EnvironmentName_ENVIRONMENT_NAME_UNSPECIFIED EnvironmentName = 0 // Unspecified environment
	EnvironmentName_PRODUCTION_MAINNET           EnvironmentName = 1
	EnvironmentName_PRODUCTION_TESTNET           EnvironmentName = 2
)

func (EnvironmentName) Descriptor() protoreflect.EnumDescriptor

func (x EnvironmentName) Enum() *EnvironmentName

func (EnvironmentName) EnumDescriptor() ([]byte, []int)

func (x EnvironmentName) Number() protoreflect.EnumNumber

func (x EnvironmentName) String() string

func (EnvironmentName) Type() protoreflect.EnumType

type NodeServiceClient ¶

type NodeServiceClient interface {
	// DownloadArtifact streams a file from the storage service in chunks.
	DownloadArtifact(ctx context.Context, in *DownloadArtifactRequest, opts ...grpc.CallOption) (*DownloadArtifactResponse, error)
}

NodeServiceClient is the client API for NodeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

NodeService defines the download-related storage service interface that is used by nodes. Workflow nodes will directly connect via gRPC to the storage service to retrieve presigned URLs which can be used to download workflow artifacts.

func NewNodeServiceClient(cc grpc.ClientConnInterface) NodeServiceClient

type NodeServiceServer ¶

type NodeServiceServer interface {
	// DownloadArtifact streams a file from the storage service in chunks.
	DownloadArtifact(context.Context, *DownloadArtifactRequest) (*DownloadArtifactResponse, error)
	// contains filtered or unexported methods
}

NodeServiceServer is the server API for NodeService service. All implementations must embed UnimplementedNodeServiceServer for forward compatibility.

NodeService defines the download-related storage service interface that is used by nodes. Workflow nodes will directly connect via gRPC to the storage service to retrieve presigned URLs which can be used to download workflow artifacts.

type UnimplementedNodeServiceServer ¶

type UnimplementedNodeServiceServer struct{}

UnimplementedNodeServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedNodeServiceServer) DownloadArtifact(context.Context, *DownloadArtifactRequest) (*DownloadArtifactResponse, error)

type UnsafeNodeServiceServer ¶

type UnsafeNodeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeNodeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeServiceServer will result in compilation errors.