v1

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
}

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

type CreateDataPipelineRunRequest struct {
	Datapipelinerun *v1alpha1.DataPipelineRun `protobuf:"bytes,1,opt,name=datapipelinerun,proto3" json:"datapipelinerun,omitempty"`
	// contains filtered or unexported fields
}

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

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)
}

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)
	// contains filtered or unexported methods
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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

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
}

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

type UnimplementedDataPipelineRunServiceServer struct {
}

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

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
}

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