Documentation
¶
Index ¶
- Variables
- func RegisterDataPipelineRunServiceServer(s *grpc.Server, srv DataPipelineRunServiceServer)
- type AbortDataPipelineRunRequest
- func (*AbortDataPipelineRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AbortDataPipelineRunRequest) GetName() string
- func (x *AbortDataPipelineRunRequest) GetNamespace() string
- func (*AbortDataPipelineRunRequest) ProtoMessage()
- func (x *AbortDataPipelineRunRequest) ProtoReflect() protoreflect.Message
- func (x *AbortDataPipelineRunRequest) Reset()
- func (x *AbortDataPipelineRunRequest) String() string
- type AbortDataPipelineRunResponse
- func (*AbortDataPipelineRunResponse) Descriptor() ([]byte, []int)deprecated
- func (*AbortDataPipelineRunResponse) ProtoMessage()
- func (x *AbortDataPipelineRunResponse) ProtoReflect() protoreflect.Message
- func (x *AbortDataPipelineRunResponse) Reset()
- func (x *AbortDataPipelineRunResponse) String() string
- type CreateDataPipelineRunRequest
- func (*CreateDataPipelineRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDataPipelineRunRequest) GetDatapipelinerun() *v1alpha1.DataPipelineRun
- func (*CreateDataPipelineRunRequest) ProtoMessage()
- func (x *CreateDataPipelineRunRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDataPipelineRunRequest) Reset()
- func (x *CreateDataPipelineRunRequest) String() string
- type CreateDataPipelineRunResponse
- func (*CreateDataPipelineRunResponse) Descriptor() ([]byte, []int)deprecated
- func (*CreateDataPipelineRunResponse) ProtoMessage()
- func (x *CreateDataPipelineRunResponse) ProtoReflect() protoreflect.Message
- func (x *CreateDataPipelineRunResponse) Reset()
- func (x *CreateDataPipelineRunResponse) String() string
- type DataPipelineRunServiceClient
- type DataPipelineRunServiceServer
- type DeleteDataPipelineRunRequest
- func (*DeleteDataPipelineRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDataPipelineRunRequest) GetName() string
- func (x *DeleteDataPipelineRunRequest) GetNamespace() string
- func (*DeleteDataPipelineRunRequest) ProtoMessage()
- func (x *DeleteDataPipelineRunRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDataPipelineRunRequest) Reset()
- func (x *DeleteDataPipelineRunRequest) String() string
- type DeleteDataPipelineRunResponse
- func (*DeleteDataPipelineRunResponse) Descriptor() ([]byte, []int)deprecated
- func (*DeleteDataPipelineRunResponse) ProtoMessage()
- func (x *DeleteDataPipelineRunResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteDataPipelineRunResponse) Reset()
- func (x *DeleteDataPipelineRunResponse) String() string
- type GetDataPipelineRunRequest
- func (*GetDataPipelineRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDataPipelineRunRequest) GetName() string
- func (x *GetDataPipelineRunRequest) GetNamespace() string
- func (*GetDataPipelineRunRequest) ProtoMessage()
- func (x *GetDataPipelineRunRequest) ProtoReflect() protoreflect.Message
- func (x *GetDataPipelineRunRequest) Reset()
- func (x *GetDataPipelineRunRequest) String() string
- type GetDataPipelineRunResponse
- func (*GetDataPipelineRunResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDataPipelineRunResponse) GetDatapipelinerun() *v1alpha1.DataPipelineRun
- func (x *GetDataPipelineRunResponse) GetYaml() string
- func (*GetDataPipelineRunResponse) ProtoMessage()
- func (x *GetDataPipelineRunResponse) ProtoReflect() protoreflect.Message
- func (x *GetDataPipelineRunResponse) Reset()
- func (x *GetDataPipelineRunResponse) String() string
- type ListDataPipelineRunRequest
- func (*ListDataPipelineRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDataPipelineRunRequest) GetLabels() map[string]string
- func (x *ListDataPipelineRunRequest) GetNamespace() string
- func (x *ListDataPipelineRunRequest) GetOrderBy() string
- func (x *ListDataPipelineRunRequest) GetPageSize() int32
- func (x *ListDataPipelineRunRequest) GetPageToken() string
- func (*ListDataPipelineRunRequest) ProtoMessage()
- func (x *ListDataPipelineRunRequest) ProtoReflect() protoreflect.Message
- func (x *ListDataPipelineRunRequest) Reset()
- func (x *ListDataPipelineRunRequest) String() string
- type ListDataPipelineRunResponse
- func (*ListDataPipelineRunResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDataPipelineRunResponse) GetDatapipelineruns() *v1alpha1.DataPipelineRunList
- func (x *ListDataPipelineRunResponse) GetNextPageToken() string
- func (*ListDataPipelineRunResponse) ProtoMessage()
- func (x *ListDataPipelineRunResponse) ProtoReflect() protoreflect.Message
- func (x *ListDataPipelineRunResponse) Reset()
- func (x *ListDataPipelineRunResponse) String() string
- type PauseDataPipelineRunRequest
- func (*PauseDataPipelineRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PauseDataPipelineRunRequest) GetName() string
- func (x *PauseDataPipelineRunRequest) GetNamespace() string
- func (*PauseDataPipelineRunRequest) ProtoMessage()
- func (x *PauseDataPipelineRunRequest) ProtoReflect() protoreflect.Message
- func (x *PauseDataPipelineRunRequest) Reset()
- func (x *PauseDataPipelineRunRequest) String() string
- type PauseDataPipelineRunResponse
- func (*PauseDataPipelineRunResponse) Descriptor() ([]byte, []int)deprecated
- func (*PauseDataPipelineRunResponse) ProtoMessage()
- func (x *PauseDataPipelineRunResponse) ProtoReflect() protoreflect.Message
- func (x *PauseDataPipelineRunResponse) Reset()
- func (x *PauseDataPipelineRunResponse) String() string
- type ResumeDataPipelineRunRequest
- func (*ResumeDataPipelineRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResumeDataPipelineRunRequest) GetName() string
- func (x *ResumeDataPipelineRunRequest) GetNamespace() string
- func (*ResumeDataPipelineRunRequest) ProtoMessage()
- func (x *ResumeDataPipelineRunRequest) ProtoReflect() protoreflect.Message
- func (x *ResumeDataPipelineRunRequest) Reset()
- func (x *ResumeDataPipelineRunRequest) String() string
- type ResumeDataPipelineRunResponse
- func (*ResumeDataPipelineRunResponse) Descriptor() ([]byte, []int)deprecated
- func (*ResumeDataPipelineRunResponse) ProtoMessage()
- func (x *ResumeDataPipelineRunResponse) ProtoReflect() protoreflect.Message
- func (x *ResumeDataPipelineRunResponse) Reset()
- func (x *ResumeDataPipelineRunResponse) String() string
- type UnimplementedDataPipelineRunServiceServer
- func (*UnimplementedDataPipelineRunServiceServer) AbortDataPipelineRun(context.Context, *AbortDataPipelineRunRequest) (*AbortDataPipelineRunResponse, error)
- func (*UnimplementedDataPipelineRunServiceServer) CreateDataPipelineRun(context.Context, *CreateDataPipelineRunRequest) (*CreateDataPipelineRunResponse, error)
- func (*UnimplementedDataPipelineRunServiceServer) DeleteDataPipelineRun(context.Context, *DeleteDataPipelineRunRequest) (*DeleteDataPipelineRunResponse, error)
- func (*UnimplementedDataPipelineRunServiceServer) GetDataPipelineRun(context.Context, *GetDataPipelineRunRequest) (*GetDataPipelineRunResponse, error)
- func (*UnimplementedDataPipelineRunServiceServer) ListDataPipelineRuns(context.Context, *ListDataPipelineRunRequest) (*ListDataPipelineRunResponse, error)
- func (*UnimplementedDataPipelineRunServiceServer) PauseDataPipelineRun(context.Context, *PauseDataPipelineRunRequest) (*PauseDataPipelineRunResponse, error)
- func (*UnimplementedDataPipelineRunServiceServer) ResumeDataPipelineRun(context.Context, *ResumeDataPipelineRunRequest) (*ResumeDataPipelineRunResponse, error)
- func (*UnimplementedDataPipelineRunServiceServer) UpdateDataPipelineRun(context.Context, *UpdateDataPipelineRunRequest) (*UpdateDataPipelineRunResponse, error)
- type UpdateDataPipelineRunRequest
- func (*UpdateDataPipelineRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDataPipelineRunRequest) GetDatapipelinerun() *v1alpha1.DataPipelineRun
- func (x *UpdateDataPipelineRunRequest) GetFieldMask() *field_mask.FieldMask
- func (*UpdateDataPipelineRunRequest) ProtoMessage()
- func (x *UpdateDataPipelineRunRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDataPipelineRunRequest) Reset()
- func (x *UpdateDataPipelineRunRequest) String() string
- type UpdateDataPipelineRunResponse
- func (*UpdateDataPipelineRunResponse) Descriptor() ([]byte, []int)deprecated
- func (*UpdateDataPipelineRunResponse) ProtoMessage()
- func (x *UpdateDataPipelineRunResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateDataPipelineRunResponse) Reset()
- func (x *UpdateDataPipelineRunResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var File_github_com_metaprov_modelaapi_services_datapipelinerun_v1_datapipelinerun_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDataPipelineRunServiceServer ¶
func RegisterDataPipelineRunServiceServer(s *grpc.Server, srv DataPipelineRunServiceServer)
Types ¶
type AbortDataPipelineRunRequest ¶
type AbortDataPipelineRunRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*AbortDataPipelineRunRequest) Descriptor
deprecated
func (*AbortDataPipelineRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use AbortDataPipelineRunRequest.ProtoReflect.Descriptor instead.
func (*AbortDataPipelineRunRequest) GetName ¶
func (x *AbortDataPipelineRunRequest) GetName() string
func (*AbortDataPipelineRunRequest) GetNamespace ¶
func (x *AbortDataPipelineRunRequest) GetNamespace() string
func (*AbortDataPipelineRunRequest) ProtoMessage ¶
func (*AbortDataPipelineRunRequest) ProtoMessage()
func (*AbortDataPipelineRunRequest) ProtoReflect ¶
func (x *AbortDataPipelineRunRequest) ProtoReflect() protoreflect.Message
func (*AbortDataPipelineRunRequest) Reset ¶
func (x *AbortDataPipelineRunRequest) Reset()
func (*AbortDataPipelineRunRequest) String ¶
func (x *AbortDataPipelineRunRequest) String() string
type AbortDataPipelineRunResponse ¶
type AbortDataPipelineRunResponse struct {
// contains filtered or unexported fields
}
func (*AbortDataPipelineRunResponse) Descriptor
deprecated
func (*AbortDataPipelineRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use AbortDataPipelineRunResponse.ProtoReflect.Descriptor instead.
func (*AbortDataPipelineRunResponse) ProtoMessage ¶
func (*AbortDataPipelineRunResponse) ProtoMessage()
func (*AbortDataPipelineRunResponse) ProtoReflect ¶
func (x *AbortDataPipelineRunResponse) ProtoReflect() protoreflect.Message
func (*AbortDataPipelineRunResponse) Reset ¶
func (x *AbortDataPipelineRunResponse) Reset()
func (*AbortDataPipelineRunResponse) String ¶
func (x *AbortDataPipelineRunResponse) String() string
type CreateDataPipelineRunRequest ¶
type CreateDataPipelineRunRequest struct { Datapipelinerun *v1alpha1.DataPipelineRun `protobuf:"bytes,1,opt,name=datapipelinerun,proto3" json:"datapipelinerun,omitempty"` // contains filtered or unexported fields }
func (*CreateDataPipelineRunRequest) Descriptor
deprecated
func (*CreateDataPipelineRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateDataPipelineRunRequest.ProtoReflect.Descriptor instead.
func (*CreateDataPipelineRunRequest) GetDatapipelinerun ¶ added in v0.4.480
func (x *CreateDataPipelineRunRequest) GetDatapipelinerun() *v1alpha1.DataPipelineRun
func (*CreateDataPipelineRunRequest) ProtoMessage ¶
func (*CreateDataPipelineRunRequest) ProtoMessage()
func (*CreateDataPipelineRunRequest) ProtoReflect ¶
func (x *CreateDataPipelineRunRequest) ProtoReflect() protoreflect.Message
func (*CreateDataPipelineRunRequest) Reset ¶
func (x *CreateDataPipelineRunRequest) Reset()
func (*CreateDataPipelineRunRequest) String ¶
func (x *CreateDataPipelineRunRequest) String() string
type CreateDataPipelineRunResponse ¶
type CreateDataPipelineRunResponse struct {
// contains filtered or unexported fields
}
func (*CreateDataPipelineRunResponse) Descriptor
deprecated
func (*CreateDataPipelineRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateDataPipelineRunResponse.ProtoReflect.Descriptor instead.
func (*CreateDataPipelineRunResponse) ProtoMessage ¶
func (*CreateDataPipelineRunResponse) ProtoMessage()
func (*CreateDataPipelineRunResponse) ProtoReflect ¶
func (x *CreateDataPipelineRunResponse) ProtoReflect() protoreflect.Message
func (*CreateDataPipelineRunResponse) Reset ¶
func (x *CreateDataPipelineRunResponse) Reset()
func (*CreateDataPipelineRunResponse) String ¶
func (x *CreateDataPipelineRunResponse) String() string
type DataPipelineRunServiceClient ¶
type DataPipelineRunServiceClient interface { ListDataPipelineRuns(ctx context.Context, in *ListDataPipelineRunRequest, opts ...grpc.CallOption) (*ListDataPipelineRunResponse, error) CreateDataPipelineRun(ctx context.Context, in *CreateDataPipelineRunRequest, opts ...grpc.CallOption) (*CreateDataPipelineRunResponse, error) GetDataPipelineRun(ctx context.Context, in *GetDataPipelineRunRequest, opts ...grpc.CallOption) (*GetDataPipelineRunResponse, error) UpdateDataPipelineRun(ctx context.Context, in *UpdateDataPipelineRunRequest, opts ...grpc.CallOption) (*UpdateDataPipelineRunResponse, error) DeleteDataPipelineRun(ctx context.Context, in *DeleteDataPipelineRunRequest, opts ...grpc.CallOption) (*DeleteDataPipelineRunResponse, error) AbortDataPipelineRun(ctx context.Context, in *AbortDataPipelineRunRequest, opts ...grpc.CallOption) (*AbortDataPipelineRunResponse, error) PauseDataPipelineRun(ctx context.Context, in *PauseDataPipelineRunRequest, opts ...grpc.CallOption) (*PauseDataPipelineRunResponse, error) ResumeDataPipelineRun(ctx context.Context, in *ResumeDataPipelineRunRequest, opts ...grpc.CallOption) (*ResumeDataPipelineRunResponse, error) }
DataPipelineRunServiceClient is the client API for DataPipelineRunService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDataPipelineRunServiceClient ¶
func NewDataPipelineRunServiceClient(cc grpc.ClientConnInterface) DataPipelineRunServiceClient
type DataPipelineRunServiceServer ¶
type DataPipelineRunServiceServer interface { ListDataPipelineRuns(context.Context, *ListDataPipelineRunRequest) (*ListDataPipelineRunResponse, error) CreateDataPipelineRun(context.Context, *CreateDataPipelineRunRequest) (*CreateDataPipelineRunResponse, error) GetDataPipelineRun(context.Context, *GetDataPipelineRunRequest) (*GetDataPipelineRunResponse, error) UpdateDataPipelineRun(context.Context, *UpdateDataPipelineRunRequest) (*UpdateDataPipelineRunResponse, error) DeleteDataPipelineRun(context.Context, *DeleteDataPipelineRunRequest) (*DeleteDataPipelineRunResponse, error) AbortDataPipelineRun(context.Context, *AbortDataPipelineRunRequest) (*AbortDataPipelineRunResponse, error) PauseDataPipelineRun(context.Context, *PauseDataPipelineRunRequest) (*PauseDataPipelineRunResponse, error) ResumeDataPipelineRun(context.Context, *ResumeDataPipelineRunRequest) (*ResumeDataPipelineRunResponse, error) }
DataPipelineRunServiceServer is the server API for DataPipelineRunService service.
type DeleteDataPipelineRunRequest ¶
type DeleteDataPipelineRunRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DeleteDataPipelineRunRequest) Descriptor
deprecated
func (*DeleteDataPipelineRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDataPipelineRunRequest.ProtoReflect.Descriptor instead.
func (*DeleteDataPipelineRunRequest) GetName ¶
func (x *DeleteDataPipelineRunRequest) GetName() string
func (*DeleteDataPipelineRunRequest) GetNamespace ¶
func (x *DeleteDataPipelineRunRequest) GetNamespace() string
func (*DeleteDataPipelineRunRequest) ProtoMessage ¶
func (*DeleteDataPipelineRunRequest) ProtoMessage()
func (*DeleteDataPipelineRunRequest) ProtoReflect ¶
func (x *DeleteDataPipelineRunRequest) ProtoReflect() protoreflect.Message
func (*DeleteDataPipelineRunRequest) Reset ¶
func (x *DeleteDataPipelineRunRequest) Reset()
func (*DeleteDataPipelineRunRequest) String ¶
func (x *DeleteDataPipelineRunRequest) String() string
type DeleteDataPipelineRunResponse ¶
type DeleteDataPipelineRunResponse struct {
// contains filtered or unexported fields
}
func (*DeleteDataPipelineRunResponse) Descriptor
deprecated
func (*DeleteDataPipelineRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDataPipelineRunResponse.ProtoReflect.Descriptor instead.
func (*DeleteDataPipelineRunResponse) ProtoMessage ¶
func (*DeleteDataPipelineRunResponse) ProtoMessage()
func (*DeleteDataPipelineRunResponse) ProtoReflect ¶
func (x *DeleteDataPipelineRunResponse) ProtoReflect() protoreflect.Message
func (*DeleteDataPipelineRunResponse) Reset ¶
func (x *DeleteDataPipelineRunResponse) Reset()
func (*DeleteDataPipelineRunResponse) String ¶
func (x *DeleteDataPipelineRunResponse) String() string
type GetDataPipelineRunRequest ¶
type GetDataPipelineRunRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetDataPipelineRunRequest) Descriptor
deprecated
func (*GetDataPipelineRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDataPipelineRunRequest.ProtoReflect.Descriptor instead.
func (*GetDataPipelineRunRequest) GetName ¶
func (x *GetDataPipelineRunRequest) GetName() string
func (*GetDataPipelineRunRequest) GetNamespace ¶
func (x *GetDataPipelineRunRequest) GetNamespace() string
func (*GetDataPipelineRunRequest) ProtoMessage ¶
func (*GetDataPipelineRunRequest) ProtoMessage()
func (*GetDataPipelineRunRequest) ProtoReflect ¶
func (x *GetDataPipelineRunRequest) ProtoReflect() protoreflect.Message
func (*GetDataPipelineRunRequest) Reset ¶
func (x *GetDataPipelineRunRequest) Reset()
func (*GetDataPipelineRunRequest) String ¶
func (x *GetDataPipelineRunRequest) String() string
type GetDataPipelineRunResponse ¶
type GetDataPipelineRunResponse struct { Datapipelinerun *v1alpha1.DataPipelineRun `protobuf:"bytes,1,opt,name=datapipelinerun,proto3" json:"datapipelinerun,omitempty"` Yaml string `protobuf:"bytes,2,opt,name=yaml,proto3" json:"yaml,omitempty"` // contains filtered or unexported fields }
func (*GetDataPipelineRunResponse) Descriptor
deprecated
func (*GetDataPipelineRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDataPipelineRunResponse.ProtoReflect.Descriptor instead.
func (*GetDataPipelineRunResponse) GetDatapipelinerun ¶ added in v0.4.480
func (x *GetDataPipelineRunResponse) GetDatapipelinerun() *v1alpha1.DataPipelineRun
func (*GetDataPipelineRunResponse) GetYaml ¶
func (x *GetDataPipelineRunResponse) GetYaml() string
func (*GetDataPipelineRunResponse) ProtoMessage ¶
func (*GetDataPipelineRunResponse) ProtoMessage()
func (*GetDataPipelineRunResponse) ProtoReflect ¶
func (x *GetDataPipelineRunResponse) ProtoReflect() protoreflect.Message
func (*GetDataPipelineRunResponse) Reset ¶
func (x *GetDataPipelineRunResponse) Reset()
func (*GetDataPipelineRunResponse) String ¶
func (x *GetDataPipelineRunResponse) String() string
type ListDataPipelineRunRequest ¶
type ListDataPipelineRunRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` // contains filtered or unexported fields }
func (*ListDataPipelineRunRequest) Descriptor
deprecated
func (*ListDataPipelineRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDataPipelineRunRequest.ProtoReflect.Descriptor instead.
func (*ListDataPipelineRunRequest) GetLabels ¶
func (x *ListDataPipelineRunRequest) GetLabels() map[string]string
func (*ListDataPipelineRunRequest) GetNamespace ¶
func (x *ListDataPipelineRunRequest) GetNamespace() string
func (*ListDataPipelineRunRequest) GetOrderBy ¶ added in v0.4.414
func (x *ListDataPipelineRunRequest) GetOrderBy() string
func (*ListDataPipelineRunRequest) GetPageSize ¶ added in v0.4.414
func (x *ListDataPipelineRunRequest) GetPageSize() int32
func (*ListDataPipelineRunRequest) GetPageToken ¶ added in v0.4.414
func (x *ListDataPipelineRunRequest) GetPageToken() string
func (*ListDataPipelineRunRequest) ProtoMessage ¶
func (*ListDataPipelineRunRequest) ProtoMessage()
func (*ListDataPipelineRunRequest) ProtoReflect ¶
func (x *ListDataPipelineRunRequest) ProtoReflect() protoreflect.Message
func (*ListDataPipelineRunRequest) Reset ¶
func (x *ListDataPipelineRunRequest) Reset()
func (*ListDataPipelineRunRequest) String ¶
func (x *ListDataPipelineRunRequest) String() string
type ListDataPipelineRunResponse ¶
type ListDataPipelineRunResponse struct { Datapipelineruns *v1alpha1.DataPipelineRunList `protobuf:"bytes,1,opt,name=datapipelineruns,proto3" json:"datapipelineruns,omitempty"` NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListDataPipelineRunResponse) Descriptor
deprecated
func (*ListDataPipelineRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDataPipelineRunResponse.ProtoReflect.Descriptor instead.
func (*ListDataPipelineRunResponse) GetDatapipelineruns ¶ added in v0.4.480
func (x *ListDataPipelineRunResponse) GetDatapipelineruns() *v1alpha1.DataPipelineRunList
func (*ListDataPipelineRunResponse) GetNextPageToken ¶ added in v0.4.472
func (x *ListDataPipelineRunResponse) GetNextPageToken() string
func (*ListDataPipelineRunResponse) ProtoMessage ¶
func (*ListDataPipelineRunResponse) ProtoMessage()
func (*ListDataPipelineRunResponse) ProtoReflect ¶
func (x *ListDataPipelineRunResponse) ProtoReflect() protoreflect.Message
func (*ListDataPipelineRunResponse) Reset ¶
func (x *ListDataPipelineRunResponse) Reset()
func (*ListDataPipelineRunResponse) String ¶
func (x *ListDataPipelineRunResponse) String() string
type PauseDataPipelineRunRequest ¶
type PauseDataPipelineRunRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*PauseDataPipelineRunRequest) Descriptor
deprecated
func (*PauseDataPipelineRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use PauseDataPipelineRunRequest.ProtoReflect.Descriptor instead.
func (*PauseDataPipelineRunRequest) GetName ¶
func (x *PauseDataPipelineRunRequest) GetName() string
func (*PauseDataPipelineRunRequest) GetNamespace ¶
func (x *PauseDataPipelineRunRequest) GetNamespace() string
func (*PauseDataPipelineRunRequest) ProtoMessage ¶
func (*PauseDataPipelineRunRequest) ProtoMessage()
func (*PauseDataPipelineRunRequest) ProtoReflect ¶
func (x *PauseDataPipelineRunRequest) ProtoReflect() protoreflect.Message
func (*PauseDataPipelineRunRequest) Reset ¶
func (x *PauseDataPipelineRunRequest) Reset()
func (*PauseDataPipelineRunRequest) String ¶
func (x *PauseDataPipelineRunRequest) String() string
type PauseDataPipelineRunResponse ¶
type PauseDataPipelineRunResponse struct {
// contains filtered or unexported fields
}
func (*PauseDataPipelineRunResponse) Descriptor
deprecated
func (*PauseDataPipelineRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use PauseDataPipelineRunResponse.ProtoReflect.Descriptor instead.
func (*PauseDataPipelineRunResponse) ProtoMessage ¶
func (*PauseDataPipelineRunResponse) ProtoMessage()
func (*PauseDataPipelineRunResponse) ProtoReflect ¶
func (x *PauseDataPipelineRunResponse) ProtoReflect() protoreflect.Message
func (*PauseDataPipelineRunResponse) Reset ¶
func (x *PauseDataPipelineRunResponse) Reset()
func (*PauseDataPipelineRunResponse) String ¶
func (x *PauseDataPipelineRunResponse) String() string
type ResumeDataPipelineRunRequest ¶
type ResumeDataPipelineRunRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*ResumeDataPipelineRunRequest) Descriptor
deprecated
func (*ResumeDataPipelineRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResumeDataPipelineRunRequest.ProtoReflect.Descriptor instead.
func (*ResumeDataPipelineRunRequest) GetName ¶
func (x *ResumeDataPipelineRunRequest) GetName() string
func (*ResumeDataPipelineRunRequest) GetNamespace ¶
func (x *ResumeDataPipelineRunRequest) GetNamespace() string
func (*ResumeDataPipelineRunRequest) ProtoMessage ¶
func (*ResumeDataPipelineRunRequest) ProtoMessage()
func (*ResumeDataPipelineRunRequest) ProtoReflect ¶
func (x *ResumeDataPipelineRunRequest) ProtoReflect() protoreflect.Message
func (*ResumeDataPipelineRunRequest) Reset ¶
func (x *ResumeDataPipelineRunRequest) Reset()
func (*ResumeDataPipelineRunRequest) String ¶
func (x *ResumeDataPipelineRunRequest) String() string
type ResumeDataPipelineRunResponse ¶
type ResumeDataPipelineRunResponse struct {
// contains filtered or unexported fields
}
func (*ResumeDataPipelineRunResponse) Descriptor
deprecated
func (*ResumeDataPipelineRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResumeDataPipelineRunResponse.ProtoReflect.Descriptor instead.
func (*ResumeDataPipelineRunResponse) ProtoMessage ¶
func (*ResumeDataPipelineRunResponse) ProtoMessage()
func (*ResumeDataPipelineRunResponse) ProtoReflect ¶
func (x *ResumeDataPipelineRunResponse) ProtoReflect() protoreflect.Message
func (*ResumeDataPipelineRunResponse) Reset ¶
func (x *ResumeDataPipelineRunResponse) Reset()
func (*ResumeDataPipelineRunResponse) String ¶
func (x *ResumeDataPipelineRunResponse) String() string
type UnimplementedDataPipelineRunServiceServer ¶
type UnimplementedDataPipelineRunServiceServer struct { }
UnimplementedDataPipelineRunServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataPipelineRunServiceServer) AbortDataPipelineRun ¶
func (*UnimplementedDataPipelineRunServiceServer) AbortDataPipelineRun(context.Context, *AbortDataPipelineRunRequest) (*AbortDataPipelineRunResponse, error)
func (*UnimplementedDataPipelineRunServiceServer) CreateDataPipelineRun ¶
func (*UnimplementedDataPipelineRunServiceServer) CreateDataPipelineRun(context.Context, *CreateDataPipelineRunRequest) (*CreateDataPipelineRunResponse, error)
func (*UnimplementedDataPipelineRunServiceServer) DeleteDataPipelineRun ¶
func (*UnimplementedDataPipelineRunServiceServer) DeleteDataPipelineRun(context.Context, *DeleteDataPipelineRunRequest) (*DeleteDataPipelineRunResponse, error)
func (*UnimplementedDataPipelineRunServiceServer) GetDataPipelineRun ¶
func (*UnimplementedDataPipelineRunServiceServer) GetDataPipelineRun(context.Context, *GetDataPipelineRunRequest) (*GetDataPipelineRunResponse, error)
func (*UnimplementedDataPipelineRunServiceServer) ListDataPipelineRuns ¶
func (*UnimplementedDataPipelineRunServiceServer) ListDataPipelineRuns(context.Context, *ListDataPipelineRunRequest) (*ListDataPipelineRunResponse, error)
func (*UnimplementedDataPipelineRunServiceServer) PauseDataPipelineRun ¶
func (*UnimplementedDataPipelineRunServiceServer) PauseDataPipelineRun(context.Context, *PauseDataPipelineRunRequest) (*PauseDataPipelineRunResponse, error)
func (*UnimplementedDataPipelineRunServiceServer) ResumeDataPipelineRun ¶
func (*UnimplementedDataPipelineRunServiceServer) ResumeDataPipelineRun(context.Context, *ResumeDataPipelineRunRequest) (*ResumeDataPipelineRunResponse, error)
func (*UnimplementedDataPipelineRunServiceServer) UpdateDataPipelineRun ¶
func (*UnimplementedDataPipelineRunServiceServer) UpdateDataPipelineRun(context.Context, *UpdateDataPipelineRunRequest) (*UpdateDataPipelineRunResponse, error)
type UpdateDataPipelineRunRequest ¶
type UpdateDataPipelineRunRequest struct { Datapipelinerun *v1alpha1.DataPipelineRun `protobuf:"bytes,1,opt,name=datapipelinerun,proto3" json:"datapipelinerun,omitempty"` FieldMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"` // contains filtered or unexported fields }
func (*UpdateDataPipelineRunRequest) Descriptor
deprecated
func (*UpdateDataPipelineRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDataPipelineRunRequest.ProtoReflect.Descriptor instead.
func (*UpdateDataPipelineRunRequest) GetDatapipelinerun ¶ added in v0.4.480
func (x *UpdateDataPipelineRunRequest) GetDatapipelinerun() *v1alpha1.DataPipelineRun
func (*UpdateDataPipelineRunRequest) GetFieldMask ¶ added in v0.4.422
func (x *UpdateDataPipelineRunRequest) GetFieldMask() *field_mask.FieldMask
func (*UpdateDataPipelineRunRequest) ProtoMessage ¶
func (*UpdateDataPipelineRunRequest) ProtoMessage()
func (*UpdateDataPipelineRunRequest) ProtoReflect ¶
func (x *UpdateDataPipelineRunRequest) ProtoReflect() protoreflect.Message
func (*UpdateDataPipelineRunRequest) Reset ¶
func (x *UpdateDataPipelineRunRequest) Reset()
func (*UpdateDataPipelineRunRequest) String ¶
func (x *UpdateDataPipelineRunRequest) String() string
type UpdateDataPipelineRunResponse ¶
type UpdateDataPipelineRunResponse struct {
// contains filtered or unexported fields
}
func (*UpdateDataPipelineRunResponse) Descriptor
deprecated
func (*UpdateDataPipelineRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDataPipelineRunResponse.ProtoReflect.Descriptor instead.
func (*UpdateDataPipelineRunResponse) ProtoMessage ¶
func (*UpdateDataPipelineRunResponse) ProtoMessage()
func (*UpdateDataPipelineRunResponse) ProtoReflect ¶
func (x *UpdateDataPipelineRunResponse) ProtoReflect() protoreflect.Message
func (*UpdateDataPipelineRunResponse) Reset ¶
func (x *UpdateDataPipelineRunResponse) Reset()
func (*UpdateDataPipelineRunResponse) String ¶
func (x *UpdateDataPipelineRunResponse) String() string